java - 从不同线程检查时，ConcurrentLinkedQueue 大小返回零

Question

我有以下代码：

Queue<Message> localMsgQueue;
//inside the constructor
localMsgQueue = new ConcurrentLinkedQueue<Message>();

public void AddMsg(Message m)
{
    localMsgQueue.offer(m);     
    System.out.println("^^"+localMsgQueue.size());

}
public void GetMsg() {
    System.out.println("+++" + localMsgQueue.size());       
}

在这里，在初始化队列的主线程中调用 AddMsg。GetMsg 不时从不同的线程调用。

我的问题是 AddMsg 中的大小检查返回队列中正确数量的元素，而 GetMsg 总是返回零大小，尽管队列包含元素。

有人可以指出这里的问题吗？这是我第一次使用 Java 并发队列，所以不知道发生了什么。

Answer 1

您可能正在构建两个不同的ConcurrentLinkedQueue<Message>对象。

在类的构造函数中放置一个断点，看看它被击中了多少次。

// put a breakpoint here
localMsgQueue = new ConcurrentLinkedQueue<Message>();