Java 中如何使用 Fork/Join 框架？

淡淡的烟草味﹌ 2024-03-22 16:03 48阅读 0赞

什么是 Fork/Join 框架？

Fork/Join 框架是 Java 7 中引入的一个用于并行计算的框架。它基于工作窃取算法（work-stealing algorithm），可以将一个大任务拆分成多个小任务交给多个线程并行执行，然后将结果汇总返回。Fork/Join 框架的核心思想是将一个大任务拆分成多个小任务，然后将小任务分配给不同的线程执行，线程在执行完自己的任务后会尝试“窃取”其他线程尚未执行的任务，以保证所有线程的负载均衡。

![在这里插入图片描述][9852eef2d4864b6fbd96eb4f8712cf98.png]

Fork/Join 框架的使用场景通常是需要处理的任务比较大且计算密集型，可以通过并行计算来提高计算速度。在 Java 中，Fork/Join 框架主要用于处理数组、列表等数据结构的计算任务。

Java 中如何使用 Fork/Join 框架？

Java 中使用 Fork/Join 框架的主要步骤包括以下几个方面：

### 定义任务类 ###

Fork/Join 框架中的任务类需要继承自`RecursiveTask`或`RecursiveAction`类。其中，`RecursiveTask`类用于有返回值的任务，`RecursiveAction`类用于没有返回值的任务。任务类需要实现`compute()`方法，该方法是具体的计算逻辑。

例如，下面是一个计算斐波那契数列的任务类：

import java.util.concurrent.RecursiveTask;
    
    public class FibonacciTask extends RecursiveTask<Integer> {
    
        private final int n;
    
        public FibonacciTask(int n) {
            this.n = n;
        }
    
        @Override
        protected Integer compute() {
            if (n <= 1) {
                return n;
            } else {
                FibonacciTask f1 = new FibonacciTask(n - 1);
                FibonacciTask f2 = new FibonacciTask(n - 2);
                f##fork();
                int result2 = f2.compute();
                int result1 = f##join();
                return result1 + result2;
            }
        }
    }

在上面的代码中，`FibonacciTask`类继承自`RecursiveTask`类，`compute()`方法实现了斐波那契数列的计算逻辑。如果`n`的值小于等于 1，则直接返回`n`。否则，创建两个新的任务`f1`和`f2`，分别计算`n - 1`和`n - 2`的斐波那契数列，然后调用`f##fork()`启动`f1`的计算，并在当前线程中计算`f2`的结果。最后使用`f##join()`等待`f1`计算完成，并将`f1`和`f2`的结果相加返回。

### 创建 ForkJoinPool 对象 ###

Fork/Join 框架需要使用`ForkJoinPool`对象来管理线程池和任务队列。可以使用`Executors.newWorkStealingPool()`方法创建一个默认的 ForkJoinPool 对象，也可以使用`ForkJoinPool`类的构造方法创建自定义的 ForkJoinPool 对象。

例如，下面是创建一个默认的 ForkJoinPool 对象的示例代码：

import java.util.concurrent.ForkJoinPool;
    
    public class Main {
        public static void main(String[] args) {
            ForkJoinPool pool = Executors.newWorkStealingPool();
            FibonacciTask task = new FibonacciTask(10);
            int result = pool.invoke(task);
            System.out.println(result);
        }
    }

在上面的代码中，`Executors.newWorkStealingPool()`方法创建了一个默认的 ForkJoinPool 对象，`FibonacciTask`类是上一步定义的斐波那契数列任务类，`pool.invoke(task)`方法启动任务的执行，并等待任务完成。最后将计算结果打印出来。

### 提交任务 ###

创建 ForkJoinPool 对象后，需要将任务提交给 ForkJoinPool 对象执行。可以使用`invoke()`方法、`submit()`方法或`execute()`方法提交任务。

例如，下面是使用`invoke()`方法提交任务的示例代码：

java

Copy

import java.util.concurrent.ForkJoinPool;
    
    public class Main {
        public static void main(String[] args) {
            ForkJoinPool pool = Executors.newWorkStealingPool();
            FibonacciTask task = new FibonacciTask(10);
            int result = pool.invoke(task);
            System.out.println(result);
        }
    }

在上面的代码中，`pool.invoke(task)`方法提交了任务，并等待任务完成。最后将计算结果打印出来。

### 处理任务结果 ###

在任务计算完成后，需要获取计算结果。可以通过任务类的返回值或通过`join()`方法获取计算结果。

例如，下面是获取任务计算结果的示例代码：

import java.util.concurrent.ForkJoinPool;
    
    public class Main {
        public static void main(String[] args) {
            ForkJoinPool pool = Executors.newWorkStealingPool();
            FibonacciTask task = new FibonacciTask(10);
            pool.execute(task);
            int result = task.join();
            System.out.println(result);
        }
    }

