如何利用 RecursiveTask 与 RecursiveAction 实现大规模数据集的归并排序并行化

千墨君_2910

千墨君_2910

2026-04-15

233人浏览

原创

recursivetask与recursiveaction的核心区别在于是否返回结果:recursivetask用于有返回值的任务(如归并排序需返回子数组),recursiveaction用于无返回值的副作用操作;误用会导致编译失败或合并逻辑断裂。

如何利用 recursivetask 与 recursiveaction 实现大规模数据集的归并排序并行化

RecursiveTask 与 RecursiveAction 的核心区别在哪

关键看是否需要返回结果:RecursiveTask 用于有返回值的并行任务(比如归并排序中每个子任务要返回已排序的子数组),RecursiveAction 用于无返回值的副作用操作(如仅对原数组某段做原地排序,不产生新数组)。归并排序天然需要合并两个有序子数组,必须组合子结果,所以优先选 RecursiveTask<int></int>,而不是 RecursiveAction。

用错类型会导致编译失败或运行时逻辑断裂——比如误用 RecursiveAction 后调用 invoke() 得到 void,无法参与合并步骤。

如何切分数组才不会触发栈溢出或线程饥饿

默认的 ForkJoinPool 使用 CPU 核心数作为并行度,但归并排序的递归深度与数据量对数相关,真正危险的是「切分粒度过小」:每层都 fork 新任务,即使数组只剩 2 个元素也提交任务,造成大量细粒度任务堆积,吞没 fork-join 线程队列。

  • 设置阈值(threshold),例如 if (end - start 时改用 <code>Arrays.sort(arr, start, end) 做插入排序,不再 fork
  • 避免每次 new 一个新子数组;对大数组应传入原数组 + 索引范围,在 compute() 中复用内存,减少 GC 压力
  • 不要在 compute() 中直接调用 fork() 两次再 join();应先 fork() 左子任务,再同步计算右子任务,最后 join() 左结果——这样节省一次上下文切换

merge() 步骤为什么必须在 compute() 内完成,不能交给另一个 ForkJoinTask

归并排序的合并操作本身是 O(n) 时间、需顺序访问左右两个子数组,不具备可进一步有意义并行化的结构。如果为 merge() 单独封装成 RecursiveAction 并 fork,反而引入额外调度开销,实测性能通常下降 15%~40%。

更严重的是数据竞争风险:若左右子任务写入同一目标数组的不同区域,而 merge 任务又依赖它们完成,就必须显式 join() 等待,此时再 fork merge 就纯属冗余。正确做法是:

  • 左子任务 fork()
  • 右子任务直接 compute()(即同步执行)
  • 调用 leftTask.join() 拿回左结果
  • 在当前线程内执行 merge(leftResult, rightResult, ...)

ForkJoinPool.commonPool() 在 Web 容器里可能悄悄失效

Spring Boot 或 Tomcat 环境下,ForkJoinPool.commonPool() 默认使用 daemon 线程,而某些容器会提前终止 daemon 线程导致任务静默丢失;另外 commonPool 不支持自定义拒绝策略和监控。

生产环境务必显式构造专用池:

ForkJoinPool pool = new ForkJoinPool(
    Runtime.getRuntime().availableProcessors(), // parallelism
    ForkJoinPool.defaultForkJoinWorkerThreadFactory,
    (t, e) -> { logger.error("Task failed", e); },
    true // asyncMode: 对归并排序这类 fork-join 密集型任务,设为 true 可略微提升吞吐
);

用完记得 pool.shutdown(),否则 JVM 无法正常退出——这点在单元测试里最容易被忽略。

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

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

下载

相关标签:

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

相关专题

更多
java
java

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

2023.06.15

10577

6

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

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

2023.07.05

7702

9

java自学难吗
java自学难吗

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

2023.07.31

6712

8

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

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

2023.08.01

1144

3

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

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

2023.08.02

948

3

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

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

2023.08.02

1376

5

java有什么用
java有什么用

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

2023.08.02

2789

5

java在线网站
java在线网站

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

2023.08.03

20091

3

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

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

2023.08.03

1235

8

热门下载

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

精品课程

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

共6课时 | 54.7万人学习

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

共89课时 | 133.7万人学习