java Fork/Join框架的使用方法

本篇内容介绍了“java Fork/Join框架的使用方法”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

Fork/Join框架重点说明：

1，在必要的情况下，将一个大任务，进行拆分（fork） 成若干个子任务（拆到不能再拆，这里就是指我们制定的拆分的临界值），再将一个个小任务的结果进行join汇总。

2，Fork/Join采用“工作窃取模式”。

3，ForkJoin更有效的利用的CPU资源。

4，Java 8 中将并行流进行了优化，Stream API可以声明性的通过parallel()与sequential()在并行流与串行流中随意切换。

以下是简单示例：

public class ForkJoinWorkTest extends RecursiveTask<Long> {

    private Long start;
    private Long end;
    public static final Long critical = 100000L;

    public ForkJoinWorkTest(Long start, Long end) {
        this.start = start;
        this.end = end;
    }

    @Override
    protected Long compute() {

        Long length = end - start;
        if(length <= critical) {
            // 拆分完毕
            Long sum = 0L;
            for(Long i = start; i <= end; i++) {
                sum += i;
            }
            return sum;
        } else {
            // 未拆分完毕
            Long middle = (end + start)/2;
            ForkJoinWorkTest right = new ForkJoinWorkTest(start, middle);
            right.fork();
            ForkJoinWorkTest left = new ForkJoinWorkTest(middle + 1, end);
            left.fork();

            return right.join() + left.join();
        }

    }

}

单元测试代码：

import java.util.concurrent.*;
import java.util.stream.LongStream;

public class ForkJoinWorkTestDemo {

    public static void main(String args[]) {

        Long startTime = System.currentTimeMillis();
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        ForkJoinTask<Long> forkJoinTask = new ForkJoinWorkTest(0L,100000000L);
        Long invoke = forkJoinPool.invoke(forkJoinTask);
        Long endTime = System.currentTimeMillis();
        System.out.println("forkAndJoin:"+invoke+" time:"+(endTime - startTime));

        System.out.println("=======================================================");

        Long startTime1 = System.currentTimeMillis();
        Long sum = 0L;
        for(Long i=0L;i<=100000000L;i++) {
            sum += i;
        }
        Long endTime1 = System.currentTimeMillis();
        System.out.println("normalSum:"+sum+" time:"+(endTime1 - startTime1));

        System.out.println("=======================================================");

        Long startTime2 = System.currentTimeMillis();
        Long sum8 = LongStream.rangeClosed(0, 100000000L).parallel().reduce(0,Long::sum);
        Long endTime2 = System.currentTimeMillis();
        System.out.println("Jdk8Sum:"+sum8+" time:"+(endTime2 - startTime2));

    }

}

结果如下：

“java Fork/Join框架的使用方法”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！