Executors - wie kann ich die Queue leeren?

[el richbo]

Hi,

Ich will Executors verwenden...genauergesagt einen SingleThreadExecutor.

Wann immer ich einen neuen Task submitte sollen vorher entweder
a) alle Tasks in der Queue entfernt werden.
b) alle Tasks in der Queue die noch nicht ausgefuehrt wurden entfernt werden. Ein aktuell aktiver Task soll nicht entfernt werden und darf zuende arbeiten. Dann wird der neue hinzugefuegte Task ausgefuehrt.

Wie kann ich das am besten umsetzen?

Danke!
el richbo

 

[byte]

Schreib Dir einen eigenen ExecutorService und leite ihn von ThreadPoolExecutor ab. Dann hast Du direkten Zugriff auf die Queue und kannst das von Dir gewünschte implementieren.

 

[el richbo]

Schreib Dir einen eigenen ExecutorService und leite ihn von ThreadPoolExecutor ab. Dann hast Du direkten Zugriff auf die Queue und kannst das von Dir gewünschte implementieren.

Hab das auch so aehnlich gemacht. Komme aber nicht weiter - Problem:

1. Leere ich die Queue auf korrekte Weise? Sollte ich nicht lieber auf den Executor zugreifen als auf die Queue?
2. Wie leere ich die Queue bis auf den grade laufenden Task?

public class CanvasUpdateExecutorService {
	
	public static void main(String[] args) {
		CanvasUpdateExecutorService cues = new CanvasUpdateExecutorService();
		cues.updateCanvas("", null);
	}
	
	private ScheduledThreadPoolExecutor executor;
	
	public CanvasUpdateExecutorService() {
		executor = new ScheduledThreadPoolExecutor(1);
	}

	public void updateCanvas(String url, JLabel canvas) {
		dummySchedule();
		dummySchedule();
		dummySchedule();
		emptyExecutor();
		System.out.println(executor.getTaskCount());
	}

	private void dummySchedule() {
		executor.schedule(new Runnable(){
			@Override
			public void run() {
				System.out.println("Hello World!");
			}
		}, 1000, TimeUnit.MILLISECONDS);
		
		System.out.println(executor.getTaskCount());
	}

	private void emptyExecutor() {
		BlockingQueue<Runnable> queue = executor.getQueue();
		ArrayList<Runnable> c = new ArrayList<Runnable>();
		queue.retainAll(c);
		System.out.println(c.size());
	}

}