讲师中心 微信公众号
AI工具推荐 视频效率加速

Java并发编程中ForkJoin框架怎么用_并行计算模型解析

胖静君_3543

胖静君_3543

发布时间:2026-01-25 12:36:09

|

394人浏览过

|

来源于php中文网

原创

当任务天然可分、子任务独立且计算量大时,应选ForkJoinPool;它基于工作窃取优化CPU利用率,适合分治类短任务,而ThreadPoolExecutor更适合I/O或长周期任务。

java并发编程中forkjoin框架怎么用_并行计算模型解析

什么时候该用 ForkJoinPool 而不是普通线程池

当任务天然可分、子任务独立、且总计算量较大(比如数组求和、树遍历、归并排序)时,ForkJoinPool 才有优势。它专为「分治 + 突发性大量短任务」设计,内部用工作窃取(work-stealing)提升 CPU 利用率;而 ThreadPoolExecutor 更适合 I/O 密集或长周期任务,强行塞进 ForkJoinPool 反而因任务调度开销变慢。

  • 适合场景:long[] 求和、JSON 深度解析、大规模图连通性判断、递归型算法并行化
  • 不适合场景:含阻塞调用(如 Thread.sleep()、数据库查询)、任务粒度太粗(每个子任务耗时 >100ms)、任务间强依赖
  • 默认并行度 = CPU 核心数,可通过 ForkJoinPool.commonPool().getParallelism() 查看;启动时传入 new ForkJoinPool(4) 可显式控制

RecursiveTask 和 RecursiveAction 怎么选

区别只在是否需要返回值:RecursiveTask<T> 用于有结果的任务(如求最大值),必须重写 compute() 并返回 T;RecursiveAction 用于无返回值的副作用操作(如批量更新对象字段),compute() 返回 void。选错会导致编译失败或运行时 ClassCastException。

public class SumTask extends RecursiveTask<Long> {
    private final long[] array;
    private final int lo, hi;
<pre class='brush:java;toolbar:false;'>public SumTask(long[] array, int lo, int hi) {
    this.array = array;
    this.lo = lo;
    this.hi = hi;
}

@Override
protected Long compute() {
    if (hi - lo <= 1000) { // 阈值决定是否继续拆分
        long sum = 0;
        for (int i = lo; i < hi; i++) sum += array[i];
        return sum;
    }
    int mid = (lo + hi) / 2;
    SumTask left = new SumTask(array, lo, mid);
    SumTask right = new SumTask(array, mid, hi);
    left.fork(); // 异步提交左子任务
    long rightResult = right.compute(); // 当前线程同步执行右子任务
    long leftResult = left.join(); // 等待左子任务结果
    return leftResult + rightResult;
}

}

常见卡死/性能差问题:阈值设置与 fork()/join() 误用

阈值(threshold)设得太小,会导致任务拆分过细,调度开销压倒计算收益;设得太大,则无法充分利用多核。典型错误是把 fork() 和 join() 写反,或在未 fork() 就调 join(),导致线程阻塞等待自己。

Comprehensive Three.js 3D graphics reference
Comprehensive Three.js 3D graphics reference

详细的 Three.js 3D 图形参考,涵盖场景设置、相机、几何体、材质、光照、动画、控制器、加载器、数学工具和调试。

下载

立即学习“Java免费学习笔记(深入)”;

  • 推荐阈值:数值计算类任务从 1000 起调,实际按压测调整;对象处理类可设为 100 左右
  • 必须成对使用:fork() 后才能 join();若只调 compute(),就退化为单线程递归
  • 避免在 compute() 中混用 Thread.sleep() 或锁,会污染工作线程,拖慢整个池
  • 不要在 commonPool() 中执行长时间阻塞操作——它被所有未指定池的 parallelStream() 共享,一卡全卡

ForkJoinPool 的异常传播机制很特别

子任务抛出的异常不会直接向上冒泡,而是被静默捕获并存入任务内部状态。只有调用 join() 或 invoke() 时,才会在当前线程重新抛出首个发生的异常(ForkJoinTask.get() 也会触发)。这意味着:没调 join() 就看不到异常;多个子任务同时异常,只暴露第一个。

  • 安全做法:每个 join() 后检查 isCompletedAbnormally(),再调 getException()
  • 调试技巧:在 compute() 开头加 System.out.println(Thread.currentThread().getName()),确认是否真在 ForkJoin 线程中执行
  • 注意 invokeAll(task1, task2) 不会立即抛异常,要分别 task1.join() 和 task2.join() 才能捕获各自异常

ForkJoin 的核心不是“怎么写”,而是“怎么切”——任务划分方式、阈值选择、结果合并逻辑,这三者比语法细节更影响最终效果。很多人卡在跑起来但不加速,问题往往出在切分粒度或合并开销上,而不是代码有没有漏掉 fork()。

相关文章

编程速学教程(入门课程)
编程速学教程(入门课程)

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

下载

相关标签:

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

热门AI工具

更多
DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

1975

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

2682

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

936

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

2999

2025.09.10

javascriptvoid(o)怎么解决
javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法:1、检查语法错误;2、确保正确的执行环境;3、检查其他代码的冲突;4、使用事件委托;5、使用其他绑定方式;6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

616

2023.11.23

java中void的含义
java中void的含义

本专题整合了Java中void的相关内容,阅读专题下面的文章了解更多详细内容。

351

2025.11.27

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

3538

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

523

2025.12.01

Buffalo框架数据库开发全教程
Buffalo框架数据库开发全教程

本专题围绕Buffalo框架数据库开发,讲解database.yml多环境配置、soda与fizz迁移生成回滚、模型结构体标签、增删改查与条件查询、一对多与多对多关联、数据校验、回调钩子、事务处理及原生SQL执行能力。

60

2026.09.23

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
dev.java 官方:Learn Java
dev.java 官方:Learn Java

共0课时 | 0人学习

Java JDBC数据库连接官方教程
Java JDBC数据库连接官方教程

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn