Java / PriorityQueue and Threads

Question

在我的应用程序中，我有 4 个线程向PriorityBlockingQueue添加元素，一个线程从中轮询元素。对于轮询线程，队列似乎无法访问。我想我必须采取措施使其线程安全。

在我获取第一个元素后，我清除了队列，它应该由其他 4 个填充线程再次填充。

轮询线程和填充线程位于保存PriorityBlockingQueue的同一类中。

这是轮询的代码：

private class UPPainter implements Runnable {
    @Override
    public void run() {
        while(queue.size() > 0) {
            ReceivedMsg msg = queue.poll();
            queue.clear();
            for(final IPacketListener c : listeners) {
                new Thread(new ListenerUp(c, msg)).start();
            }
        }
    }
}

Answer 1

当你的使用者线程启动时，队列可能是空的，所以大小 = 0 和 run（） 将退出。您必须实际等待输入消息。清除队列对我来说似乎没有意义吗？如果要"关闭"使用者线程，请发送特殊的队列结束消息。使用 queue.take（） 实际阻止，直到插入元素：

private class UPPainter implements Runnable {  
    @Override  
    public void run() {  
        while(true) {  
            ReceivedMsg msg = queue.take();  
            for(final IPacketListener c : listeners) {  
                new Thread(new ListenerUp(c, msg)).start();  
            }  
        }  
    }  
}