trytransfer 是 transferqueue 的核心能力,主动发起同步传输而非入队;它仅在有线程正阻塞于 take 时立即传递并返回 true,否则返回 false 且不入队、不阻塞。

TransferQueue.tryTransfer 是什么,和 put/take 有什么本质区别
tryTransfer 不是“新特性”(它从 Java 7 就存在),而是 TransferQueue 区别于普通阻塞队列的核心能力:主动发起一次同步传输。它不把元素塞进队列等别人来取,而是直接“伸手找人要交接”——如果此时有线程正卡在 take() 上等待,就立刻完成传递;否则立即返回 false,不入队、不阻塞、不挂起当前线程。
- 普通
put():无条件入队,可能触发阻塞或丢弃(取决于实现) -
take():无条件等待,直到有元素可取 -
tryTransfer(E e):只在“对方正在等”的瞬间成交,否则甩手走人
这决定了它的典型场景不是缓冲,而是协调:比如生产者不想囤积数据,宁可跳过这次提交,也不愿让消息滞留在队列里。
什么时候该用 tryTransfer 而不是 offer/poll
关键看你的逻辑是否依赖“此刻是否有人等着接”这个实时状态。
- 适合:
tryTransfer常用于流控、背压反馈、零拷贝式协作。例如一个实时音视频帧处理管道,若下游消费者暂时卡住(没调take),上游就该丢弃旧帧,而不是堆积。 - 不适合:当你要确保数据至少“落盘”或“进队”,哪怕延迟一点——这时
offer()或带超时的offer(e, timeout, unit)更稳。
常见错误现象:
立即学习“Java免费学习笔记(深入)”;
- 误以为
tryTransfer是“非阻塞版 put”:它根本不入队,失败就是彻底没传出去 - 在没有消费者等待时反复调用,结果始终返回
false,却没做降级处理(如日志告警、降频、切备路径)
LinkedTransferQueue.tryTransfer 的实际行为细节
LinkedTransferQueue 是唯一 JDK 自带的 TransferQueue 实现,它的 tryTransfer 行为必须结合其内部状态理解:
- 如果当前有线程在
take()中自旋或阻塞等待,tryTransfer(e)立即匹配并返回true - 如果没有等待者,返回
false,且e不会被入队 - 它不支持超时版本的
tryTransfer(那是transfer()干的事) - 参数
e不能为null,否则抛NullPointerException
性能影响:
- 成功匹配时开销极低(CAS + 线程唤醒,无内存分配)
- 失败时只是几次 volatile 读,比
offer()还轻量 - 但频繁失败+重试会浪费 CPU,建议搭配退避策略(如指数退避)
示例:
if (!queue.tryTransfer(frame)) {
// 下游没准备好,直接丢弃或转存到本地环形缓存
droppedFrames.increment();
}容易被忽略的线程可见性与竞态点
tryTransfer 的成败高度依赖线程调度时序,不是原子“检查再执行”,而是一次 CAS 协作尝试。这意味着:
- 没有“先检查是否有 take 线程再决定是否调用”的安全方式——
hasWaitingConsumer()这类方法根本不存在,任何中间状态都可能被抢占 - 多个生产者同时
tryTransfer同一个元素?不行,e是值传递,但语义上每个调用都是独立尝试传一个副本 - 如果消费者在
take()前被中断,或刚唤醒就又被调度走,tryTransfer可能错过匹配窗口——这不是 bug,是设计使然
真正难处理的,是把“传输失败”当作“下游故障”来响应。实际上它只是瞬时状态,下一毫秒可能就通畅了。要不要重试、重试几次、是否切到备用队列,得由你的业务 SLA 决定,而不是由一次 tryTransfer 的返回值决定。










