我的github: https://github.com/soyoungboy
我的segmentfault: http://segmentfault.com/u/soyoungboy
【不积跬步,无以至千里;不积小流,无以成江海】
博客园 首页 新随笔 联系 订阅 管理 随笔-477 评论-20 文章-0
java多线程 -- ForkJoinPool 分支/ 合并框架 工作窃取
Fork/Join 框架:就是在必要的情况下,将一个大任务,进行拆分(fork)成若干个小任务(拆到不可再拆时),再将一个个的小任务运算的结果进行 join 汇总。
Fork/Join 框架与线程池的区别
- 采用 “工作窃取”模式(work-stealing):当执行新的任务时它可以将其拆分分成更小的任务执行,并将小任务加到线程队列中,然后再从一个随机线程的队列中偷一个并把它放在自己的队列中。
- 相对于一般的线程池实现,fork/join框架的优势体现在对其中包含的任务的处理方式上.在一般的线程池中,如果一个线程正在执行的任务由于某些原因无法继续运行,那么该线程会处于等待状态。而在fork/join框架实现中,如果某个子问题由于等待另外一个子问题的完成而无法继续运行。那么处理该子问题的线程会主动寻找其他尚未运行的子问题来执行.这种方式减少了线程的等待时间,提高了性能。
ForkJoinPool封装类:
package com.company;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
public final class ForkJoinPoolUtils {
private static final int CPUS_COUNT = Runtime.getRuntime().availableProcessors();
private ForkJoinPoolUtils(){}
public static <T> T executeInDedicatedThreadPool(Callable<T> task){
return executeInDedicatedThreadPool(task, CPUS_COUNT);
}
public static <T> T invokeInDedicatedThreadPool(ForkJoinTask<T> task){
return new ForkJoinPool(CPUS_COUNT).invoke(task);
}
public static <T> T executeInDedicatedThreadPool(Callable<T> task, int threadsCount){
try{
return new ForkJoinPool(threadsCount).submit(task).get();
}
catch( ExecutionException execEx ){
throw new IllegalStateException(execEx);
}
catch(InterruptedException interEx ){
Thread.currentThread().interrupt();
throw new IllegalStateException(interEx);
}
}
}
使用forkJoinPool Demo:
package com.company;
import java.time.Duration;
import java.time.Instant;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
public class TestForkJoinPool {
public static void main(String[] args) {
Instant start = Instant.now();
ForkJoinTask<Long> task = new ForkJoinSumCalculate(0L, 500000000L);
Long sum = ForkJoinPoolUtils.invokeInDedicatedThreadPool(task);
System.out.println(sum);
Instant end = Instant.now();
System.out.println("耗费时间为:" + Duration.between(start, end).toMillis());//166-1996-10590
}
}
class ForkJoinSumCalculate extends RecursiveTask<Long> {
private static final long serialVersionUID = -259195479995561737L;
private long start;
private long end;
private static final long THURSHOLD = 10000L; //临界值
public ForkJoinSumCalculate(long start, long end) {
this.start = start;
this.end = end;
}
@Override
protected Long compute() {
long length = end - start;
if (length <= THURSHOLD) {
long sum = 0L;
for (long i = start; i <= end; i++) {
sum += i;
}
return sum;
} else {
long middle = (start + end) / 2;
ForkJoinSumCalculate left = new ForkJoinSumCalculate(start, middle);
left.fork(); //进行拆分,同时压入线程队列
ForkJoinSumCalculate right = new ForkJoinSumCalculate(middle + 1, end);
right.fork(); //
return left.join() + right.join();
}
}
}
结果:
125000000250000000
耗费时间为:204
posted on 2017-04-03 17:15 西北野狼 阅读(46) 评论(0) 编辑 收藏 刷新评论刷新页面返回顶部 注册用户登录后才能发表评论,请 登录 或 注册, 访问网站首页。 【推荐】超50万VC++源码: 大型工控、组态\仿真、建模CAD源码2018!
【推荐】微信小程序一站式部署 多场景模板定制
最新IT新闻:
· 余承东为何会被传转岗?
· 孙正义的“猎物”、“队友”和“敌人”
· 机器人先生Geoffrey Hinton
· 即使《星际争霸2》衰落,其架构和理念还可延伸至无人驾驶等
· 欠款近百亿,金立正面临生死一线
» 更多新闻... 最新知识库文章:
· 领域驱动设计在互联网业务开发中的实践
· 步入云计算
· 以操作系统的角度述说线程与进程
· 软件测试转型之路
· 门内门外看招聘
» 更多知识库文章... 昵称:西北野狼
园龄:4年6个月
粉丝: 34
关注: 3 +加关注
|
||||||
日 | 一 | 二 | 三 | 四 | 五 | 六 |
---|---|---|---|---|---|---|
28 | 29 | 30 | 31 | 1 | 2 | 3 |
4 | 5 | 6 | 7 | 8 | 9 | 10 |
11 | 12 | 13 | 14 | 15 | 16 | 17 |
18 | 19 | 20 | 21 | 22 | 23 | 24 |
25 | 26 | 27 | 28 | 1 | 2 | 3 |
4 | 5 | 6 | 7 | 8 | 9 | 10 |
搜索
常用链接
我的标签
- android 5.0(16)
- ormlite(3)
- AndroidGradle(2)
- java复习(2)
- swift object c学习(1)
- Swift or Object c(1)
随笔分类
- 【android 面试】(12)
- 【android】(194)
- 【android--bug】(33)
- 【android--openGL】(1)
- 【androidstudio--学习和使用经验】(2)
- 【android--Thread--线程池的使用】(1)
- 【android--性能优化】(19)
- 【App研发录读书笔记】(6)
- 【Effactive Java】(2)
- 【Eventbus】(7)
- 【Gradle学习】
- 【html5】(6)
- 【IOS】(3)
- 【J2EE】(22)
- 【J2EE面试题】(2)
- 【Java -- JDBC 学习】(12)
- 【java 1.8 新特性学习】
- 【Java NIO -- IO高级进阶】(7)
- 【java 基础复习】(5)
- 【JavaWeb】(2)
- 【java多线程 -- 高级进阶】(10)
- 【JDK源码学习】(2)
- 【json异常】(2)
- 【maven学习】(4)
- 【MySQL】(1)
- 【phoneGap学习】(1)
- 【python 学习】(11)
- 【Rxjava学习】(1)
- 【Servlet】(2)
- 【shell脚本学习】
- 【sqlite高级进阶】(1)
- 【Volley学习和源码分析】(7)
- 【Web前端 -- JavaScript 学习和复习】(8)
- 【Web前端--Html&Css学习复习】(39)
- 【产品知识学习】
- 【计划】(1)
- 【设计模式复习】(26)
- 【深入理解java虚拟机】(2)
- 【数据结构与算法】(6)
- 【移动支付】(3)
- 【重构-改善既有代码的设计】
- 【自定义控件】(7)
随笔档案
- 2017年11月 (3)
- 2017年10月 (8)
- 2017年9月 (9)
- 2017年8月 (11)
- 2017年7月 (4)
- 2017年6月 (26)
- 2017年5月 (22)
- 2017年4月 (40)
- 2017年3月 (18)
- 2017年2月 (11)
- 2017年1月 (9)
- 2016年9月 (5)
- 2016年8月 (6)
- 2016年7月 (2)
- 2016年6月 (4)
- 2016年5月 (7)
- 2016年4月 (8)
- 2016年3月 (2)
- 2016年2月 (2)
- 2016年1月 (2)
- 2015年12月 (6)
- 2015年11月 (10)
- 2015年10月 (10)
- 2015年9月 (11)
- 2015年8月 (5)
- 2015年7月 (13)
- 2015年6月 (6)
- 2015年5月 (17)
- 2015年4月 (10)
- 2015年3月 (6)
- 2015年2月 (4)
- 2015年1月 (19)
- 2014年12月 (15)
- 2014年11月 (11)
- 2014年10月 (1)
- 2014年9月 (2)
- 2014年8月 (4)
- 2014年7月 (2)
- 2014年6月 (2)
- 2014年5月 (17)
- 2014年4月 (11)
- 2014年3月 (6)
- 2014年2月 (4)
- 2014年1月 (17)
- 2013年12月 (38)
- 2013年11月 (21)
- 2013年10月 (2)
- 2013年9月 (1)
- 2013年8月 (7)
My github
我的个人博客站点
积分与排名
- 积分 - 110533
- 排名 - 2676
最新评论
- 1. Re:J2EE--常见面试题总结 -- 一
- mark
- --Jason928
- 2. Re:LinkedHashMap 源码解析
- @稻花谢谢,也欢迎多多指点和建议...
- --西北野狼
- 3. Re:LinkedHashMap 源码解析
- 非常不错
- --稻花
- 4. Re:项目实战之集成邮件开发
- 不错!
- --天边里
- 5. Re:Spring -- AOP
- @BillySir通过 ProceedingJoinPoint 或者JoinPoint...
- --西北野狼
阅读排行榜
- 1. Glide加载圆形图片(13833)
- 2. androidstudio--gsonformat--超爽的数据解析方式(9864)
- 3. android app 集成 支付宝支付 微信支付(6304)
- 4. 项目中处理android 6.0权限管理问题(4390)
- 5. Activity生命周期方法调用finish后的不同表现(4353)
评论排行榜
- 1. material design 的android开源代码整理(4)
- 2. Spring -- AOP(2)
- 3. 如何在使用eclipse的情况下,清理android项目中的冗余class文件和资源文件以及冗余图片(2)
- 4. android使用shape做selector按钮按下和弹起的动画(2)
- 5. java泛型操作复习,以及讲解在android中使用的场景(2)
推荐排行榜
- 1. material design 的android开源代码整理(8)
- 2. 某技术大牛的帖子(android项目总结)(1)
- 3. android经典开源代码集合(1)
- 4. android -- 加载gif 防止oom(1)
- 5. android 实现透明状态栏(1)