将复杂的大任务拆分成多个简单的小任务进行计算

时间：2015-07-09 18:11:41 阅读：155 评论：0 收藏：0 [点我收藏+]

package thread;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;
/**
* Fork/Join框架实现多线程计算<br/>
* 计算1+2+3+4+...+99+100的总和<br/>
* 因为本程序模拟的是最简单的计算，耗时极少，所以多线程计算还不如单线程计算快。<br/>
* 但如果是比较耗时的复杂计算，多线程计算就快得多啦！
* @author zhaoyujie
*
*/
public class CountTask extends RecursiveTask<Integer> {

private static final long serialVersionUID = -4488036422261690638L;

private static final int THRESHOLD = 10;
private int start;
private int end;

public CountTask(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;
CountTask leftTask = new CountTask(start, middle);
CountTask rightTask = new CountTask(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) {
long currTime = System.currentTimeMillis();
ForkJoinPool forkJoinPool = new ForkJoinPool();
CountTask task = new CountTask(1, 100);
Future<Integer> future = forkJoinPool.submit(task);
try {
System.out.println(future.get());
System.out.println("用时毫秒数："+(System.currentTimeMillis()-currTime));
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}

}

标签：多线程拆分任务计算

原文地址：http://blog.csdn.net/keketrtr/article/details/46818179

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行