怎么利用 SynchronousQueue 的无存储空间特性实现线程池任务的零延迟直接移交

冬瑶姑娘_2242

冬瑶姑娘_2242

2026-04-20

355人浏览

原创

synchronousqueue 不能存任务,因其无内部容量,offer()仅当有线程正执行poll()/take()时才成功,实现“一手交任务、一手接执行”的零延迟移交;需配合corepoolsize==maximumpoolsize及callerrunspolicy等配置方可发挥优势。

怎么利用 synchronousqueue 的无存储空间特性实现线程池任务的零延迟直接移交

为什么 SynchronousQueue 不能存任务,反而适合零延迟移交

SynchronousQueue 的核心特性是它没有内部容量——offer() 只有在有另一个线程正调用 poll()(或 take())时才返回 true;否则立刻失败或阻塞。这意味着:任务不会“排队”,而必须被**当场消费**。这正是零延迟移交的物理基础——不是“先存再取”,而是“一手交任务,一手接执行”。

但注意:这只有在线程池中已有空闲工作线程、且该线程恰好处于 take() 等待状态时才成立。如果所有线程都在忙,新任务会触发线程池的拒绝策略(默认是 AbortPolicy),而不是等待。

用 SynchronousQueue 构建 FixedThreadPool 的正确姿势

常见误区是直接 new ThreadPoolExecutor(..., new SynchronousQueue()),却忽略核心参数配合。SynchronousQueue 本身不缓冲,所以必须确保:当任务到来时,总有线程能立刻响应。这就要求线程池的 corePoolSize 和 maximumPoolSize 相等,且拒绝策略设为 CallerRunsPolicy 或自定义兜底逻辑。

  • corePoolSize == maximumPoolSize:避免任务因线程扩容延迟而被拒绝
  • 拒绝策略不用 AbortPolicy:否则无空闲线程时直接抛 RejectedExecutionException
  • 保持 keepAliveTime = 0L:无意义(因为线程数恒定)
  • 推荐构造方式:
    new ThreadPoolExecutor(n, n, 0L, TimeUnit.MILLISECONDS, new SynchronousQueue(), new CallerRunsPolicy())

实际移交过程:从 submit() 到 run() 中间发生了什么

当你调用 executor.submit(runnable),流程是:线程 A 调用 queue.offer(runnable) → 若此时线程 B 正在 getTask() 中执行 queue.poll()(或阻塞于 take()),则 offer 成功,runnable 直接交给线程 B 执行,**无内存拷贝、无队列入队出队开销**。

关键点在于:这个“移交”是通过线程间直接的 LockSupport.unpark / park 协作完成的,底层依赖 TransferQueue 的 transfer() 方法。所以它比 ArrayBlockingQueue 少了至少两次 volatile 写 + 一次 CAS 操作。

  • 成功移交时,任务对象引用直接从生产者栈帧传入消费者线程的局部变量,不经过堆上队列节点
  • 若无空闲线程,offer() 返回 false,触发拒绝策略——这时才是真正的“延迟点”,而非队列本身
  • 监控时可观察 executor.getRejectedExecutionHandler() 是否被频繁调用,这是容量瓶颈信号

容易被忽略的陷阱:CPU 密集型任务会让移交失效

SynchronousQueue 的零延迟只对“移交动作”成立,不代表任务执行没延迟。如果线程池里全是 CPU 密集型任务,线程长时间占用 CPU,新任务来了没人能及时 take(),offer() 就会失败,最终走拒绝逻辑。

  • 这不是 SynchronousQueue 的问题,而是线程池配置与负载不匹配
  • 解决方法:按 CPU 核心数设置 n(如 Runtime.getRuntime().availableProcessors()),并确保任务确实不阻塞
  • 混合 I/O 任务时,务必搭配 allowCoreThreadTimeOut(true) 或改用其他队列,否则空闲线程无法释放,资源浪费
  • 调试时可打印 executor.getActiveCount() 和 executor.getCompletedTaskCount() 差值,判断是否长期满载

真正难的不是配对 SynchronousQueue 和线程池,而是让“移交瞬间”和“执行时机”严丝合缝——这取决于你对任务行为的预判,而不是队列本身有多快。

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

2023.06.15

10017

6

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

2023.07.05

7162

9

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

2023.07.31

6292

8

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.01

1084

3

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.02

908

3

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

1316

5

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

2629

5

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

2023.08.03

19951

3

配置java环境变量
配置java环境变量

配置Java环境变量是为了让操作系统能够识别和使用Java的相关命令和功能。本专题为大家提供配置java环境变量相关文章,帮助大家解决问题。

2023.08.03

1175

8

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.4万人学习