Java 中怎么使用 SynchronousQueue 实现无存储空间的线程安全托付-java教程-PHP中文网

synchronousqueue 是一种不存储元素的阻塞队列，每个 put 必须等待 take、反之亦然，实现线程间直接交付；它无容量、不支持 peek/size，适用于生产者-消费者紧耦合或线程池无缓冲调度。

java 中怎么使用 synchronousqueue 实现无存储空间的线程安全托付

SynchronousQueue 是 Java 并发包（java.util.concurrent）中一种特殊的阻塞队列，它**不存储元素**——每个插入操作（put）必须等待另一个线程执行对应的移除操作（take），反之亦然。这种“手递手”式的交接机制，天然适合实现**无缓冲、线程安全的直接交付（hand-off）**，常用于工作窃取、生产者-消费者紧耦合协作等场景。

理解 SynchronousQueue 的核心行为

它不是传统意义上的“队列”，而是一个传递通道：

调用 put(e) 的线程会**阻塞**，直到另一个线程调用 take() 接收该元素；
调用 take() 的线程也会**阻塞**，直到另一个线程调用 put(e) 提供元素；
构造时不能指定容量（始终为 0），也不支持 peek()、size() 等查看类操作（size() 永远返回 0）；
线程安全由内部锁或 CAS 保证，无需额外同步。

典型用法：生产者-消费者直接托付

下面是一个最小可运行示例，模拟主线程（生产者）向工作线程（消费者）直接交付任务：

import java.util.concurrent.*;

public class SynchronousQueueExample {
    public static void main(String[] args) throws InterruptedException {
        SynchronousQueue<string> queue = new SynchronousQueue();

        // 启动消费者线程
        Thread consumer = new Thread(() -> {
            try {
                String task = queue.take(); // 阻塞等待
                System.out.println("处理任务: " + task);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });
        consumer.start();

        // 主线程作为生产者，直接交付
        queue.put("发送邮件"); // 阻塞，直到 consumer 调用 take()
        consumer.join(); // 等待消费完成
    }
}</string>

注意：若消费者未就绪就调用 put，生产者会一直阻塞；反之亦然。这是“托付”的本质——双方必须协调好时机。

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

配合线程池实现无缓冲任务调度

更实用的方式是结合 Executors.newCachedThreadPool()（其默认使用 SynchronousQueue）：

新任务提交时，若无空闲线程，线程池会立即创建新线程（因为队列无法暂存任务）；
任务不会排队等待，而是“即来即交”，避免积压和内存占用；
适用于任务突发性强、执行时间短、希望快速响应的场景。

你也可以显式构造：

ExecutorService executor = new ThreadPoolExecutor(
    0, Integer.MAX_VALUE,
    60L, TimeUnit.SECONDS,
    new SynchronousQueue(), // 关键：无存储
    new ThreadPoolExecutor.CallerRunsPolicy()
);

注意事项与替代建议

使用 SynchronousQueue 需谨慎权衡：

阻塞是常态：没有“缓冲”意味着任何一方慢都会拖住另一方，不适合异步解耦；
不支持超时的批量操作：如 drainTo 不可用；
调试困难：因无中间状态，死锁或饥饿需靠线程 dump 分析；
若需要轻量缓冲，考虑 LinkedTransferQueue（支持带等待的 transfer 和非阻塞 tryTransfer）或小容量 ArrayBlockingQueue。