如何使用ConcurrentLinkedQueue？

Question

如何ConcurrentLinkedQueue在Java中使用？
使用此方法LinkedQueue，我是否需要担心队列中的并发性？还是只需要定义两种方法（一种方法是从列表中检索元素，另一种方法是将元素添加到列表中）？
注意：显然，这两种方法必须同步。对？

编辑：
我想做的是：我有一类（在Java中），其中一种方法可从队列中检索项目，而另一类具有一种方法可将项目添加至队列。从列表中添加和检索的项目是我自己类的对象。

另一个问题：我需要在remove方法中执行以下操作：

while (queue.size() == 0){ 
  wait(); 
  queue.poll();
}

我只有一个消费者和一个生产者。

Answer 1

不，方法不需要同步，也不需要定义任何方法。它们已经在ConcurrentLinkedQueue中，只需使用它们即可。ConcurrentLinkedQueue在内部完成您需要的所有锁定和其他操作；您的生产者将数据添加到队列中，而消费者则对其进行轮询。

首先，创建您的队列：

Queue<YourObject> queue = new ConcurrentLinkedQueue<YourObject>();

现在，无论您在哪里创建生产者/消费者对象，都将其传递到队列中，以便它们有放置对象的位置（您可以为此使用setter，但是我更喜欢在构造函数中执行这种操作）：

YourProducer producer = new YourProducer(queue);

和：

YourConsumer consumer = new YourConsumer(queue);

并在您的生产者中添加一些东西：

queue.offer(myObject);

并在您的使用者中取出东西（如果队列为空，则poll（）将返回null，因此进行检查）：

YourObject myObject = queue.poll();

有关更多信息，请参见Javadoc。

如果需要阻止等待队列不为空，则可能要使用LinkedBlockingQueue，并使用take（）方法。但是，LinkedBlockingQueue具有最大容量（默认为Integer.MAX_VALUE，超过20亿），因此根据您的具体情况可能合适，也可能不合适。

如果只有一个线程将材料放入队列，而另一个线程将材料从队列中取出，则ConcurrentLinkedQueue可能会过大。当您可能有数百甚至数千个线程同时访问队列时，它的作用更大。您的需求可能会满足：

Queue<YourObject> queue = Collections.synchronizedList(new LinkedList<YourObject>());

这样做的好处是它锁定实例（队列），因此您可以在队列上进行同步以确保复合操作的原子性（如Jared所述）。您不能使用ConcurrentLinkedQueue来执行此操作，因为所有操作都是在不锁定实例的情况下完成的（使用java.util.concurrent.atomic变量）。如果要在队列为空时进行阻塞，则无需执行此操作，因为当队列为空时，poll（）只会返回null，而poll（）是原子的。检查poll（）是否返回null。如果是这样，请等待（），然后重试。无需锁定。

最后：

老实说，我只会使用LinkedBlockingQueue。对于您的应用程序来说，它仍然是多余的，但是很有可能会正常工作。如果性能不够（PROFILE！），则可以随时尝试其他方法，这意味着您不必处理任何同步的东西：

BlockingQueue<YourObject> queue = new LinkedBlockingQueue<YourObject>();

queue.put(myObject); // Blocks until queue isn't full.

YourObject myObject = queue.take(); // Blocks until queue isn't empty.

其他一切都一样。放置 可能 不会阻塞，因为您不太可能将20亿个对象放入队列。