用于实现Fork/Join框架。
适用于将一个大任务拆分成多个小任务并行处理的情况。
使用场景：适用于需要利用多核处理器性能的应用程序，如图像处理、大数据分析等。
import java.util.concurrent.ForkJoinPool; ?
import java.util.concurrent.RecursiveAction; ?
??
public class ForkJoinPoolExample { ?
? ? public static void main(String[] args) { ?
? ? ? ? // 创建一个ForkJoinPool线程池，包含4个工作线程 ?
? ? ? ? ForkJoinPool pool = new ForkJoinPool(4); ?
??
? ? ? ? // 提交一个任务给线程池执行 ?
? ? ? ? pool.submit(new RecursiveAction() { ?
? ? ? ? ? ? @Override ?
? ? ? ? ? ? protected void compute() { ?
? ? ? ? ? ? ? ? if (size() > 0) { ?
? ? ? ? ? ? ? ? ? ? int half = size() / 2; ?
? ? ? ? ? ? ? ? ? ? invokeAll(new Task(0, half), new Task(half, size())); ?
? ? ? ? ? ? ? ? } else { ?
? ? ? ? ? ? ? ? ? ? compute(); ?
? ? ? ? ? ? ? ? } ?
? ? ? ? ? ? } ?
? ? ? ? }); ?
??
? ? ? ? // 关闭线程池 ?
? ? ? ? pool.shutdown(); ?
? ? } ?
} ?
??
class Task extends RecursiveAction { ?
? ? private int start; ?
? ? private int end; ?
? ? private int[] array; ?
??
? ? public Task(int start, int end) { ?
? ? ? ? this.start = start; ?
? ? ? ? this.end = end; ?
? ? ? ? this.array = new int[end - start]; ?
? ? } ?
??
? ? @Override ?
? ? protected void compute() { ?
? ? ? ? for (int i = start; i < end; i++) { ?
? ? ? ? ? ? array[i] = i; ?
? ? ? ? } ?
? ? ? ? System.out.println("Task " + start + " - " + end + " completed"); ?
? ? } ?
}
在这个例子中，我们创建了一个ForkJoinPool线程池，并提交了一个任务给线程池执行。任务是一个递归的RecursiveAction，它会将数组分成两部分，并分别调用invokeAll方法来并行执行两个子任务。每个子任务会计算数组的一部分，并在完成后输出一条消息。最后，我们关闭了线程池。ForkJoinPool适用于处理大量计算任务，它可以将任务拆分成较小的子任务，然后使用工作窃取算法来重新分配子任务，以充分利用多核处理器的计算能力。