浅谈Java的Fork/Join并发框架

/**

* Description: ForkJoin基类

* Designer: jack

* Date: 2017/8/3

* Version: 1.0.0

public class ForkJoinTest extends ForkJoinService<List<String>> {

private static ForkJoinTest forkJoinTest;

private int threshold; //阈值

private List<String> list; //待拆分List

private ForkJoinTest(List<String> list, int threshold) {

this.list = list;

this.threshold = threshold;

}

@Override

protected List<String> compute() {

// 当end与start之间的差小于阈值瓯，开端进行实际筛选

if (list.size() < threshold) {

return list.parallelStream().filter(s -> s.contains("a")).collect(Collectors.toList());

} else {

// 如不雅当end与start之间的差大年夜于阈值时,将大年夜义务分化成两个小义务。

int middle = list.size() / 2;

List<String> leftList = list.subList(0, middle);

List<String> rightList = list.subList(middle, list.size());

ForkJoinTest left = new ForkJoinTest(leftList, threshold);

ForkJoinTest right = new ForkJoinTest(rightList, threshold);

// 并行履行两个“小义务”

left.fork();

right.fork();

　　推荐阅读

　　Gartner公布2017年全球云存储魔力象限：阿里云跻身四强全球前四

图1-2017年Gartner全球云存储魔力象限图据媒体报道，国际有名调研机构Gartner近日颁布了2017年全球云计算云存储魔力象限。阿里云的云存储成长敏捷，与AWS、Microsoft、Google合营跻身这一>>>详细阅读

地址：http://www.17bianji.com/lsqh/36553.html