温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Java中forkjoin的原理和forkjoin怎么应用

发布时间:2022-02-21 17:03:35 来源:亿速云 阅读:118 作者:iii 栏目:开发技术

这篇文章主要介绍了Java中forkjoin的原理和forkjoin怎么应用的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Java中forkjoin的原理和forkjoin怎么应用文章都会有所收获,下面我们一起来看看吧。

ForkJoinTask就是ForkJoinPool里面的每一个任务。他主要有两个子类:RecursiveActionRecursiveTask。然后通过fork()方法去分配任务执行任务,通过join()方法汇总任务结果

这就是整个过程的运用。他有两个子类,使用这两个子类都可以实现我们的任务分配和计算。

(1)RecursiveAction 一个递归无结果的ForkJoinTask(没有返回值)

(2)RecursiveTask 一个递归有结果的ForkJoinTask(有返回值)

ForkJoinPool:中含有一个workQueues队列;

workQueues:由ForkJoinTask数组和workerThread和指向ForkJoinPool的引用;

ForkJoinTask数组负责存放程序提交给ForkJoinPool的任务,而workerThread数组负责执行这些任务,ForkJoinPool的引用是为了当ForkJoinTask数组中的任务处理完之后再次获取任务交给workerThread进行处理。

知识点扩展:Java并发Fork-Join框架原理解析

1、什么是Foirk/Join框架

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

2、什么是并行流与顺序流2.1 什么是并行流?

并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流。

2.2 工作窃取模式

某个线程从其他队列里窃取任务来执行,

3、使用Fork/Join框架

/**
 *  累加运算测试
 */
public class ForkJoinCalculate extends RecursiveTask<Long> {
 
    /**
     * 
     */
    private static final long serialVersionUID = 7125244951292834932L;
     
    private long start;// 起始值
    private long end;// 结束值
    private static final long THRESHOLD = 10000L;// 临界值
 
    @Override
    protected Long compute() {
        long length = end - start;
         
        if(length <= THRESHOLD) {
            long sum = 0L;
             
            for (long i = start; i <= end; i++) {
                sum += i;
            }
             
            return sum;
        }else {
            long middle = (start + end) / 2;// 中间值
             
            ForkJoinCalculate left = new ForkJoinCalculate(start, middle);// 0-50000000
            left.fork();// 拆分子任务,同时压入线程队列
            ForkJoinCalculate right = new ForkJoinCalculate(middle + 1, end);// 50000001-100000000
            right.fork();// 拆分子任务,同时压入线程队列
             
            return left.join() + right.join();// 汇总任务结果
        }
    }
     
    public ForkJoinCalculate() {
    }
 
    public ForkJoinCalculate(long start, long end) {
        this.start = start;
        this.end = end;
    }
}

4、Java8中的并行流和顺序流

4.1顺序流

/**
     * Java8的顺序流
     */
    @Test
    public void test3() {
        Instant start = Instant.now();// java8中新时间日期API
         
        LongStream.rangeClosed(0, 10000000000L)
                    .sequential()// 顺序流
                    .reduce(0, Long::sum);
         
        Instant end = Instant.now();
         
        // 5780
        System.out.println("耗费时间为:" + Duration.between(start, end).toMillis());// java8中新时间日期API
    }

4.2步行流

/**
     * Java8的并行流
     */
    @Test
    public void test4() {
        Instant start = Instant.now();// java8中新时间日期API
         
        LongStream.rangeClosed(0, 10000000000L)
                    .parallel()// 并行流
                    .reduce(0, Long::sum);
         
        Instant end = Instant.now();
         
        // 2392
        System.out.println("耗费时间为:" + Duration.between(start, end).toMillis());// java8中新时间日期API
    }

关于“Java中forkjoin的原理和forkjoin怎么应用”这篇文章的内容就介绍到这里,感谢各位的阅读!相信大家对“Java中forkjoin的原理和forkjoin怎么应用”知识都有一定的了解,大家如果还想学习更多知识,欢迎关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI