浅谈辄止_java forkjoinpool

浅谈辄止_java forkjoinpool文章目录一、ForkJoin是什么?它能用来实现什么功能?二、ForkJoin的实现原理三、ForkJoin的简单使用一、ForkJoin是什么?它能用来实现什么功能?二、ForkJoin的实现原理三、ForkJoin的简单使用在这里插入代码片…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺


一、ForkJoin是什么?它能用来实现什么功能?

ForkJoin也是一种线程池,只不过ForkJoin是专为CPU密集型任务而建立的线程池,它能大大提高CPU密集型任务的执行效率。

二、ForkJoin的实现原理

ForkJoin是使用分治算法实现的,主要的原理就是将一个大的任务拆分为若干个小任务分发给若干个线程去处理,最后将若干的线程处理好后的结果进行汇总,从而达到提升计算效率的结果。
ForkJoin内部含有工作窃取逻辑:如果一个线程完成了本身所关联的工作队列中的人物,那么它会尝试从其它的工作队列中窃取任务来执行(窃取任务的位置是双端队列base端,工作线程一般都是从top端获取任务),从而提升了线程的使用率

三、ForkJoin的简单使用

package com.muyichen.demo.forkjoin;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;
@Slf4j
public class ForkJoinExample extends RecursiveTask<Integer> { 

public static final int threshold = 2;
private int start;
private int end;
public ForkJoinExample(int start, int end) { 

this.start = start;
this.end = end;
}
@Override
protected Integer compute() { 

int sum = 0;
//如果任务足够小就计算任务
boolean canCompute = (end - start) <= threshold;
if (canCompute) { 

for (int i = start; i <= end; i++) { 

sum += i;
}
} else { 

// 如果任务大于阈值,就分裂成两个子任务计算
int middle = (start + end) / 2;
ForkJoinExample leftTask = new ForkJoinExample(start, middle);
ForkJoinExample rightTask = new ForkJoinExample(middle + 1, end);
// 执行子任务
leftTask.fork();
rightTask.fork();
// 等待任务执行结束合并其结果
int leftResult = leftTask.join();
int rightResult = rightTask.join();
// 合并子任务
sum = leftResult + rightResult;
}
return sum;
}
public static void main(String[] args) { 

ForkJoinPool forkjoinPool = new ForkJoinPool();
//生成一个计算任务,计算1加到100
ForkJoinExample task = new ForkJoinExample(1, 100);
//执行一个任务
Future<Integer> result = forkjoinPool.submit(task);
try { 

log.info("result:{}", result.get());
} catch (Exception e) { 

log.error("exception", e);
}
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/191357.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Moya 浅析_motivationally

    Moya 浅析_motivationallyMoya是一个高度抽象的网络库,他的理念是让你不用关心网络请求的底层的实现细节,只用定义你关心的业务。且Moya采用桥接和组合来进行封装(默认桥接了Alamofire),使得Moya非常好扩展,让你不用修改Moya源码就可以轻易定制。官方给出几个Moya主要优点:编译时检查APIendpoint权限让你使用枚举定义各种不同Target,endpoints把stubs当做…

    2022年10月25日
  • 快速查找Python安装路径方法「建议收藏」

    快速查找Python安装路径方法「建议收藏」我相信一定有很多的人跟我一样,经常忘记Python安装的路径,每当用到的时候,最笨的办法就是在全局电脑里,直接查找Python,这样是肯定能查到的,但是如果你的电脑文件超级多,这将是一个工厂量很大的事情,你要等好久的。便捷的方法时:打开我们的cmd命令输入Python输入importsys输入print(sys.path)列表中的第五个将是你的安装路径…

  • MSSQL 的QUOTENAME函数「建议收藏」

    MSSQL 的QUOTENAME函数「建议收藏」–功能:返回带有分隔符的Unicode字符串,分隔符的加入可使输入的字符串成为有效的MSSQL分隔标识符。–语法QUOTENAME(‘character_string'[,’quote_character’]) –SQL语句中的字段名,表名为关键字时,用QUOTENAME添加有效分隔符() –在动态查询中,对表名参数QUOTENAME处理,避免表名为

  • Java生成xml文件的四种方式

    Java生成xml文件的四种方式上一篇文章写了xml文件4种读取方式,本篇文章将简介使用四种方式对xml进行写入。

  • 安卓apk证书_安卓无法打开apk文件

    安卓apk证书_安卓无法打开apk文件获取apk证书文件MD5值

  • linux

    linux

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号