博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
jdk7 并行计算框架Fork/Join
阅读量:5883 次
发布时间:2019-06-19

本文共 1923 字,大约阅读时间需要 6 分钟。

故名思义,拆分fork+合并join。jdk1.7整合Fork/Join,性能上有大大提升。

思想:充分利用多核CPU把计算拆分成多个子任务,并行计算,提高CPU利用率大大减少运算时间。有点像,MapReduce思路感觉大致一样。

jdk7中已经提供了最简洁的接口,让你不需要太多时间关心并行时线程的通信,死锁问题,线程同步,下面是它提供的接口:

简单示例:

package tank.forjoin.demo;import java.util.concurrent.RecursiveTask;/**        * @author tank        * @date:2014-8-27 下午01:30:06        * @description:        * @version :任务        * futrue:        * forkjoinTask:recursiveTask recursiveAction        */public class Demo1 extends RecursiveTask
{ private int start; private int end; public Demo1(int start, int end) { this.start = start; this.end = end; } //计算 @Override protected Integer compute() { int sum = 0; if (start - end < 100) { for (int i = start; i < end; i++) { sum += i; } } else {
//间隔有100则拆分多个任务计算 int middle = (start + end) / 2; Demo1 left = new Demo1(start, middle); Demo1 right = new Demo1(middle + 1, end); left.fork(); right.fork(); sum = left.join() + right.join(); } return sum; }}
package tank.forjoin.demo;import java.util.concurrent.ExecutionException;import java.util.concurrent.ForkJoinPool;import java.util.concurrent.Future;import org.junit.Test;/**        * @author tank        * @date:2014-8-27 下午01:50:20        * @description:        * @version :        */public class TestDemo1 {    @Test    public void testDemo1() throws InterruptedException, ExecutionException {        ForkJoinPool forkJoinPool = new ForkJoinPool();//对线程池的扩展        Future
result = forkJoinPool.submit(new Demo1(1, 10000)); System.out.println(result.get());            forkJoinPool.shutdown(); }}

RecursiveAction 无返回值任务。

RecursiveTask有返回值类型。
ForkJoinPool提供了一系列的submit方法,计算任务。ForkJoinPool默认的线程数通过Runtime.availableProcessors()获得,因为在计算密集型的任务中,获得多于处理性核心数的线程并不能获得更多性能提升。

 

转载地址:http://ngsix.baihongyu.com/

你可能感兴趣的文章
[Contiki系列论文之1]Contiki——为微传感器网络而生的轻量级的、灵活的操作系统...
查看>>
Android 网络编程 记录
查看>>
微软同步发行Windows 10和Windows 10 Mobile系统更新
查看>>
Zeppelin的入门使用系列之使用Zeppelin运行shell命令(二)
查看>>
form表单下的button按钮会自动提交表单的问题
查看>>
那些年追过的......写过的技术博客
查看>>
python基础教程_学习笔记19:标准库:一些最爱——集合、堆和双端队列
查看>>
CSS魔法堂:Transition就这么好玩
查看>>
Golang协程与通道整理
查看>>
解决win7远程桌面连接时发生身份验证错误的方法
查看>>
C/C++ 多线程机制
查看>>
js - object.assign 以及浅、深拷贝
查看>>
python mysql Connect Pool mysql连接池 (201
查看>>
Boost在vs2010下的配置
查看>>
一起谈.NET技术,ASP.NET伪静态的实现及伪静态的意义
查看>>
20款绝佳的HTML5应用程序示例
查看>>
string::c_str()、string::c_data()及string与char *的正确转换
查看>>
11G数据的hive初测试
查看>>
如何使用Core Text计算一段文本绘制在屏幕上之后的高度
查看>>
==和equals区别
查看>>