在上面的代码中，`pool.execute(task)`方法提交任务，然后使用`task.join()`方法等待任务完成，并获取计算结果。最后将计算结果打印出来。

Fork/Join 框架的优点是可以自动利用多核处理器来提高计算性能，而且不需要手动维护线程池和任务队列。但是，它并不适合所有类型的任务，对于 IO 密集型任务或者需要大量等待的任务，Fork/Join 框架的效率可能不如传统的线程池框架。因此，在使用 Fork/Join 框架时，需要根据实际任务类型和计算需求进行评估和选择。

附代码：

import java.util.concurrent.ForkJoinPool;
    import java.util.concurrent.RecursiveTask;
    
    public class FibonacciTask extends RecursiveTask<Integer> {
    
        private final int n;
    
        public FibonacciTask(int n) {
            this.n = n;
        }
    
        @Override
        protected Integer compute() {
            if (n <= 1) {
                return n;
            } else {
                FibonacciTask f1 = new FibonacciTask(n - 1);
                FibonacciTask f2 = new FibonacciTask(n - 2);
                f##fork();
                int result2 = f2.compute();
                int result1 = f##join();
                return result1 + result2;
            }
        }
    
        public static void main(String[] args) {
            ForkJoinPool pool = Executors.newWorkStealingPool();
            FibonacciTask task = new FibonacciTask(10);
            int result = pool.invoke(task);
            System.out.println(result);
        }
    }

[9852eef2d4864b6fbd96eb4f8712cf98.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/59533a7ab0034377863f2a34f5d8f02e.png

发表评论取消回复

表情：

评论列表（有 0 条评论，48人围观）

还没有评论，来说两句吧...

相关阅读

相关 forkjoin框架的简单使用

目录 1.说明 2.使用场景 3.实例 -------------------- 1.说明是一个分而治之的任务框架，如一个任务需要多线程执行，分割成很多块计算

淡淡的烟草味﹌/ 2023年09月27日 13:04/ 0 赞/ 146 阅读

相关 ForkJoin框架简单使用

场景描述设想这样一个场景，在一个接口中，需要通过http的方式调用多个外部接口，而且可能存在某几个接口非常耗时的情况，这么一来，对当前接口来说，由于是串行的执行，忽略本

拼搏现实的明天。/ 2023年07月14日 14:59/ 0 赞/ 7 阅读

相关 fork() Java_java中的forkjoin框架的使用

fork join框架是java 7中引入框架，这个框架的引入主要是为了提升并行计算的能力。 fork join主要有两个步骤，第一就是fork，将一个大任务分成很多个小任务

太过爱你忘了你带给我的痛/ 2022年11月05日 08:57/ 0 赞/ 157 阅读

相关 ForkJoin框架

介绍 Fork/Join它可以将一个大的任务拆分成多个子任务进行并行处理，最后将子任务结果合并成最后的计算结果，并进行输出。Fork/Join框架要完成两件事情： Fo

r囧r小猫/ 2022年09月08日 03:35/ 0 赞/ 229 阅读

相关 ForkJoin框架

介绍 Fork/Join它可以将一个大的任务拆分成多个子任务进行并行处理，最后将子任务结果合并成最后的计算结果，并进行输出。Fork/Join框架要完成两件事情： Fo

骑猪看日落/ 2022年09月08日 00:19/ 0 赞/ 254 阅读

相关 ForkJoin框架

介绍 Fork/Join 是 JDK 1.7 加入的新的线程池实现，它体现的是一种分治思想，适用于能够进行任务拆分的 cpu 密集型运算 Fork/Join它可以将一个

本是古典何须时尚/ 2022年08月28日 13:46/ 0 赞/ 276 阅读

相关 ForkJoin框架详解

一、ForkJoin主要类主要类有以下4个： 1、ForkJoinPool 2、ForkJoinTask 3、ForkJoinWorkerThread

你的名字/ 2022年05月28日 07:19/ 0 赞/ 252 阅读

相关 Java7 ForkJoin框架详解

Fork/Join框架是Java 7提供的一个用于并行执行任务的框架，是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架。Fork/Join框架要完

深藏阁楼爱情的钟/ 2022年05月14日 09:45/ 0 赞/ 288 阅读

相关 Java7 ForkJoin框架详解

Fork/Join框架是Java 7提供的一个用于并行执行任务的框架，是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架。Fork/Join框架要完

柔情只为你懂/ 2022年05月14日 00:10/ 0 赞/ 246 阅读

相关 ForkJoin框架原理

任务性质类型 CPU密集型 CPU密集型也叫计算密集型，系统的硬盘、内存性能相对于CPU会好很多，此时系统运作大部分的状况是CPU Loading 100%、CPU要读写I

曾经终败给现在/ 2021年09月25日 05:56/ 0 赞/ 372 阅读