synchronousqueue 是无缓冲的线程间直接移交通道，put() 与 take() 必须一对一即时配对；zerowaitexecutor 利用其阻塞特性实现提交即执行的零等待语义，适用于轻量信号传递、严格顺序任务等场景。
理解 SynchronousQueue 的核心特性
SynchronousQueue 不是传统意义的“队列”，它不存储元素，而是作为线程间**直接移交（hand-off）的通道**。一个线程调用 put() 会阻塞，直到另一个线程恰好调用 take()；反之亦然。这种“一对一即时配对”机制天然适合构建**零缓冲、零等待、请求即响应**的并发执行模型。
设计零等待执行器的关键结构
要实现“提交任务后立即被处理”，不能依赖线程池内部队列缓存任务。必须让任务提交线程与工作线程在 SynchronousQueue 上**严格同步交接**：
- 使用
Executors.newCachedThreadPool()或自定义线程池，但禁止设置任何工作队列（即不传入 BlockingQueue） - 手动包装一层调度逻辑：用
SynchronousQueue<runnable></runnable>接收任务，由专用分发线程或 worker 线程直接take()并执行 - 避免使用
execute()默认逻辑，改用offer()+ 自旋/回调 或put()阻塞式提交——后者更符合“即时响应”语义（提交即触发执行，无排队延迟）
一个可运行的极简实现
以下代码展示如何用 SynchronousQueue 构建真正零等待的执行器：
class ZeroWaitExecutor {
private final SynchronousQueue<runnable> queue = new SynchronousQueue();
private final Thread dispatcher;
public ZeroWaitExecutor() {
this.dispatcher = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
try {
Runnable task = queue.take(); // 阻塞直到有任务
task.run(); // 立即执行，无调度开销
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}, "ZeroWait-Dispatcher");
this.dispatcher.start();
}
public void submit(Runnable task) throws InterruptedException {
queue.put(task); // 提交即阻塞，直到 dispatcher take 并执行完 run()
}
public void shutdown() {
dispatcher.interrupt();
}
}</runnable>
注意：queue.put(task) 会阻塞，直到 dispatcher 调用 take() 并执行完 task.run()。这意味着调用 submit() 的线程实际在等待任务执行完成——这正是“零等待执行器”在语义上的一致性保证（不是异步 fire-and-forget，而是同步执行+无中间队列）。
适用场景与重要提醒
这种模式适合：
- 跨线程的轻量级信号传递（如 UI 线程通知后台线程刷新状态）
- 需要严格顺序执行且不允许积压的任务（如实时采样控制、硬件指令下发）
- 构建测试用的确定性并发调度器（便于验证时序行为）
但需警惕：
- 如果
task.run()执行过长，submit()调用方会被卡住——这不是缺陷，而是设计使然。如需异步，请明确拆分为“提交”和“结果回调”两阶段 - 不能靠增加 worker 数量提升吞吐：SynchronousQueue 本身不扩容，dispatcher 是单点。如需并行执行多个任务，应启动多个配对线程（例如每个
put对应一个专属take线程），而非共享队列 - 务必处理中断，否则
put/take可能永久挂起
不复杂但容易忽略。
