fork join框架

Java 7中的Fork / Join Framework專為可分解為較小任務(wù)的工作而設(shè)計(jì)，并將這些任務(wù)的結(jié)果組合起來(lái)以產(chǎn)生最終結(jié)果。 通常，使用Fork / Join Framework的類遵循以下簡(jiǎn)單算法：

// pseudocode Result solve(Problem problem) {if (problem.size < SEQUENTIAL_THRESHOLD)return solveSequentially(problem);else {Result left, right;INVOKE-IN-PARALLEL {left = solve(extractLeftHalf(problem));right = solve(extractRightHalf(problem));}return combine(left, right);} }

為了證明這一點(diǎn)，我創(chuàng)建了一個(gè)示例，使用fork / join從一個(gè)大型數(shù)組中查找最大數(shù)量：

import java.util.Random; import java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveTask;public class MaximumFinder extends RecursiveTask<Integer> {private static final int SEQUENTIAL_THRESHOLD = 5;private final int[] data;private final int start;private final int end;public MaximumFinder(int[] data, int start, int end) {this.data = data;this.start = start;this.end = end;}public MaximumFinder(int[] data) {this(data, 0, data.length);}@Overrideprotected Integer compute() {final int length = end - start;if (length < SEQUENTIAL_THRESHOLD) {return computeDirectly();}final int split = length / 2;final MaximumFinder left = new MaximumFinder(data, start, start + split);left.fork();final MaximumFinder right = new MaximumFinder(data, start + split, end);return Math.max(right.compute(), left.join());}private Integer computeDirectly() {System.out.println(Thread.currentThread() + ' computing: ' + start+ ' to ' + end);int max = Integer.MIN_VALUE;for (int i = start; i < end; i++) {if (data[i] > max) {max = data[i];}}return max;}public static void main(String[] args) {// create a random data setfinal int[] data = new int[1000];final Random random = new Random();for (int i = 0; i < data.length; i++) {data[i] = random.nextInt(100);}// submit the task to the poolfinal ForkJoinPool pool = new ForkJoinPool(4);final MaximumFinder finder = new MaximumFinder(data);System.out.println(pool.invoke(finder));} }

MaximumFinder類是一個(gè)RecursiveTask ，它負(fù)責(zé)從數(shù)組中查找最大數(shù)目。 如果數(shù)組的大小小于閾值（5），則通過(guò)遍歷數(shù)組直接找到最大值。 否則，將數(shù)組分成兩半，每半遞歸并等待它們完成（ join ）。 一旦我們得到了每一半的結(jié)果，我們就可以找到兩個(gè)的最大值并返回。

參考： Java 7：我們的JCG合作伙伴 Fahd Shariff在fahd.blog博客上提供的Fork / Join Framework Example 。

翻譯自: https://www.javacodegeeks.com/2013/02/java-7-forkjoin-framework-example.html

fork join框架

總結(jié)

以上是生活随笔為你收集整理的fork join框架_Java 7：Fork / Join框架示例的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。