以下示例来自网络。
package com.wjxie.test.forkjoin;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;
/**
* 并行计算 1 到 n 之和。
*
* Created by wenjing.xie on 2016年4月20日
*/
public class Calculator extends RecursiveTask<Integer> {
private static final long serialVersionUID = 1L;
private static final int THRESHOLD = 100;
private int start;
private int end;
public Calculator(int start, int end) {
this.start = start;
this.end = end;
}
@Override
protected Integer compute() {
int sum = 0;
if (end - start < THRESHOLD) {
for (int i = start; i < end; i++) {
sum += i;
}
} else {
int middle = (start + end) / 2;
Calculator left = new Calculator(start, middle);
Calculator right = new Calculator(middle + 1, end);
left.fork();
right.fork();
sum = left.join() + right.join();
}
return sum;
}
public static void main(String[] args) throws InterruptedException, ExecutionException {
ForkJoinPool forkJoinPool = new ForkJoinPool();
// 继承关系: RecursiveTask --> ForkJoinTask --> Future
Future<Integer> result = forkJoinPool.submit(new Calculator(0, 10000));
System.out.println("当前活跃线程数: " + Thread.getAllStackTraces().size());
System.out.println(result.get());
}
}
package com.wjxie.test.forkjoin;
import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;
import java.util.concurrent.TimeUnit;
/**
* 并行排序数组。
*
* Created by wenjing.xie on 2016年4月20日
*/
public class SortTask extends RecursiveAction {
private static final long serialVersionUID = 1L;
final long[] array;
final int start;
final int end;
private int THRESHOLD = 100;
public SortTask(long[] array) {
this.array = array;
this.start = 0;
this.end = array.length - 1;
}
public SortTask(long[] array, int start, int end) {
this.array = array;
this.start = start;
this.end = end;
}
protected void compute() {
if (end - start < THRESHOLD)
sequentiallySort(array, start, end);
else {
int pivot = partition(array, start, end);
new SortTask(array, start, pivot - 1).fork();
new SortTask(array, pivot + 1, end).fork();
}
}
/**
* 取数组 array[start-end] 的中间数的下标,并使得 array[pivot] 左边的元素比自己小,右边的比自己大。
*/
private int partition(long[] array, int start, int end) {
long x = array[end];
int i = start - 1;
for (int j = start; j < end; j++) {
if (array[j] <= x) {
i++;
swap(array, i, j);
}
}
swap(array, i + 1, end);
return i + 1;
}
private void swap(long[] array, int i, int j) {
if (i != j) {
long temp = array[i];
array[i] = array[j];
array[j] = temp;
}
}
private void sequentiallySort(long[] array, int lo, int hi) {
Arrays.sort(array, lo, hi + 1);
}
public static void main(String[] args) throws InterruptedException {
int SIZE = 10000;
ForkJoinPool forkJoinPool = new ForkJoinPool();
Random rnd = new Random();
long[] array = new long[SIZE];
for (int i = 0; i < SIZE; i++) {
array[i] = rnd.nextInt();
}
forkJoinPool.submit(new SortTask(array));
forkJoinPool.shutdown();
forkJoinPool.awaitTermination(1000, TimeUnit.SECONDS);
for (long item : array) {
System.out.println(item);
}
}
}
分享到:
相关推荐
介绍了ForkJoin并发框架,供有java基础者学习,工作配合使用,附件带有PPT,介绍并发与并行区别,和ForkJoin代码范例,资源来自网络,分享分享!
《Java并发编程从入门到精通》内容包括并发编程概念,线程,线程安全,线程集合类,线程阀,线程池,Fork/Join,线程、线程池在互联网项目开发的应用,线程监控及线程分析,Android中线程应用。 本书适合Java开发...
为所有Spring开发提供根本上更快且可广泛访问的入门经验 开箱即用,但是随着需求开始偏离默认值,您会很快摆脱困境 提供一系列大型项目共有的非功能性功能(例如,嵌入式服务器,安全性,指标,运行状况检查,外部...
用fork开展地下工作 发送及接收信号 习题 第十七章高级perl技巧 用eval捕获错误 用grep来筛选列表 用map对列表进行转换 不带引号的哈希键 切片 习题 附录a习题解答 附录b超越小骆驼...
《Java学习指南(第4版)(上、下册)》加入了从Java 6和Java 7发布以后的变化,包括新的语言功能、并发工具(Fork-Join框架)、新的NIO Files API、Java Servlet(3.0)等新主题,作者通过精心挑选的、富有实用性和趣味性...
第三节、CUDA与fork/join模式 .................................................................................... 4 第四节、CUDA C语言 .....................................................................
分散其简约的结构,此爬虫基于 Java ForkJoin 框架,该框架允许 RexCrawler 通过将其本地工作负载分区来按需创建其他守护进程。 这种方法的一个关键好处是更好地控制粒度和更少的同步。 入门 关于如何使用 ...
Java并发Fork-Join框架原理解析.docx JAVA核心知识整理.pdf JAVA核心知识点整理.pdf Java面试笔记.docx JAVA面试题解惑系列.pdf Java面试题(基础).pdf JVM 实用参数系列 - v1.0.pdf JVM与性能优化知识点整理.pdf ...
流程节点详解.....................................67 3.1 公共属性.............Fork和Join节点.........................................81 3.7 Decision节点.............................................86 3.8 ...
流程节点详解.....................................67 3.1 公共属性.............Fork和Join节点.........................................81 3.7 Decision节点.............................................86 3.8 ...
高并发编程第三阶段34讲 ForkJoin框架之RecursiveAction_.mp4 高并发编程第三阶段35讲 Phaser工具的实战案例使用第一部分_.mp4 高并发编程第三阶段36讲 Phaser工具的实战案例使用第二部分_.mp4 高并发编程第...
高并发编程第三阶段34讲 ForkJoin框架之RecursiveAction_.mp4 高并发编程第三阶段35讲 Phaser工具的实战案例使用第一部分_.mp4 高并发编程第三阶段36讲 Phaser工具的实战案例使用第二部分_.mp4 高并发编程第...