如何在Java中使用SynchronousQueue_技术教程_奈瑶·映南科技互联网学院

SynchronousQueue不存储元素，每个put需等待take完成，适用于线程间直接协作，如生产者-消费者模型、即时任务处理及高并发线程池等场景。

SynchronousQueue 是 Java 并发包（java.util.concurrent）中一个特殊的阻塞队列，它不会真正存储元素。每个 put 操作必须等待另一个线程执行 take 操作，反之亦然。这种“直接交接”的机制使得 SynchronousQueue 更像是一个数据的“传递点”，而不是传统意义上的队列。它常用于线程之间的直接协作通信场景。

理解 SynchronousQueue 的特点

SynchronousQueue 最显著的特点是：

不存储元素：你无法往队列中添加元素并保留它，put 的元素必须立刻被另一个线程 take 走。
线程配对交换：生产者线程和消费者线程必须同时准备好才能完成一次数据传递。
支持公平与非公平策略：构造时可指定是否采用公平模式（FIFO），默认是非公平的（性能更高但顺序不确定）。

注意：调用 offer() 或 poll() 非阻塞方法通常会失败（返回 false 或 null），因为没有缓冲空间。建议使用阻塞的 put() 和 take() 方法。

基本使用示例：生产者-消费者模型

下面是一个简单的例子，展示两个线程通过 SynchronousQueue 传递字符串消息：

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(); // 阻塞直到有数据被 put
                System.out.println("消费者收到: " + data);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }).start();
    }
}

运行结果通常是：

消费者先启动并阻塞在 take()
生产者执行 put()，唤醒消费者完成交接
两者几乎同时完成操作

实际应用场景

SynchronousQueue 适用于需要严格同步的场景：

工作线程分配任务：主线程生成任务，工作线程立即处理，不缓存任务。
手递手通信：确保每个任务都被即时处理，避免堆积。
高并发线程池：比如 Executors.newCachedThreadPool() 内部就使用 SynchronousQueue，新提交的任务如果没有空闲线程就会创建新线程来处理。