在并发程序中从 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
. 。所以你可以看到你正在以正确的方式做这件事。以下引用告诉您它必须起作用:
内存一致性影响:与其他并发集合一样,将对象放入块中的操作之前,在另一个线程中访问或删除该元素之后的操作之前发生了操作。
不隶属于 StackOverflow