forkjoin使用实例

ForkJoin 是 Java 并发库中的一个类，用于实现任务的并行计算。下面是一个使用 ForkJoin 的示例代码：

import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveTask;

public class ForkJoinExample extends RecursiveTask<Integer> {
    private static final int THRESHOLD = 2;
    private int[] arr;
    private int start;
    private int end;

    public ForkJoinExample(int[] arr, int start, int end) {
        this.arr = arr;
        this.start = start;
        this.end = end;
    }

    @Override
    protected Integer compute() {
        int sum = 0;
        if (end - start <= THRESHOLD) {
            for (int i = start; i < end; i++) {
                sum += arr[i];
            }
        } else {
            int mid = (start + end) / 2;
            ForkJoinExample left = new ForkJoinExample(arr, start, mid);
            ForkJoinExample right = new ForkJoinExample(arr, mid, end);
            left.fork();
            right.fork();
            sum = left.join() + right.join();
        }
        return sum;
    }

    public static void main(String[] args) {
        int[] arr = {1, 2, 3, 4, 5, 6, 7, 8};
        ForkJoinExample task = new ForkJoinExample(arr, 0, arr.length);
        ForkJoinPool pool = new ForkJoinPool();
        Integer result = pool.invoke(task);
        System.out.println(result);
    }
}

在上面的示例中，我们定义了一个 `ForkJoinExample` 类来实现并行计算数组中元素的和。其中，`THRESHOLD` 常量表示当计算的数组元素个数小于等于 2 时，就直接计算它们的和，而不再进行分割。`compute()` 方法是 ForkJoin 框架中的核心方法，它将任务分割成子任务，并进行递归执行，最终将结果合并返回。在 `main()` 方法中，我们创建了一个 `ForkJoinExample` 对象，并将它交给 `ForkJoinPool` 线程池来执行，并输出最终的结果。