个人中心
文章发布
退出
作者热门文章
- mongodb - 在 MongoDB mapreduce 中，如何展平值对象？
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗？
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
25
4
我的问题与 this question 有关之前问过。在我使用队列在生产者和消费者线程之间进行通信的情况下，人们通常会建议使用 LinkedBlockingQueue 或 ConcurrentLinkedQueue？
使用其中一种的优点/缺点是什么？
从 API 的角度来看，我可以看到的主要区别是 LinkedBlockingQueue 可以选择有界。
最佳答案
对于生产者/消费者线程，我不确定 ConcurrentLinkedQueue 是否是一个合理的选择 - 它没有实现 BlockingQueue，这是生产者/消费者排队 IMO。您必须调用 poll()，如果没有找到任何内容，请稍等片刻，然后再次进行轮询等...导致新项目进入时出现延迟，并导致效率低下空(由于不必要地从 sleep 中醒来)。
来自 BlockingQueue 的文档:
BlockingQueueimplementations are designed to be used primarily for producer-consumer queues
我知道它并没有严格说只有阻塞队列应该用于生产者-消费者队列，但即便如此......
关于java - LinkedBlockingQueue 与 ConcurrentLinkedQueue，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/1426754/
25
4
0
我在迭代时更新ConcurrentLinkedQueue。理论上，该队列上的迭代器在到达队列末尾之前不应停止。但是，在我的程序中(如下所示)，迭代器在迭代队列的初始状态(没有更新)后停止。我应该怎样解
假设我有 ConcurrentLinkedQueue 类型的类字段。此类的一些方法向该队列提供新元素。还有一些其他方法需要轮询此时队列中的所有元素。 我无法在循环中使用poll()，因为在循环尚未完成
作为我项目的一部分，我需要创建一个包含固定数量线程的线程池。每当线程分配给不同的进程时，我也需要与线程一起分配那么多 session 。我想使用 ConcurrentLinkedQueue (固定大小
我正在开发一个项目，其中我将某些数据包添加到队列中以便稍后处理(接下来的 600 毫秒滴答处理队列中的所有数据包)。 但是，我目前遇到了麻烦，因为当在同一周期中接收到两个数据包时，队列的行为非常奇怪。
我正在开发一个 Andoid 应用程序，它由在后台运行的服务和连接到该服务的一些 Activity 组成。该服务在它自己的进程上运行。 我的Service主要有3个类:ServiceMain、Serv
您能否澄清一下，我们是否需要使用显式同步或锁来使用 ConcurrentLinkedQueue？我特别想知道以下 ConcurrentLinkedQueue 方法是否需要同步调用。 添加 清除 尺寸
当前正在 for 循环中处理的元素是队列的头部吗？ private Queue users = new ConcurrentLinkedQueue(); for(User u : users){
我想知道在什么情况下 ConcurrentLinkedQueue 无法从其集合中删除元素。该项目存在，它在集合内但调用 SomeConcurrentLinkedQueue.remove(item) 不
我想实现一个监视器队列，两个不相关的线程可以共享它的附加内容。在这种情况下，仅使用 ConcurrentLinkedQueue 就足够了，还是我应该采取不同的做法？我想实现 Activity 对象设计
我想使用 ConcurrentLinkedQueue在原子中lock-free方式: 多个并发线程将事件插入队列，其他线程将处理它们。队列未绑定(bind)，我不希望任何线程等待或被锁定。然而，阅读部
阅读 Java's ConcurrentLinkedQueue Docs ，我想知道为什么实现无法存储大小: Beware that, unlike in most collections, the
我想使用 java.util.ConcurrentLinkedQueue 作为 Servlet 的非持久队列。这是该类(class)的 javadoc 中的简介。 An unbounded threa
如何在 Java 中使用 ConcurrentLinkedQueue？ 使用这个LinkedQueue，我需要担心队列中的并发吗？还是我只需要定义两个方法(一个从列表中检索元素，另一个将元素添加到列表
当我们使用诸如 ConcurrentLinkedQueue 甚至一些 BlockingQueue 之类的内置队列之一时，单个调用是原子的并且保证是线程安全的。 但是当对 API 的 5 次调用中，有
我有一个工作线程，它应该迭代 ArrayList 。其他线程可以添加和删除对象(队列)。但ArrayList不是线程安全的。使用 ConcurrentLinkedQueue 可以吗？而不是ArrayL
我有以下代码: Queue localMsgQueue; //inside the constructor localMsgQueue = new ConcurrentLinkedQueue(); p
我广泛使用 ConcurrentLinkedQueue 进行多消耗任务排队，以前从未遇到过此问题。场景如下: 用一些任务填充我的队列 运行多个线程(在本例中为 2 个)，这些线程将从队列中池化任务 当
我的线程永远运行并在 ConcurrentLinkedQueue#peek() 之后调用 ConcurrentLinkedQueue#poll()。 但在某些情况下，线程似乎挂起。我知道这有点含糊但是
我目前正在开发一个 Java 项目，该项目在原始数据包通过网络时对其进行处理。数据由libpcap读入，然后每个数据包放入一个byte[]，然后放入一个ConcurrentLinkedQueue，线程
使用ConcurrentLinkedQueue时出现以下错误: Error : local variables referenced from a lambda expression must be
我是一名优秀的程序员,十分优秀！