【JUC系列】Fork/Join框架之概览

顧棟发布时间：2022-06-29 22:30:00 ，浏览量：0

JUC系列Fork/Join框架

文章目录

JUC系列Fork/Join框架
- Fork/Join总览类图
- 主要模块
- - 核心类
- 核心算法：分治算法
- 核心算法：工作窃取法
- 使用示例
- - RecursiveAction使用
  - RecursiveTask使用

Fork/Join框架是Java并发工具包中的一种可以将一个大任务拆分为很多小任务来异步执行的工具，自JDK1.7引入。

Fork/Join总览类图

在这里插入图片描述

主要模块

ForkJoinPool可以通过池中的ForkJoinWorkerThread来处理ForkJoinTask任务。

ForkJoinPool只接收ForkJoinTask任务(在实际使用中，也可以接收Runnable/Callable任务，但在真正运行时，也会把这些任务封装成ForkJoinTask类型的任务)，RecursiveTask是ForkJoinTask的子类，是一个可以递归执行的ForkJoinTask，RecursiveAction是一个无返回值的RecursiveTask，CountedCompleter 在任务完成执行后会触发执行一个自定义的钩子函数。

在实际运用中，我们一般都会继承 RecursiveTask 、RecursiveAction 或 CountedCompleter 来实现我们的业务需求，而不会直接继承ForkJoinTask类。

核心类

任务对象：

ForkJoinTask

任务管理的线程池

ForkJoinPool

执行任务的线程

ForkJoinWorkerThread

核心算法：分治算法

#mermaid-svg-jfCTnePxyRVXf0OX {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .error-icon{fill:#552222;}#mermaid-svg-jfCTnePxyRVXf0OX .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-jfCTnePxyRVXf0OX .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-jfCTnePxyRVXf0OX .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-jfCTnePxyRVXf0OX .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-jfCTnePxyRVXf0OX .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-jfCTnePxyRVXf0OX .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-jfCTnePxyRVXf0OX .marker{fill:#333333;stroke:#333333;}#mermaid-svg-jfCTnePxyRVXf0OX .marker.cross{stroke:#333333;}#mermaid-svg-jfCTnePxyRVXf0OX svg{font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-jfCTnePxyRVXf0OX .label{font-family:"trebuchet ms",verdana,arial,sans-serif;color:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .cluster-label text{fill:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .cluster-label span{color:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .label text,#mermaid-svg-jfCTnePxyRVXf0OX span{fill:#333;color:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .node rect,#mermaid-svg-jfCTnePxyRVXf0OX .node circle,#mermaid-svg-jfCTnePxyRVXf0OX .node ellipse,#mermaid-svg-jfCTnePxyRVXf0OX .node polygon,#mermaid-svg-jfCTnePxyRVXf0OX .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-jfCTnePxyRVXf0OX .node .label{text-align:center;}#mermaid-svg-jfCTnePxyRVXf0OX .node.clickable{cursor:pointer;}#mermaid-svg-jfCTnePxyRVXf0OX .arrowheadPath{fill:#333333;}#mermaid-svg-jfCTnePxyRVXf0OX .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-jfCTnePxyRVXf0OX .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-jfCTnePxyRVXf0OX .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-jfCTnePxyRVXf0OX .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-jfCTnePxyRVXf0OX .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-jfCTnePxyRVXf0OX .cluster text{fill:#333;}#mermaid-svg-jfCTnePxyRVXf0OX .cluster span{color:#333;}#mermaid-svg-jfCTnePxyRVXf0OX div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-jfCTnePxyRVXf0OX :root{--mermaid-font-family:"trebuchet ms",verdana,arial,sans-serif;}

1.fork

2.fork

3.join

4.join

mainTaskA

TaskB

TaskC

TaskB-1

TaskB-2

TaskC-1

TaskC-2

核心算法：工作窃取法

work-stealing(工作窃取)算法: 线程池内的所有工作线程都尝试找到并执行已经提交的任务，或者是被其他活动任务创建的子任务(如果不存在就阻塞等待)。这种特性使得 ForkJoinPool 在运行多个可以产生子任务的任务，或者是提交的许多小任务时效率更高。尤其是构建异步模型的 ForkJoinPool 时，对不需要合并(join)的事件类型任务也非常适用。

在 ForkJoinPool 中，线程池中每个工作线程(ForkJoinWorkerThread)都对应一个任务队列(WorkQueue)，工作线程优先处理来自自身队列的任务(LIFO或FIFO顺序，参数 mode 决定)，然后以FIFO的顺序随机窃取其他队列中的任务。

使用示例 RecursiveAction使用

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;

public class SortTask extends RecursiveAction {
    final long[] array;
    final int low;
    final int high;
    private int THRESHOLD = 0;

    public SortTask(long[] array) {
        this.array = array;
        this.low = 0;
        this.high = array.length - 1;
    }

    public SortTask(long[] array, int low, int high) {
        this.array = array;
        this.low = low;
        this.high = high;
    }

    @Override
    protected void compute() {
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss.SSS").format(new Date()) + "--" + Thread.currentThread().getName() + "] task is [low=" + low + ", high=" + high + "].");

        if (low

关注

打赏

1663402667

查看更多评论

【JUC系列】Fork/Join框架之概览

最近更新

热门博客

[ 申请 ]友情链接：