美文网首页
Java并发-23.Fork/Join框架

Java并发-23.Fork/Join框架

作者: 悠扬前奏 | 来源:发表于2019-05-30 17:56 被阅读0次
  • 什么是Fork/Join框架
    • Fork把一个大任务切分成若干个子任务
    • Join把子任务的执行结果合并
  • 工作窃取算法
    • 是什么:某个线程从其他队列窃取任务来执行。
    • 双端队列实现,被窃取任务线程从头部拿任务执行,窃取任务线程从尾部拿任务执行
    • 优点:充分利用线程并行计算,减少线程竞争
    • 缺点:某些情况下存在竞争,消耗更多的系统资源
  • 框架设计
    • ForkJoinTask:创建ForkJoin任务,用于分割一般不需要直接继承它,而是继承它的子类:
      • RecursiveAction:没有返回结果的任务
      • RecursiveTask:有返回结果的任务
    • ForkJoinPool:执行任务并合并结果,ForkJoinTask通过它来执行
  • 使用:
package com.junzerg.threads;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.RecursiveTask;

/**
 * @author pengjunzhe
 */
public class CountTask extends RecursiveTask<Integer> {

    /**
     * 阈值
     */
    private static final int THRESHOLD = 2;
    private int start;
    private int end;

    public CountTask(int start, int end) {
        this.start = start;
        this.end = end;
    }

    @Override
    protected Integer compute() {
        int sum = 0;
        // 如果任务足够小,就直接计算任务
        boolean canComputer = (end - start) < THRESHOLD;
        if (canComputer) {
            for (int i = start; i <= end; i++) {
                sum += i;
            }
        } else {
            //如果任务大于阈值,就分裂成两个子任务来计算
            int middle = (end + start) / 2;
            CountTask leftTask = new CountTask(start, middle);
            CountTask rightTask = new CountTask(middle + 1, end);
            leftTask.fork();
            rightTask.fork();
            // 等待子任务执行完,得到结果
            int leftResult = leftTask.join();
            int rightResult = rightTask.join();
            sum = leftResult + rightResult;
        }
        return sum;
    }

    public static void main(String[] args) throws InterruptedException {
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        CountTask task = new CountTask(1,4);
        Future<Integer> result = forkJoinPool.submit(task);
        try{
            System.out.println(result.get());
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}
  • ForkJoinTask执行可能抛出异常,但是无法再主程序中获取
    • isCompletedAbnormally()方法检查是否已经抛出异常或者被取消了。
    • getException()方法可以获取异常,任务被取消了返回CancellationException,没有完成或者没有抛出异常返回null

相关文章

  • Java并发-23.Fork/Join框架

    什么是Fork/Join框架Fork把一个大任务切分成若干个子任务Join把子任务的执行结果合并 工作窃取算法是什...

  • 简体字、冯|聊聊 fork-join框架

    title: 2018-8-3 聊聊 fork-join框架tags: java,并发,线程池grammar_cj...

  • 9、ForkJoinPool 线程池

    Java 1.7 引入了一种新的并发框架—— Fork/Join Framework它和ExecutorServi...

  • Java并发之JDK并发包(3)

    实战Java高并发程序设计笔记 分而治之:Fork/Join框架 ForkJoinPool线程池,对于fork而言...

  • 并发框架之Fork/Join框架

    今天来介绍一下java并发框架之Fork/Join 初探Fork/Join: 分割任务 使用一个fork类来把大任...

  • 走进Java

    JDK是支持Java程序开发的最小环境;JRE是运行Java程序的标准环境 并发框架:fork-join、Hado...

  • Java并发 - fork/join并发处理框架

    思想:分而治之 用来做什么 ForkJoinPool是ExecutorService接口的实现,它专为可以递归分解...

  • java中的fork join框架

    java 中的fork join框架 fork join框架是java 7中引入框架,这个框架的引入主要是为了提升...

  • Fork & Join

    从Java7开始,Java提供了一个并发式编程框架,Fork & Join。简单来讲,用户可以将一个较大的计算任务...

  • Fork/Join框架

    Fork/Join框架 1. Fork/Join框架简介 Fork/Join框架是java7提供的一个用于并行执行...

网友评论

      本文标题:Java并发-23.Fork/Join框架

      本文链接:https://www.haomeiwen.com/subject/bclvzqtx.html