java.util.ConcurrentLinkedQueue

Question

我想使用 java.util.ConcurrentLinkedQueue 作为 Servlet 的非持久队列。 这是该类(class)的 javadoc 中的简介。

An unbounded thread-safe queue based on linked nodes. A ConcurrentLinkedQueue is an appropriate choice when many threads will share access to a common collection. This queue does not permit null elements.

现在假设我在 servlet 上有 1000 个并发请求，每个线程都需要将一个对象放入 ConcurrentLinkedQueue。从描述中，我是否应该得出结论，处理负载没有问题？我需要的保证是:

1. 我自动获得线程安全保证，无需自己进行同步。
2. 如果流量负载超过 1000 个并发请求，我不会丢失任何请求。

谢谢

Answer 1

您实际上是在问三个不同的问题(其中两个是明确的，一个是隐含的。)这是它们以及我的答案:

<强>1。如果我使用 java.util.ConcurrentLinkedQueue，是否需要自己进行同步？

并发集合上的原子操作为您同步。换句话说，对队列的每个单独调用都保证线程安全，而无需您采取任何操作。 不保证线程安全的是您对非原子集合执行的任何操作。

例如，这是线程安全的，您无需执行任何操作:

queue.add(obj);

或

queue.poll(obj);

但是；对队列的非原子调用不是自动线程安全的。例如，以下操作不会自动是线程安全的:

if(!queue.isEmpty()) {
   queue.poll(obj);
}

最后一个不是线程安全的，因为很可能在调用 isEmpty 和调用 poll 之间，其他线程会在队列中添加或删除项目。执行此操作的线程安全方式如下:

synchronized(queue) {
    if(!queue.isEmpty()) {
       queue.poll(obj);
    }
}

再次...对队列的原子调用是自动线程安全的。非原子调用不是。

<强>2。如果有 1000 个并发请求，我是否保证不会丢失对 java.util.ConcurrentLinkedQueue 的调用？

因为这是一个无限制的实现，你可以保证无论同时发出多少请求，队列都不会丢失这些请求(因为队列的并发性......你可能会耗尽内存或类似的......但队列实现本身不会成为您的限制因素。)在 Web 应用程序中，还有其他机会“丢失”请求，但队列的同步(或缺乏同步)不会成为您的原因。

<强>3。 java.util.ConcurrentLinkedQueue 的性能是否足够好？

通常，当我们谈论并发时，我们会谈论“正确性”。我的意思是，并发类保证它们是线程安全的(或对死锁、饥饿等具有鲁棒性)。当我们谈论这个时，我们并没有对性能做出任何保证(调用集合的速度有多快are) - 我们只保证它们是“正确的”。

但是； ConcurrentLinkedQueue 是一个“无等待”实现，因此这可能是您可以获得的最佳性能。保证 servlet 负载性能(包括并发类的使用)的唯一方法是在负载下对其进行测试。