Java 中可通过 SynchronousQueue 精确模拟 Go 的无缓冲通道语义：发送线程必须与接收线程同步阻塞配对，无中间存储，严格满足“发送即接收”的协作模型。
java 中可通过 `synchronousqueue` 精确模拟 go 的无缓冲通道语义：发送线程必须与接收线程同步阻塞配对，无中间存储，严格满足“发送即接收”的协作模型。
Go 的无缓冲通道（unbuffered channel）是协程间直接、同步通信的核心原语：ch 操作会<strong>永久阻塞</strong>，直到另一 goroutine 正在执行 <code>；反之亦然。这种“握手式”通信消除了缓冲区，天然规避了竞态与数据滞留，强调协作而非解耦。
在 Java 中，java.util.concurrent.SynchronousQueue 正是为此场景设计的标准类——它不存储任何元素，每个 put() 调用必须等待另一个线程执行 take()，反之亦然。其内部采用高效的无锁算法（如 LIFO/公平模式下的双栈或双队列），性能接近底层系统调用，且完全符合 JMM 规范。
以下是一个典型示例，模拟 Go 中两个 goroutine 通过无缓冲 channel 交换整数：
import java.util.concurrent.*;
public class UnbufferedChannelExample {
public static void main(String[] args) throws InterruptedException {
// 等效于 Go 中的: ch := make(chan int)
SynchronousQueue<Integer> ch = new SynchronousQueue<>();
Thread sender = new Thread(() -> {
try {
System.out.println("Sender: waiting to send...");
ch.put(42); // 阻塞，直到 receiver 调用 take()
System.out.println("Sender: sent 42");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
Thread receiver = new Thread(() -> {
try {
System.out.println("Receiver: waiting to receive...");
int value = ch.take(); // 阻塞，直到 sender 调用 put()
System.out.println("Receiver: received " + value);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
receiver.start();
Thread.sleep(100); // 确保 receiver 先启动并进入 take() 阻塞
sender.start();
sender.join();
receiver.join();
}
}⚠️ 注意事项：
立即学习“Java免费学习笔记（深入）”；
-
SynchronousQueue不可迭代、不可遍历（size()始终为 0，isEmpty()恒为true），这是其无缓冲本质的体现； - 不支持
null元素（抛出NullPointerException）； - 构造时可选择公平模式（
new SynchronousQueue(true)），确保 FIFO 调度，避免线程饥饿； - 与
BlockingQueue其他实现不同，它不提供容量概念，因此remainingCapacity()返回0，不应误用于有界场景。
总结而言，SynchronousQueue 是 Java 平台对 Go 无缓冲通道最直接、最语义一致的对应实现。它不是“简化版队列”，而是一种纯传递机制（hand-off queue），适用于需要强同步协调的生产者-消费者场景，例如线程间信号传递、任务委托、资源交接等。正确理解其“零容量、必配对、强阻塞”特性，是写出可预测、高可靠并发代码的关键。
