Il metodo migliore per ottenere oggetti da una BlockingQueue in un programma simultaneo?
-
09-06-2019 - |
Domanda
Qual è il metodo migliore per estrarre oggetti da una BlockingQueue, in un programma simultaneo, senza incorrere in una condizione di competizione?Attualmente sto facendo quanto segue e non sono convinto che sia il metodo migliore:
BlockingQueue<Violation> vQueue;
/*
in the constructor I pass in a BlockingQueue object
full of violations that need to be processed - cut out for brevity
*/
Violation v;
while ( ( v = vQueue.poll(500, TimeUnit.MILLISECONDS) ) != null ) {
// do stuff with the violation
}
Devo ancora raggiungere una condizione di gara...ma non sono sicuro che sia veramente sicuro.
Soluzione
class Producer implements Runnable {
private final BlockingQueue queue;
Producer(BlockingQueue q) { queue = q; }
public void run() {
try {
while (true) { queue.put(produce()); }
} catch (InterruptedException ex) { ... handle ...}
}
Object produce() { ... }
}
class Consumer implements Runnable {
private final BlockingQueue queue;
Consumer(BlockingQueue q) { queue = q; }
public void run() {
try {
while (true) { consume(queue.take()); }
} catch (InterruptedException ex) { ... handle ...}
}
void consume(Object x) { ... }
}
class Setup {
void main() {
BlockingQueue q = new SomeQueueImplementation();
Producer p = new Producer(q);
Consumer c1 = new Consumer(q);
Consumer c2 = new Consumer(q);
new Thread(p).start();
new Thread(c1).start();
new Thread(c2).start();
}
}
Questo esempio è stato tratto da Documenti JDK 1.6 di BlockingQueue
.Quindi puoi vedere che lo stai facendo nel modo giusto.Ecco la citazione che ti dice che deve funzionare:
Effetti sulla consistenza della memoria:Come per Altre raccolte e azioni simultanee in un thread prima di posizionare un oggetto in un BlockingQueue happen-before azioni successive all'accesso o alla l'eliminazione di tale elemento dal BlockingQueue in un altro thread.