0

0

什么是Java中的同步辅助类CountedCompleter_在ForkJoin中处理复杂递归

P粉602998670

P粉602998670

发布时间:2026-02-22 20:08:03

|

103人浏览过

|

来源于php中文网

原创

countedcompleter专用于有依赖关系的并行子任务协调,如分段哈希校验、树形聚合等;需用setpendingcount预设等待数、子任务完成调complete/trycomplete、合并逻辑必须在oncompletion中实现,compute不返回值且不可阻塞等待。

什么是java中的同步辅助类countedcompleter_在forkjoin中处理复杂递归

CountedCompleter 不是给普通递归用的,它是为“有依赖关系的并行子任务”设计的底层协调工具;直接拿它改写简单递归,大概率掉进线程饥饿、计数错乱、完成逻辑失控的坑里。

什么时候非得用 CountedCompleter

典型场景:一个任务必须等多个子任务都产出中间结果后,才能合并计算(比如分段哈希校验、树形结构的自底向上聚合、带前置条件的图遍历)。ForkJoinTask 的默认模型(RecursiveAction/RecursiveTask)没法自然表达“我等 N 个孩子完成再干活”,而 CountedCompletersetPendingCounttryComplete 就是干这个的。

常见错误现象:onCompletion 没触发、任务卡在 tryComplete 后不继续、compute 被重复调用。

  • 必须重写 onCompletion 处理合并逻辑,不能只靠 compute
  • setPendingCount(n) 要在 fork 子任务前调用,且 n 必须等于实际 fork 出的子任务数
  • 每个子任务完成后必须调用 complete(null)tryComplete(),否则父任务永远等不到

compute() 里 fork 子任务的写法陷阱

RecursiveTask 不同,CountedCompletercompute() 不返回值,结果要靠副作用或共享状态传递。容易忽略的关键点:

大师兄智慧家政
大师兄智慧家政

58到家打造的AI智能营销工具

下载

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

  • 不能在 compute() 末尾 return 一个值——它签名是 void
  • 子任务必须用 fork() 启动,不能直接 compute() 调用(否则失去并行性,且计数机制失效)
  • 如果某层不需要并行(比如数据量小),应调用 quietlyComplete() 主动标记完成,而不是漏掉 tryComplete

示例片段(求数组区间和,但要求左右子区间和都算完才加总):

void compute() {
    if (hi - lo <= THRESHOLD) {
        sum = IntStream.range(lo, hi).mapToLong(i -> arr[i]).sum();
        quietlyComplete(); // 主动完成,不等别人
        return;
    }
    int mid = (lo + hi) / 2;
    setPendingCount(2); // 明确等两个子任务
    new SumTask(arr, lo, mid).fork();
    new SumTask(arr, mid, hi).fork();
    // 不 return —— 等 onCompletion 触发
}

为什么 onCompletioncompute 更关键?

onCompletion 是唯一能安全访问所有子任务结果的地方,也是整个依赖链的“汇合点”。很多人误以为在 compute 里等子任务就行,但那是阻塞式等待,会拖垮 ForkJoinPool 的工作线程。

  • onCompletion 参数是当前任务自身(CountedCompleter 实例),不是子任务结果——结果得你自己存(比如用 volatile long sum 字段)
  • 子任务的结果不能通过返回值传上来,必须用共享字段 + 内存可见性保障(volatileAtomicLong
  • 如果子任务抛异常,onCompletion 仍会执行,需配合 getRawResult() 或额外标志位判断是否成功

真正难的不是写对语法,是想清楚“谁等谁”“谁改什么”“谁看什么”。哪怕只多一层依赖,计数逻辑就可能从线性变网状;一旦漏掉一次 tryComplete 或错设 pendingCount,整个任务树就静默卡死——这种问题在线程堆栈里根本看不出线索。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

246

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

826

2024.03.01

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

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

183

2023.11.23

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

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

121

2025.11.27

c++中volatile关键字的作用
c++中volatile关键字的作用

本专题整合了c++中volatile关键字的相关内容,阅读专题下面的文章了解更多详细内容。

71

2025.10.23

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

421

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

595

2023.08.10

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

421

2023.07.18

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

1030

2026.02.13

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 3.8万人学习

C# 教程
C# 教程

共94课时 | 10万人学习

Java 教程
Java 教程

共578课时 | 70.4万人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号