Synchr%ignore_a_1%nousQueue不存储元素，每个put操作需等待take操作完成，适用于生产者消费者直接传递数据的场景。1. 它无内部容量，插入和移除必须同步配对。2. 不支持null值，不能遍历。3. 常用于newCachedThreadPool线程池任务传递。4. 提供offer/poll等超时方法实现限时交互。5. 适合一对一同步传递，不适合缓冲或批量处理。示例中生产者调用put后阻塞，直到消费者调用take完成“握手”，数据直接传递。注意其性能依赖线程调度，调试困难因无中间状态。核心是理解其“只传递、不存储”的设计本质。
SynchronousQueue 是 Java 并发包 java.util.concurrent 中的一个特殊阻塞队列，它没有内部容量，每个插入操作必须等待另一个线程的对应移除操作，反之亦然。它适用于在生产者和消费者之间直接传递数据的场景，常用于线程池如 Executors.newCachedThreadPool() 中。
理解 SynchronousQueue 的工作方式
SynchronousQueue 不存储元素。当你调用 put() 方法时，该方法会阻塞，直到另一个线程调用 take() 来接收这个元素；同样，如果一个线程尝试 take()，它会一直等待直到有另一个线程执行 put()。这种“握手”机制实现了线程间直接的数据传递。
主要特点：
不支持 null 值 不能遍历，因为没有存储空间 非常适合工作窃取或高并发任务传递场景
基本使用示例：生产者-消费者模式
下面是一个简单的生产者和消费者通过 SynchronousQueue 通信的例子：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.SynchronousQueue;public class SynchronousQueueExample { public static void main(String[] args) { SynchronousQueue queue = new SynchronousQueue(); // 生产者线程 new Thread(() -> { try { System.out.println("生产者准备放入数据"); queue.put("Hello from producer"); System.out.println("数据已放入"); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); // 消费者线程 new Thread(() -> { try { System.out.println("消费者等待数据"); String data = queue.take(); System.out.println("收到数据: " + data); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); }}
运行结果会显示两个线程“握手”成功，数据从生产者直接传递给消费者。
使用 offer 和 poll 进行非阻塞或限时操作
除了阻塞的 put/take，SynchronousQueue 还提供非阻塞或超时版本的方法：
offer(E e)：尝试将元素放入队列，如果没有消费者等待，立即返回 false offer(E e, long timeout, TimeUnit unit)：最多等待指定时间，如果有消费者在此期间到来并接收，则返回 true poll(long timeout, TimeUnit unit)：尝试获取元素，最多等待指定时间
示例：带超时的交互
new Thread(() -> { try { boolean success = queue.offer("Timeout data", 2, TimeUnit.SECONDS); if (success) { System.out.println("数据发送成功"); } else { System.out.println("发送超时，无消费者接收"); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); }}).start();new Thread(() -> { try { Thread.sleep(3000); // 故意延迟，使 offer 超时 String data = queue.poll(5, TimeUnit.SECONDS); System.out.println("消费者最终收到: " + data); } catch (InterruptedException e) { Thread.currentThread().interrupt(); }}).start();
适用场景与注意事项
SynchronousQueue 最适合用于：
线程池中任务传递，如 CachedThreadPool 动态创建线程处理任务 需要严格一对一传递的同步场景 实现“工作移交”而非“任务缓存”的设计
需要注意：
性能依赖线程调度，若配对不及时可能导致线程长时间阻塞 不适合用于缓冲或批量处理场景 调试时不易观察中间状态，因为没有队列内容可查看
基本上就这些。SynchronousQueue 虽然不常用，但在特定高并发协作场景下非常高效。关键是要理解它“不存储、只传递”的本质。
以上就是在Java中如何使用同步队列SynchronousQueue的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/34911.html
微信扫一扫 
支付宝扫一扫 
