在并发程序中从 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
}
我还没有达到比赛条件......但是,我不太确定这是否真的安全。