new ForkJoinPool();

ForkJoinService<List<String>> forkJoinService = ForkJoinTest.getInstance(stringList, 20);

// 提交可分化的ForkJoinTask义务

ForkJoinTask<List<String>> future = pool.submit(forkJoinService);

System.out.println(future.get());

// 封闭线程池

pool.shutdown();

}

下面是引用Oracle官方定义的原文：

The fork/join framework is an implementation of the ExecutorService interface that helps you take advantage of multiple processors. It is designed for work that can be broken into smaller pieces recursively. The goal is to use all the available processing power to enhance the performance of your application.
代码如下：
As with any ExecutorService implementation, the fork/join framework distributes tasks to worker threads in a thread pool. The fork/join framework is distinct because it uses a work-stealing algorithm. Worker threads that run out of things to do can steal tasks from other threads that are still busy.
The center of the fork/join framework is the ForkJoinPool class, an extension of the AbstractExecutorService class. ForkJoinPool implements the core work-stealing algorithm and can execute ForkJoinTask processes.

2. Fork/Join的根本用法

（1）Fork/Join基类

上文已经提到，Fork/Join就是要讲一个大年夜的义务瓜分成若干小的义务，所以第一步当然是要做义务的瓜分，大年夜致方法如下：

if (这个义务足够小){ 
  履行要做的义务 
} else { 
  将义务瓜分成两小部分 
  履行两小部分并等待履行结不雅 
}

要实现FrokJoinTask我们须要一个持续了RecursiveTask或RecursiveAction的基类，并根据自身营业情况将膳绫擎的代码放入基类的coupute办法中。RecursiveTask和RecursiveAction都持续了FrokJoinTask，它俩的差别就是RecursiveTask有返回值而RecursiveAction没有。下面是我做的一个选出字符串列表中还有"a"的元素的Demo：

@Override 
protected List<String> compute() { 
    // 当end与start之间的差小于阈值瓯，开端进行实际筛选 
    if (end - this.start < threshold) { 
        List<String> temp = list.subList(this.start, end); 
        return temp.parallelStream().filter(s -> s.contains("a")).collect(Collectors.toList()); 
    } else { 
        // 如不雅当end与start之间的差大年夜于阈值时 
        // 将大年夜义务分化成两个小义务。 
        int middle = (this.start + end) / 2; 
	
			 2/5   首页 上一页 1 2 3 4 5 下一页 尾页	
			

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


本文标题：浅谈Java的Fork/Join并发框架
地址：http://www.17bianji.com/lsqh/36553.html
 1/2    1