Interject Java Oggetti eseguibili in ExecutorService

Question

Ho un oggetto ExecutorService pool a thread singolo. A un certo momento in futuro verranno aggiunte le attività da eseguire utilizzando il metodo submit(). La mia comprensione è che l'invio invierà aggiungere il Runnable inviato alla fine dell'elenco di attività da eseguire. Tuttavia, ho una situazione in cui, in base a un booleano, potrei voler inviare il runnable alla parte anteriore delle attività da eseguire. Non voglio che ciò influisca sul compito corrente, solo che il prossimo compito sarà quello che ho appena dato. Un metodo di esempio è riprodotto di seguito. Come faccio a fare questo?

Grazie

private ExecutorService singleLoadPool = Executors.newSingleThreadExecutor(); 
public void submitTask(Runnable run, boolean doNow) { 
    if (doNow) 
     singleLoadPool.submitFront(run); // This is the method I'm looking for 
    else 
     singleLoadPool.submit(run); 
} 

Answer 1

mia preferenza sarebbe usare un LinkedBlockingDeque. Supporta direttamente inserimenti/rimuovi posizionali - putFirst(e)/takeFirst() e putLast(e)/takeLast() - che è il tuo requisito principale - non devi implementare uno Comparator per i tuoi elementi. Anche questo è limitato - il che significa che fornisce sicurezza contro OutOfMemoryError.

modifica In risposta all'ultima domanda:

In primo luogo, hanno l'ExecutorService come

ExecutorService executorService = new ThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, workQueue);

In secondo luogo, la domanda importante è: qual è il workQueue?

Il workQueue è un involucro sottile su qualsiasi BlockingQueue attuazione, che delega tutti i metodi per un'istanza LinkedBlockingDeque che contiene, ad eccezione del metodo offer(), che è chiamato su di essa dalla ThreadPoolExecutor e che deve venire ignorate, come questo:

 public boolean offer(E e) { 
     if(doNow) 
     return linkedBlockingDequeInstance.offerFirst(e); 
     else 
     return linkedBlockingDequeInstance.offerLast(e); 
    } 

Naturalmente quando si modifica qualsiasi metodo - è necessario fare attenzione a preservare la sicurezza dei thread e il suo generale contract.Definitely questo richiede un'attenta riflessione e test rigorosi.

Answer 2

penso che il tuo approccio migliore per questo sarebbe di instantiate a ThreadPoolExecutor con un PriorityBlockingQueue. In particolare, utilizzare un costruttore di PriorityBlockingQueue che accetta un Comparator. Il tuo Comparator sarà ciò che utilizzerai per implementare la tua 'priorità'.

PriorityBlockingQueue<Runnable> workQueue = new PriorityBlockingQueue<Runnable>(20, yourPriorityComparator); 
ExecutorService executorService = new ThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, workQueue);