Java 7中的Fork / Join Framework專為可分解為較小任務的工作而設計，并將這些任務的結果組合起來以產生最終結果。 通常，使用Fork / Join Framework的類遵循以下簡單算法：

// 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);} }

為了證明這一點，我創建了一個示例，使用fork / join從一個大型數組中查找最大數量：

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類是RecursiveTask ，它負責從數組中查找最大數目。 如果數組的大小小于閾值（5），則通過遍歷數組直接找到最大值。 否則，將數組分成兩半，每半遞歸，然后等待它們完成（ join ）。 一旦我們得到了每一半的結果，我們就可以找到兩個的最大值并返回。

參考： fahd.blog博客上的JCG合作伙伴 Fahd Shariff的Java 7：Fork / Join Framework示例 。

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

總結

以上是生活随笔為你收集整理的Java 7：Fork / Join框架示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。