SynchronousQueue不存储元素,任务通过直接交接在生产者和消费者线程间传递。1. 在线程池中用于无缓冲任务调度,如newCachedThreadPool,有空闲线程则直接执行,否则新建线程。2. 实现一对一同步通信,put()和take()配对阻塞,适合精确数据传递场景。3. 作为背压机制,防止任务积压,控制并发线程数,避免资源耗尽。其核心是“不缓存、直接传递”,适用于实时性高、需控制并发的场景,但不可作为普通队列使用。

Java中的SynchronousQueue是一种特殊的阻塞队列,它不会真正存储元素。每个插入操作都必须等待另一个线程的移除操作,反之亦然。这种“直接交接”的特性决定了它的使用场景非常特定且高效。
任务提交与工作线程的直接交接
在一些生产者-消费者模型中,你希望任务不经过中间缓冲,直接由生产者交给消费者处理,避免任务堆积和内存浪费。
- 比如在线程池中使用
SynchronousQueue作为任务队列(如Executors.newCachedThreadPool()的底层实现)。 - 当有新任务提交时,如果存在空闲工作线程正在等待任务,任务会直接交由该线程执行;如果没有空闲线程,则创建新线程。
- 这种方式适合执行大量短期异步任务的场景,响应快,资源利用灵活。
线程间的一对一同步通信
当你需要两个线程之间进行精确的数据传递,一个线程生产一个数据,另一个线程消费后才能继续,这时SynchronousQueue可以充当“手递手”交接的通道。
- 例如,在某些协同计算或信号传递场景中,主线程生成参数后必须等待工作线程完成处理并返回结果,使用
put()和take()能自然实现这种配对等待。 - 相比使用
BlockingQueue加锁或CountDownLatch,代码更简洁,语义更清晰。
控制并发线程数量,避免资源耗尽
由于SynchronousQueue不缓存任务,当没有消费者时,生产者的put()操作会被阻塞,这可以作为一种背压机制。
立即学习“Java免费学习笔记(深入)”;
- 在高负载系统中,防止生产者过快提交任务导致内存溢出。
- 配合线程池使用时,能有效控制最大线程数,超出的提交请求将触发拒绝策略,而不是无限制排队。
基本上就这些。SynchronousQueue的核心价值在于“不缓存、直接传递”,适用于强调实时交接、控制并发、避免积压的场景。用好了很高效,但要注意它不适合用于需要缓冲的任务流。不复杂但容易忽略的是:它不是队列的“常规替代品”,而是一种特殊的同步工具。










