当前位置:

首页 > 编程开发 > SynchronousQueue 的 transfer:解析基于 Slot 的线程交替数据传递逻辑

SynchronousQueue 的 transfer:解析基于 Slot 的线程交替数据传递逻辑

SynchronousQueue的transfer方法通过无缓冲设计实现线程间直接数据传递。其核心是volatile修饰的Slot作为同步协调点,结合CAS操作保证原子性,以及park/unpark进行精准线程控制。生产者与消费者通过Slot交换数据或线程引用,完成“握手”。该方法支持公平与非公平两种模式,分别采用栈或队列组织等待线程,展现了高并发场景下零库

SynchronousQueue的transfer方法:无缓冲直接交接的线程握手艺术

在并发编程的世界里,有一种队列堪称“极简主义”的典范——它内部没有任何存储空间,却能让数据在生产者和消费者之间精准、原子地传递。这就是SynchronousQueue,而其灵魂所在,便是transfer方法。这套机制的核心,可以概括为一场精心设计的线程“碰头会”:双方必须同时到场,一手交数据,一手交凭证,完成一次完美的握手。整个过程高度依赖volatile SlotCASpark/unpark的精密协作,实现了线程间的精确同步与唤醒。

SynchronousQueue 的 transfer:解析基于 Slot 的线程交替数据传递逻辑

Slot 是什么:一个轻量级的同步协调点

首先得搞清楚,这里的Slot并非传统队列中的节点。它本质上是一个volatile修饰的AtomicReference字段,扮演着临时“中转站”或“信号灯”的角色。其工作流程非常清晰:

  • 当一位消费者调用take()却找不到现成的数据时,它不会空等。相反,它会尝试将自己的线程对象(或一个特殊的null标记)通过CAS操作写入Slot,然后立刻挂起自己,进入等待状态。
  • 当一位生产者带着数据put(x)到来时,如果发现Slot非空(这意味着已经有消费者在等了),它会直接将自己的数据x通过CAS替换进去,并随即唤醒那个等待的消费者。
  • 反过来,如果生产者发现Slot是空的(没有等待者),它就会把自己包装成一个包含数据和线程引用的QNode放入Slot,然后挂起,等待消费者的到来。

你看,Slot就像一个共享的公告板,谁先到谁就在上面留下自己的联系方式,后到的人看到后,要么直接完成交易,要么留下自己的信息然后等待。

transfer 如何实现线程交替:一次成功的“握手”流程

理论可能有些抽象,让我们看一个典型场景:生产者put(x)时,恰好遇到一位已经在等待的消费者take()。这场“握手”是如何一步步完成的?

  • 第一步:消费者就位。 消费者已经执行了slot.compareAndSet(null, this),成功将自己的线程引用注册到了Slot中,随后调用LockSupport.park(this)进入阻塞状态。
  • 第二步:生产者抵达并交换。 生产者到达后,读取Slot发现不是null(而是一个线程引用),意识到有消费者在等。于是,它执行关键操作:slot.compareAndSet(e, x),试图将Slot中的消费者线程引用原子性地替换成自己要传递的数据x。
  • 第三步:唤醒对方。 CAS替换成功后,生产者立即调用LockSupport.unpark(e)唤醒对应的消费者线程。
  • 第四步:消费者验收。 消费者被唤醒后,会再次检查Slot当前的值。如果发现已经是数据x,则顺利取走并返回;如果发现值仍然是自己的线程引用(这可能是因为被中断或超时了),则会尝试通过CAS将Slot清空,然后处理中断或超时逻辑并退出。

整个过程行云流水,没有冗余的缓冲,完全是一次面对面的即时交易。

为什么需要 CAS + volatile + park/unpark 组合

