Java 并发编程中怎么使用 SynchronousQueue 传递零容量数据-java教程-PHP中文网

synchronousqueue 是一种不存储元素的同步点，核心语义是“直接移交”，生产者与消费者必须配对阻塞协作，容量恒为0，适用于强耦合、低延迟的线程间协作场景。

java 并发编程中怎么使用 synchronousqueue 传递零容量数据

SynchronousQueue 不是用于“传递零容量数据”的容器，它根本不存储元素——它的核心语义是“直接移交”（hand-off），即生产者线程必须等待消费者线程就绪后才能完成插入操作，反之亦然。所谓“零容量”，指其内部队列长度恒为 0，任何 offer()、put() 都不会成功返回，除非同时有另一个线程正在执行 poll() 或 take()。

理解 SynchronousQueue 的协作机制

它本质上是一个同步点（synchronization point），不是缓冲区。每个插入操作都必须与一个移除操作配对发生，就像两个人面对面交接一个物品：交不出去就一直等着，接不到也一直等着。

调用 put(e) 会阻塞，直到另一个线程调用 take()；
调用 take() 会阻塞，直到另一个线程调用 put(e)；
offer(e, timeout, unit) 和 poll(timeout, unit) 支持超时，避免无限等待；
isEmpty() 始终返回 true，size() 永远是 0 —— 它没有“待处理数据”的概念。

典型使用场景：生产者-消费者强耦合协作

适合需要严格一对一、无缓冲、低延迟协调的场景，例如：

线程池中 newCachedThreadPool() 的默认工作队列，任务提交和空闲线程唤醒直接绑定；
两个线程之间传递控制信号或单次事件（如“准备就绪”、“开始执行”）；
构建无锁管道（pipeline）中相邻阶段的精确同步点。

示例：主线程通知工作线程开始处理，并等待其完成确认：

Java Maven Common

Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。

下载

SynchronousQueue<string> queue = new SynchronousQueue();
Thread worker = new Thread(() -> {
    try {
        String cmd = queue.take(); // 等待指令
        System.out.println("收到指令: " + cmd);
        // 执行任务...
        queue.put("DONE"); // 发送完成信号
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
});
worker.start();

queue.put("START"); // 主线程发出指令，阻塞直到 worker take
String result = queue.take(); // 阻塞等待 worker put DONE
System.out.println(result); // 输出 DONE
</string>