在Java并发包中，TransferQueue是一个用于线程间传递元素的阻塞队列接口，位于java.util.concurrent包下。它在SynchronousQueue的基础上做了增强，既保留了直接传递的语义，又提供了更丰富的控制方法，适合需要精确掌握传递状态的场景。
TransferQueue与SynchronousQueue的关系
SynchronousQueue本身也是一种特殊的阻塞队列，每一个插入操作必须等待另一个线程的移除操作，相当于手递手传递。TransferQueue接口的主要实现类LinkedTransferQueue，不仅兼容这种机制，还新增了transfer、tryTransfer等方法，让生产者可以主动感知消费者是否接收。
核心差异对比
| 特性 | SynchronousQueue | TransferQueue |
|---|---|---|
| 直接传递 | 支持 | 支持 |
| 非阻塞试探传递 | 不支持 | 支持(tryTransfer) |
| 查询等待消费者数 | 不支持 | 支持(getWaitingConsumerCount) |
| 容量模式 | 无容量 | 可有界或无界 |
TransferQueue的核心方法
- transfer(E e)：阻塞直到消费者接收元素
- tryTransfer(E e)：立即返回，若有消费者等待则传递成功
- tryTransfer(E e, long timeout, TimeUnit unit)：带超时试探传递
- getWaitingConsumerCount()：返回正在等待的消费者线程数
- hasWaitingConsumer()：是否有消费者在等待
代码示例：使用LinkedTransferQueue传递任务
下面演示一个生产者使用transfer阻塞等待消费者接收任务的简单例子。
import java.util.concurrent.LinkedTransferQueue;
import java.util.concurrent.TransferQueue;
public class TransferDemo {
public static void main(String[] args) throws InterruptedException {
// 创建无界TransferQueue
TransferQueue<String> queue = new LinkedTransferQueue<>();
// 消费者线程
new Thread(() -> {
try {
String task = queue.take();
System.out.println("消费者收到: " + task);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}).start();
// 生产者阻塞传递
queue.transfer("hello-transfer");
System.out.println("生产者确认任务已被接收");
}
}
为什么TransferQueue更强大
在实际任务调度中，如果只使用SynchronousQueue，生产者无法知道当前是否有消费者在等待，也不能做非阻塞的试探。TransferQueue的tryTransfer允许生产者先尝试交付，失败后再决定入队或丢弃，避免无谓阻塞。getWaitingConsumerCount则方便监控系统负载，例如当等待消费者为0时，生产者可选择本地处理而非远程提交。
对于需要手递手传递且要求灵活控制的高并发系统，TransferQueue比SynchronousQueue提供更细粒度的协作能力。
使用注意点
- LinkedTransferQueue是无界队列，使用transfer不会因容量满而阻塞，只因无消费者而阻塞
- 在大量试探调用场景下，tryTransfer可能带来自旋开销，需结合业务评估
- 若仅需严格一对一同步且无需查询，SynchronousQueue仍更轻量
小结
TransferQueue通过扩展SynchronousQueue的传递语义，让线程间任务交接具备可探测、可等待、可统计的特性。理解这些差异有助于在并发组件选型时做出合理判断。
TransferQueueSynchronousQueueJava并发修改时间：2026-07-26 04:45:20