如此精巧的设计,单靠任何一种技术都无法实现。它需要CASvolatilepark/unpark三者紧密配合,各司其职:

  • volatile Slot:保证可见性。 这是线程间能够“看见”对方的基础。它确保了生产者或消费者对Slot状态的修改,能立刻被另一个线程感知到,避免了因为线程缓存而导致“我到了,你却看不见”的尴尬局面。
  • CAS 操作:保证原子性。 无论是注册等待、交换数据还是清理状态,这些关键步骤都必须原子完成。CAS防止了多个生产者同时尝试写入数据,或多个消费者同时尝试读取数据所造成的状态混乱和数据错乱。
  • park/unpark:提供精准的线程控制。 相比传统的wait/notifypark/unpark机制更加精准和可控。它允许线程在指定的对象上挂起和唤醒,并且不易产生“虚假唤醒”问题,这使得线程状态判断的逻辑更加健壮可靠。

这三者缺一不可,共同构筑了transfer方法正确、高效的基石。

公平模式下的 TransferStack vs 非公平模式的 TransferQueue

有趣的是,SynchronousQueue内部提供了两种不同的等待线程组织策略,对应着公平与非公平的模式:

  • TransferQueue(非公平模式,默认): 其内部是一个FIFO(先进先出)的双向队列。新来的等待线程总是插入队尾,唤醒时则从队头开始。这实际上形成了一种“先到先得”的公平调度。我们常说的“非公平”指的是默认选择,但其内部队列本身是公平的。
  • TransferStack(公平模式): 在构造函数中传入true时启用。它采用LIFO(后进先出)的栈结构。这意味着后到达的线程可能会优先获得匹配机会。这种策略的初衷是减少线程的平均等待时间,提升整体吞吐,但潜在的代价是可能导致早到的线程被“饿死”。
  • 需要明确的是,无论是栈还是队列,它们核心的transfer主逻辑是一致的,差异仅仅在于等待线程的组织方式和匹配时的顺序策略。选择哪一种,取决于你对公平性和吞吐量的权衡。

总而言之,SynchronousQueue的transfer方法展示了一种极致的高并发协作模式。它摒弃了缓冲区的概念,通过一个精巧的Slot和一套经典的同步原语组合,实现了线程间数据传递的零库存、高时效。理解这套机制,对于深入掌握Ja va并发编程的精髓大有裨益。 本文内容来源于互联网,如有侵权请联系删除。

作者最新文章
编程开发
相关文章 更多
好衣库售后怎么样?把保障体系拆开看
好衣库售后怎么样?把保障体系拆开看

好衣库售后全程由平台统一受理,绝不甩给店主,店主零售后负担。物流合作顺丰、京东、菜鸟三大优质快递,退货运费险由人保、众安保承保。消费者全面享直购标准,退换货由平台全额兜底,买卖双方均安心省心无忧。

全电作业新标杆!2026款长安猎手K50上市,14.19万起重塑皮卡体验
全电作业新标杆!2026款长安猎手K50上市,14.19万起重塑皮卡体验

2026款长安猎手K50增程皮卡上市,售价14.19万至17.89万元。搭载2.0T超级大增程系统,双电机峰值功率240kW,百公里加速5.9秒。配备宁德时代2C电池,纯电续航192公里,总电力储备239kWh,支持30kW+3.3kW双功率供电,实现全场景用电覆盖。

2026年车市新势力崛起:新车型成销量担当,零跑A10单月破2万领跑
2026年车市新势力崛起:新车型成销量担当,零跑A10单月破2万领跑

2026年5月,国内乘用车出口78.4万辆,同比增长75.1%,占厂商总销量35%。新车型成为增长核心引擎,零跑A10以2.2万辆登顶新车型冠军。消费者需求加速从功能满足转向体验升级,汽车产业进入高速迭代周期,推动行业洗牌。

十七载深耕智能领域,长安“天枢领航”亮相车展引领安全出行新体验
十七载深耕智能领域,长安“天枢领航”亮相车展引领安全出行新体验

长安汽车在重庆车展发布“天枢领航”辅助驾驶系统,从安全防护、减轻压力到智能交互三个维度升级出行体验。该系统基于十七年技术深耕,依托天枢智能实验中心积累超40万虚拟场景,实测500万公里覆盖185类典型场景,形成技术-场景-用户闭环优化机制。

《2025年度北京历史文化名城保护大事记》发布
《2025年度北京历史文化名城保护大事记》发布

