- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
我看到了 BlockingQueue 的这些实现,无法理解它们之间的区别。到目前为止我的结论:
那么我什么时候需要SynchronousQueue?此实现的性能是否优于 LinkedBlockingQueue?
为了让它更复杂......为什么 Executors.newCachedThreadPool 使用 SynchronousQueue 而其他(Executors.newSingleThreadExecutor 和 Executors.newFixedThreadPool ) 使用 LinkedBlockingQueue?
编辑
第一个问题解决了。但是我仍然不明白为什么 Executors.newCachedThreadPool 使用 SynchronousQueue 而其他(Executors.newSingleThreadExecutor 和 Executors.newFixedThreadPool)使用 LinkedBlockingQueue?
我得到的是,使用 SynchronousQueue,如果没有空闲线程,生产者将被阻塞。但是由于线程的数量实际上是无限的(如果需要,将创建新的线程),这永远不会发生。那么为什么要使用 SynchronousQueue?
最佳答案
SynchronousQueue
是一种非常特殊的队列——它在Queue
的接口(interface)后面实现了一种集合方式(生产者等待消费者准备好,消费者等待生产者准备好)。 .
因此,您可能仅在需要特定语义的特殊情况下才需要它,例如 Single threading a task without queuing further requests .
使用 SynchronousQueue
的另一个原因是性能。 SynchronousQueue
的实现似乎已经过高度优化,所以如果您只需要一个集合点(如 Executors.newCachedThreadPool()
的情况,消费者是“按需”创建的,因此队列项目不会累积),您可以通过使用 SynchronousQueue
获得性能提升.
简单的综合测试表明,在简单的单生产者-单消费者场景中,双核机器吞吐量为SynchronousQueue
比 LinkedBlockingQueue
的吞吐量高约 20 倍和 ArrayBlockingQueue
队列长度= 1。当队列长度增加时,它们的吞吐量上升并几乎达到SynchronousQueue
的吞吐量.这意味着 SynchronousQueue
与其他队列相比,在多核机器上具有较低的同步开销。但同样,只有在需要伪装成 Queue
的集合点的特定情况下才重要。 .
编辑:
这是一个测试:
public class Test {
static ExecutorService e = Executors.newFixedThreadPool(2);
static int N = 1000000;
public static void main(String[] args) throws Exception {
for (int i = 0; i < 10; i++) {
int length = (i == 0) ? 1 : i * 5;
System.out.print(length + "\t");
System.out.print(doTest(new LinkedBlockingQueue<Integer>(length), N) + "\t");
System.out.print(doTest(new ArrayBlockingQueue<Integer>(length), N) + "\t");
System.out.print(doTest(new SynchronousQueue<Integer>(), N));
System.out.println();
}
e.shutdown();
}
private static long doTest(final BlockingQueue<Integer> q, final int n) throws Exception {
long t = System.nanoTime();
e.submit(new Runnable() {
public void run() {
for (int i = 0; i < n; i++)
try { q.put(i); } catch (InterruptedException ex) {}
}
});
Long r = e.submit(new Callable<Long>() {
public Long call() {
long sum = 0;
for (int i = 0; i < n; i++)
try { sum += q.take(); } catch (InterruptedException ex) {}
return sum;
}
}).get();
t = System.nanoTime() - t;
return (long)(1000000000.0 * N / t); // Throughput, items/sec
}
}
这是我机器上的结果:
关于java - BlockingQueue : What are the differences between SynchronousQueue and LinkedBlockingQueue 的实现,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5102570/
我的理解是1.5加入了callable,runnable接口(interface)保持原样,防止世界末日。为什么我不能实例化 ThreadPoolExecutor (core, max, tu, un
我正在制作一个包含两个线程的应用程序:其中一个向 LinkedBlockingQueue 写入一个值,另一个正在读取。我正在使用 ScheduledExecutorService 在某个时间段内以秒为
我正在尝试 Autowiring 参数化的阻塞队列: @Bean(name = "saveProductQueue") public BlockingQueue saveProductQueue()
我正在实现一个程序,其中主线程将各种消息推送到工作线程,而工作线程将工作结果推送回主线程。 为此,我计划使用两个队列,一个用于推送到工作线程,另一个用于从中拉出。 据我了解,线程会缓存对象,因此如果它
我正在使用 RabbitMQ,它默认为消费者使用 LinkedBlockingQueue 。它有一个阻塞的 nextDelivery() 方法,该方法基本上调用队列上的 take() 。 但是如果在调
我有 n 个生产者线程通过 BlockingQueue 为 1 个消费者线程提供数据。我正在使用 .put 和 .take (后者当 .peek != null 时)。除了明显在传输过程中不可避免的数
我已经实现了一个带有套接字线程池的两人游戏。每个玩家都连接到自己的线程。我按照this添加了一个消息队列系统文章。 问题是消息滞后。第一个玩家的第一个响应会按预期添加到 messageQueue 中。
据我所知,BlockingCollection 使用非繁忙等待,这是对新项目/回调的通知。所以我不明白它是如何阻塞的,但我认为我可能混合了阻塞的线程和阻塞的共享对象访问? 最佳答案 这是一个很好的解释
我的 Android 应用程序有一个长时间运行的后台服务,据我所知,它在应用程序的主线程中运行,因此,任何耗时或阻塞的任务都应移至单独的线程。 现在,情况是这样的,我不明白/困惑: 当我从一个 Act
我在数据库前面使用 LinkedBlockingQueue。一个线程写入队列,另一个线程从队列读取。 我认为两个并发写入是不可能的。但是是否有可能一个线程写入而另一个线程同时从队列中读取呢?如果没有,
我有一个在单个后台线程上处理工作事件的 BlockingQueue。各种线程调用 add 将一些工作添加到队列中,单个后台线程调用 take 获取工作并一次处理一个。最终可能是停止处理工作的时候了,我
我在多线程系统中使用 BlockingQueue,其中同步块(synchronized block)将项目添加到列表中。有时它不会将项目添加到列表中,它遗漏的项目是随机的。我尝试将以下行添加到代码中,
我有以下阻塞队列; final BlockingQueue blockingQueue = new LinkedBlockingQueue(); 在哪里 public class Message
这个问题的标题让我怀疑这是否存在,但仍然: 我感兴趣的是是否有 Java 的 BlockingQueue 的实现,它受大小限制,从不阻塞,而是在尝试入队太多元素时抛出异常。 编辑 - 我将 Block
假设我有 BlockingQueue 并且一些线程被称为 take() 但此时队列是空的。假设我以某种方式知道将来不会有新元素出现在队列中。如何释放那些被称为 take() 的线程等待?谢谢! p
我想要一个线程安全的容器,它会阻止调用者,直到有项目可用为止。项目将以每秒 1000 秒的速度添加到此容器中,但不会以相同的速度排出。因此,我希望容器不允许重复。我围绕 LinkedBlockingQ
我正在使用 BlockingQueue(LinkedBlockingQueue) 在多个线程之间同步数据。请看下图。 主线程是一个生产者,它生产对象,然后将它们放入每个消费者的队列中(线程2-10)。
我有一个容量为 1 的 BlockingQueue。它存储收到的股票的最后价格。价格保留在队列中,直到客户端轮询队列。然后,我有一个名为 getLatestPrice() 的方法,它应该返回股票的最新
我的 Java 代码中使用 BlockingQueue 时存在潜在的竞争条件,我想知道如何修改代码来避免这种情况: private static BlockingQueue ftpQueue = ne
我有一种情况需要 BlockingQueue 上的方法 peekWait。我会将此方法描述为 retrieves but not remove the head of the queue, waiti
我是一名优秀的程序员,十分优秀!