Лучший способ получить объекты из BlockingQueue в параллельной программе?
-
09-06-2019 - |
Вопрос
Каков наилучший метод для извлечения объектов из BlockingQueue в параллельной программе без выполнения условия гонки?В настоящее время я делаю следующее, и я не уверен, что это лучший метод:
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
}
Я еще не достиг состояния гонки...но я не слишком уверен, что это действительно безопасно.
Решение
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();
}
}
Этот пример был взят из Документы JDK 1.6 о BlockingQueue
.Таким образом, вы можете видеть, что делаете это правильно.Вот цитата, которая говорит вам, что это должно сработать:
Эффекты согласованности памяти:Как и в случае с другими параллельными коллекциями, действия в потоке перед помещением объекта в очередь блокировки выполняются-до действий, следующих за доступом или удалением этого элемента из очереди блокировки в другом потоке.