2025年度北京历史文化名城保护大事记发布,收录94项代表性事件。关键进展包括《北京中轴线世界文化遗产保护条例》施行、先农坛校址腾退实现空间贯通、长辛店老镇启动区开街、路县故城遗址公园试运行等,标志保护工作从被动抢救转向主动规划。

DBeaver 25.3.3 发布
DBeaver 25.3.3 发布

DBeaver25.3.3发布,优化SQL编辑器响应速度与资源占用,AI辅助自动禁用不兼容模型的temperature参数。数据编辑器默认对SELECT查询自动统计行数,修复数据迁移对话框尺寸异常。重构自动提交逻辑,升级UI布局,修正事务状态显示及macOS欢迎画面。数据库适配增强:ClickHouse修复空格解析,Sybase修复双击表打开,DuckDB新

REDMI 17与Note 17系列通过认证 Note 17系列或7、8月发布
REDMI 17与Note 17系列通过认证 Note 17系列或7、8月发布

红米十七与Note十七系列已经通过多项国际认证。红米十七搭载骁龙六sGen二四G版,含日本专属版本和POCO联名版C九五Pro。Note十七系列由三款机型组成,均基于骁龙平台,预计二零二六年七至八月率先在中国上市。

美股科技板块剧烈震荡:心片股集体承压 ARM跌超6%
美股科技板块剧烈震荡:心片股集体承压 ARM跌超6%

当地时间6月9日,美股三大指数走势分化,纳指与标普500双双收跌。科技板块调整明显,半导体ETF盘中最大跌幅超7%,费城半导体指数一度大跌逾8.6%。ARM跌超6%,Coherent跌逾11%,部分AI相关个股也显著回调。

macOS Golden Gate调整菜单设计 移除菜单项图标
macOS Golden Gate调整菜单设计 移除菜单项图标

macOSGoldenGate更新后移除了菜单项图标,回归简洁纯文字布局。此前Tahoe版本引入图标但辨识度低,反而拖慢浏览效率。此次调整遵循简洁原则,显著提升可读性与操作效率,是对用户反馈的理性精简。这一改动减少视觉干扰,菜单栏更清晰,用户可快速定位功能。

新款奔驰GLC中期改款谍照来袭,设计革新,2027年发布引期待
新款奔驰GLC中期改款谍照来袭,设计革新,2027年发布引期待

新款奔驰GLC中期改款谍照曝光,前脸采用三叉星徽LED大灯,内饰升级MBUX超联屏及MB.OS系统,科技感显著提升。国产版或与科技企业合作优化智能驾驶,动力延续2.0T轻混与插混,兼顾性能与油耗,2027年全球发布。

查看更多
精品专题 更多
装机必备
装机必备

正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

Windows
Windows

正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

macOS软件
macOS软件

正软商城macOS软件专区,精选适用于Mac电脑的办公、设计、影音、效率、开发和系统工具,提供软件功能介绍、macOS兼容版本、正版授权及购买下载服务。

Mac软件 更多
灵活计算器
灵活计算器
macOS/iOS/Android

灵活计算器是一款笔记式算数应用,支持实时计算、动态关联和云端同步功能。记录、整理和输出之间的过渡会更自然,适合长期写作、做笔记或持续沉淀个人内容。

赤友清理大师
赤友清理大师
macOS

赤友清理大师是一款为 Mac 设计的智能清理优化工具,可精准扫描垃圾、大文件、重复文件等,释放磁盘空间。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

极度公式
极度公式
Windows/macOS/Linux

极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

WINDOWS 更多
Windows 10
Windows 10
Windows

Windows 10 是一款微软推出的经典操作系统,拥有硬件兼容性与多任务处理能力。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。

极度公式
极度公式
Windows/macOS/Linux

极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

密码键盘
密码键盘
Windows/macOS/iOS/Android

密码键盘是一款兼具安全性与便捷性的高效密码管理器。日常使用里的持续防护和信息管理会更突出,适合把安全控制放进长期使用流程中的场景。

网站备案号:苏ICP备2026018738号-1 联系邮箱:bd@zhengruan.com 网站地图

Copyright ©2018-2026