Java中如何高效运用ForkJoin框架实现并行计算？

本文共计1198个文字，预计阅读时间需要5分钟。

Fork/Join框架是Java 7引入的框架，主要目的是提升并行计算能力。该框架包含两个主要步骤：首先，Fork将一个大任务分解成多个小任务；其次，Join将完成的小任务结果合并，完成整个大任务。

fork join框架是java 7中引入框架，这个框架的引入主要是为了提升并行计算的能力。

fork join主要有两个步骤，第一就是fork，将一个大任务分成很多个小任务，第二就是join，将第一个任务的结果join起来，生成最后的结果。如果第一步中并没有任何返回值，join将会等到所有的小任务都结束。

还记得之前的文章我们讲到了thread pool的基本结构吗？

• ExecutorService - ForkJoinPool 用来调用任务执行。
• workerThread - ForkJoinWorkerThread 工作线程，用来执行具体的任务。
• task - ForkJoinTask 用来定义要执行的任务。

下面我们从这三个方面来详细讲解fork join框架。

ForkJoinPool

ForkJoinPool是一个ExecutorService的一个实现，它提供了对工作线程和线程池的一些便利管理方法。

public class ForkJoinPool extends AbstractExecutorService

一个work thread一次只能处理一个任务，但是ForkJoinPool并不会为每个任务都创建一个单独的线程，它会使用一个特殊的数据结构double-ended queue来存储任务。