FutureTask-详解(二)-ThreadPollExecutor-并发编程(Java)

news2025/7/12 7:32:14

文章目录

    • 1 FutureTask
      • 1.1 简介
      • 1.2 成员变量
      • 1.3 构造方法
      • 1.4 主要执行流程分析
        • 1.4.1 run任务执行
          • 1.4.1.1 run方法
          • 1.4.1.2 set(result)方法
          • 1.4.1.3 setException(ex)方法
          • 1.4.1.4 finishCompletion()方法
        • 1.4.2 get() 执行流程
          • 1.4.2.1 get()方法
          • 1.4.2.2 awaitDone()方法
          • 1.4.2.3 removeWaiter()方法
          • 1.4.2.4 report()方法
    • 2 submit
    • 3 invokeAll()和invokeAny()
    • 4 Executors

1 FutureTask

1.1 简介

public class FutureTask<V> implements RunnableFuture<V> 
public interface RunnableFuture<V> extends Runnable, Future<V>

从继承关系不难看出，该类用于任务执行后的结果获取，任务可以是同步的也可以是异步，主要用于异步获取，调用线程不必阻塞等待任务执行结果，从而提高系统的吞吐量。

1.2 成员变量

private volatile int state;
private static final int NEW          = 0;
private static final int COMPLETING   = 1;
private static final int NORMAL       = 2;
private static final int EXCEPTIONAL  = 3;
private static final int CANCELLED    = 4;
private static final int INTERRUPTING = 5;
private static final int INTERRUPTED  = 6;

private Callable<V> callable;
private Object outcome; 
private volatile Thread runner;
private volatile WaitNode waiters;
  • state：状态
  • NEW~INTERRUPTED：为状态取值
    • NEW=0：新建
    • COMPLETING：正在停止
      • 停止之前还要做一些善后工作
    • NORMAL：正常执行任务得到结果
    • EXCEPTIONAL：产生异常
    • CANCELLED：任务已取消
    • INTERRUNPTING：正在打断
      • 打断之前还要做一些善后工作
    • INTERRUPTED：以打断
  • callable：任务
  • outcome：任务执行的结果
  • runner：当前线程
  • waiters：等待执行结果的线程单链表集合

1.3 构造方法

public FutureTask(Callable<V> callable) {
    if (callable == null)
        throw new NullPointerException();
    this.callable = callable;
    this.state = NEW;       // ensure visibility of callable
}

public FutureTask(Runnable runnable, V result) {
    this.callable = Executors.callable(runnable, result);
    this.state = NEW;       // ensure visibility of callable
}

我们知道Callable有返回值，而Runnable线程执行并没有返回值，那么它是怎么将执行结果返回的呢？这里看下Executors.callable(runnable, result)是怎么处理的。

public static <T> Callable<T> callable(Runnable task, T result) {
    if (task == null)
        throw new NullPointerException();
    return new RunnableAdapter<T>(task, result);
}

static final class RunnableAdapter<T> implements Callable<T> {
    final Runnable task;
    final T result;
    RunnableAdapter(Runnable task, T result) {
        this.task = task;
        this.result = result;
    }
    public T call() {
        task.run();
        return result;
    }
}

这样子看来，它的执行结果是我们自己传进去的？是地，如果想要任务自己的执行结果调用Callable线程就好了。

1.4 主要执行流程分析

这里我们主要分析:

  • run()：任务执行
  • get(),get(long timout, Timeunit unit)：结果获取
  • cancel(boolean mayInterruptIfRunning)：取消任务执行

这几个方法，其他自行查看相关文档或者源码。

1.4.1 run任务执行

1.4.1.1 run方法

先上源码：

public void run() {
    if (state != NEW ||
        !UNSAFE.compareAndSwapObject(this, runnerOffset,
                                     null, Thread.currentThread()))
        return;
    try {
        Callable<V> c = callable;
        if (c != null && state == NEW) {
            V result;
            boolean ran;
            try {
                result = c.call();
                ran = true;
            } catch (Throwable ex) {
                result = null;
                ran = false;
                setException(ex);
            }
            if (ran)
                set(result);
        }
    } finally {
        // runner must be non-null until state is settled to
        // prevent concurrent calls to run()
        runner = null;
        // state must be re-read after nulling runner to prevent
        // leaked interrupts
        int s = state;
        if (s >= INTERRUPTING)
            handlePossibleCancellationInterrupt(s);
    }
}

执行流程分4部分：

  • 前期检测
  • 正常执行
  • 执行异常
  • 最终处理

执行流程图如下图1.4.1所示：[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传在这里插入图片描述

1.4.1.2 set(result)方法

任务正常执行，返回结果后，会执行set()方法把任务赋值给outcome,上源码：

protected void set(V v) {
    if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
        outcome = v;
        UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
        finishCompletion();
    }
}
  • 执行流程
    • cas操作尝试吧状态由NEW更换为COMPETING
      • 把结果赋值给outcome
      • case操作把state状态设置为NORMAL
      • 执行完成操作finishCompletion()
1.4.1.3 setException(ex)方法

如果在run执行任务的过程中产生异常，catch捕获异常后，会执行该方法，源码如下：

protected void setException(Throwable t) {
    if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
        outcome = t;
        UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state
        finishCompletion();
    }
}

执行流程

  • cas操作尝试吧状态由NEW更换为COMPETING
    • 把异常对象赋值给outcome
    • case操作把state状态设置为EXCEPTIONAL
    • 执行完成操作finishCompletion()
1.4.1.4 finishCompletion()方法

不管是正常执行后set()方法还是异常执行setException()方法，方法内部都会执行该方法，源码如下：

private void finishCompletion() {
    // assert state > COMPLETING;
    for (WaitNode q; (q = waiters) != null;) {
        if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) {
            for (;;) {
                Thread t = q.thread;
                if (t != null) {
                    q.thread = null;
                    LockSupport.unpark(t);
                }
                WaitNode next = q.next;
                if (next == null)
                    break;
                q.next = null; // unlink to help gc
                q = next;
            }
            break;
        }
    }

    done();

    callable = null;        // to reduce footprint
}

该方法主要任务就是清理waitNode上等待的线程，具体过程如下：

  • 双层循环的目的就是防止等待线程出现空和不空混杂的情况
  • cas尝试吧waiters置为空
    • 因为waiters是单链表结构，通过for内循环清理
    • 获取q.thread赋值给线程变量t
    • 如果t不为空
      • t值为空，同时unpark()唤醒线程，之前调用的park()阻塞
    • 继续获取后继节点，为空中断循环
  • done()方法当前类为空，啥也没干，根据应用场景可由子类继承覆盖
  • callable置空

1.4.2 get() 执行流程

1.4.2.1 get()方法

源码如下：

public V get() throws InterruptedException, ExecutionException {
    int s = state;
    if (s <= COMPLETING)
        s = awaitDone(false, 0L);
    return report(s);
}
  • 执行步骤
    • 判断状态<=COMPLETING
      • 等等执行结束awaitDone(false,0L)：无时限等等
    • 然后结果,report(s)
1.4.2.2 awaitDone()方法

源码如下：

private int awaitDone(boolean timed, long nanos)
    throws InterruptedException {
    final long deadline = timed ? System.nanoTime() + nanos : 0L;
    WaitNode q = null;
    boolean queued = false;
    for (;;) {
        if (Thread.interrupted()) {
            removeWaiter(q);
            throw new InterruptedException();
        }

        int s = state;
        if (s > COMPLETING) {
            if (q != null)
                q.thread = null;
            return s;
        }
        else if (s == COMPLETING) // cannot time out yet
            Thread.yield();
        else if (q == null)
            q = new WaitNode();
        else if (!queued)
            queued = UNSAFE.compareAndSwapObject(this, waitersOffset,
                                                 q.next = waiters, q);
        else if (timed) {
            nanos = deadline - System.nanoTime();
            if (nanos <= 0L) {
                removeWaiter(q);
                return state;
            }
            LockSupport.parkNanos(this, nanos);
        }
        else
            LockSupport.park(this);
    }
}

执行流程图如下：在这里插入图片描述

主要职责就是等待任务执行完毕，且设置结果；否则就阻塞等待。如果中间被中断或取消执行，也会结束。

1.4.2.3 removeWaiter()方法

源码如下：

private void removeWaiter(WaitNode node) {
    if (node != null) {
        node.thread = null;
        retry:
        for (;;) {          // restart on removeWaiter race
            for (WaitNode pred = null, q = waiters, s; q != null; q = s) {
                s = q.next;
                if (q.thread != null)
                    pred = q;
                else if (pred != null) {
                    pred.next = s;
                    if (pred.thread == null) // check for race
                        continue retry;
                }
                else if (!UNSAFE.compareAndSwapObject(this, waitersOffset,
                                                      q, s))
                    continue retry;
            }
            break;
        }
    }
}

主要任务就是如果参数给定的等待节点不为空，把给定节点 thread赋值null。然后移除阻塞等待队列中等待节点thread为空的节点。

1.4.2.4 report()方法

源码如下：

private V report(int s) throws ExecutionException {
    Object x = outcome;
    if (s == NORMAL)
        return (V)x;
    if (s >= CANCELLED)
        throw new CancellationException();
    throw new ExecutionException((Throwable)x);
}

方法用于返回执行结果：

  • 正常执行任务，设置结果后state状态为NORMAL，此时返回结果outcome
  • 如果此时状态>=CANCELLED，此时任务被取消，抛出取消任务异常
  • 其他状态抛出执行异常。

2 submit

线程池执行任务，处理直接执行execute()方法，如果任务为异常且需要返回值，可以调用submit方法，源码如下：

public <T> Future<T> submit(Callable<T> task) {
    if (task == null) throw new NullPointerException();
    RunnableFuture<T> ftask = newTaskFor(task);
    execute(ftask);
    return ftask;
}

execute()和submit()执行任务主要区别就是前者不需要返回值而后者有返回值。

3 invokeAll()和invokeAny()

前面讲解的主要是执行单个任务的情况，如果需要批量执行任务，这可以调用invokeAll()或者invokeAny()方法。

  • invokeAll()：等待全部任务执行完毕，返回全部执行结果，如果产生异常，把任务取消
  • invokeAny()：任意一任务执行完毕，返回该任务执行结果，其余任务取消

invokeAll()和invokeAny()执行流程相对简单，这里不在详述。

4 Executors

在构建线程池对象的时候，建议使用该类。该类通过静态方法返回多种线程池对象，常用三种线程池简单使用可参考之前写的文章详解-ThreadPollExecutor-并发编程(Java)或者自行查阅相关文档。其他的线程池类型，等以后用到的时候在讲解。

我们来看下其中一种线程池的构建，源代码如下：

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

它是直接new ThreadPoolExecutor的对象，那么我们为什么不直接自己new一个，还要在包装一下呢？这里用到了一种设计模式，具体的等后面我们学习设计模式的时候在讲解。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/17939.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

C++获取计算机硬件信息（Linux）

C++获取计算机硬件信息（Linux）

C获取计算机硬件信息&#xff08;Windows&#xff09; https://blog.csdn.net/hhy321/article/details/121258036 C获取计算机硬件信息&#xff08;Linux&#xff09; https://blog.csdn.net/hhy321/article/details/127930470 “春赏百花秋望月&#xff0c;夏有凉风冬观雪。若…
阅读更多...
InnoDB之Undo log写入和恢复

InnoDB之Undo log写入和恢复

1. 前言 为了实现事务的回滚和MVCC&#xff0c;InnoDB设计了Undo log模块&#xff0c;简单来说就是在修改记录前先记下日志&#xff0c;以便之后能将记录恢复成修改前的样子。针对insert、delete、update这三种不同的操作&#xff0c;InnoDB设计了不同类型的undo log&#xff…
阅读更多...
Redis 常见问题

Redis 常见问题

一、 什么是Redis&#xff1f; Redis 是一个使用 C 语言写成的&#xff0c;开源的高性能key-value非关系缓存数据库&#xff1b;Redis的数据都基于缓存的&#xff0c;所以很快&#xff0c;每秒可以处理超过 10万次读写操作&#xff1b;Redis也可以实现数据写入磁盘中&#xff…
阅读更多...
Spring源码里开天辟地的五个Bean，再介绍一个学习方法

Spring源码里开天辟地的五个Bean，再介绍一个学习方法

准备工作 首先咱们还是来写一个最简单的例子&#xff1a; 用的还是 https://github.com/xiexiaojing/yuna 里的代码&#xff0c;只是标签和引用都换成了Spring原生的。 配置类就是配置了扫描路径&#xff1a; 在可以被扫描的包路径下定义了一个Bean对象。用了Component注解这…
阅读更多...
Java#16(包装类和集合练习)

Java#16(包装类和集合练习)

目录 基本数据类型对应的包装类: 一.添加学生对象并遍历 二.添加用户对象并判断是否存在 三.添加手机对象并返回要求的数据 基本数据类型对应的包装类: byte------>Byte short------->Short char------->Character int------->Integer long------->Long flo…
阅读更多...
MRT(MODIS Reprojection Tool) 下载及安装教程

MRT(MODIS Reprojection Tool) 下载及安装教程

大家下载MODIS数据的时候&#xff0c;大多是hdf的格式数据。HDF数据包括11个波段的数据&#xff08;如下图&#xff09;&#xff0c;假如想要其中一个波段数据&#xff0c;我们需要批量提取&#xff0c;这时就要用到NASA提供的MODIS Reprojection Tool&#xff0c;此工具虽不能…
阅读更多...
c++ 指针，new运算符

c++ 指针，new运算符

1、指针相关基础知识&#xff1a; 1.1、指针一般指向变量的地址&#xff0c;等同于变量名前加&&#xff0c;如下&#xff1a; int a 3; int* p; p &a; 1.2、 * 符号被称为间接值运算符或解除引用运算符&#xff0c;将其运用于指针&#xff0c;可以获取指针指向的值…
阅读更多...
【Java八股文总结】之IO流

【Java八股文总结】之IO流

文章目录Java IO流一、IO基础知识1、字节流2、字符流3、字节缓冲流4、打印流5、随机访问流6、字节流和字符流的区别&#xff1f;二、IO设计模式1、装饰器模式2、适配器模式Q&#xff1a;适配器模式和装饰器模式的区别&#xff1f;3、工厂模式4、观察者模式三、IO模型详解&#…
阅读更多...
柯桥留学日语培训机构有吗日本人平时都喝什么酒？

柯桥留学日语培训机构有吗日本人平时都喝什么酒？

日本葡萄酒侍酒大师高野丰先生&#xff0c;带来一瓶在北海道发现的陈年白兰地。 那是2014年的事&#xff0c;高野先生去北海道十胜地区的一家葡萄酒厂考察&#xff0c;在一个多年未开启的葡萄酒储存库的角落里&#xff0c;发现了一只陈旧的酒桶&#xff0c;他很好奇地问酒厂的…
阅读更多...
Javaweb filter过滤器 跟 listener监听器

Javaweb filter过滤器 跟 listener监听器

Filter 权限控制&#xff1a;登录才能进数据库等 统一编码&#xff1a;统一各种编码 Filter快速入门 放行前&#xff0c;我们对request里的数据进行处理 处理完&#xff0c;然后放行&#xff0c;携带到对应的资源里去 放行后&#xff0c;对response的数据进行处理 //将re…
阅读更多...
C/C++问题：一个指针的大小是多少？怎么理解指针变量的存在

C/C++问题：一个指针的大小是多少？怎么理解指针变量的存在

目录 举例 一、 int a; int (*(*v)[])(); 二、 int func(); int (*func)(); 三、 const; int const a; const int a; int const*r; int *const r; 四、一个指针的大小是多少&#xff1f;&#xff08;补充&#xff09; 举例 一、 int a; 可以看到上面声明了一个变…
阅读更多...
【MySQL基础】SQL语言的概述、组成及特点

【MySQL基础】SQL语言的概述、组成及特点

目录 一、SQL的概述 二、SQL语言的组成 三、SQL语言的特点 语法特点&#xff1a; &#x1f49f; 创作不易&#xff0c;不妨点赞&#x1f49a;评论❤️收藏&#x1f499;一下 一、SQL的概述 SQL全称&#xff1a; Structured Query Language&#xff0c;是结构化查询语言&am…
阅读更多...
数据结构先序序列创建二叉树

数据结构先序序列创建二叉树

2022.11.19连发两回。 先序序列创建二叉树任务描述相关知识编程要求测试说明C/C代码任务描述 本关任务&#xff1a;利用先序遍历创建二叉树&#xff0c;并给出相应二叉树的中序遍历结果。 相关知识 为了完成本关任务&#xff0c;你需要掌握&#xff1a;1.二叉树的前序遍历&a…
阅读更多...
win11系统下，迅雷启动后闪退的问题

win11系统下，迅雷启动后闪退的问题

win11系统&#xff0c;迅雷最新版本。 之前用迅雷一直好好的&#xff0c;某天要下东西突然发现点击就闪退&#xff0c;进程管理器里一点痕迹都没有。 启动就闪退&#xff0c;没有一点点痕迹。 因为之前是win10系统&#xff0c;一直用的好好的&#xff0c;考虑是不是win11系统…
阅读更多...
创建自己数据集全套流程

创建自己数据集全套流程

目录 1、准备自己具有的数据集 2、标注数据----json格式 3、标注数据转为分割图----voc格式 4、增广数据集 5、分训练集以及验证集 1、准备自己具有的数据集 注意&#xff1a;数据集必须是统一的后缀格式&#xff0c;jpg或者png 2、标注数据----json格式 采用labelme标注…
阅读更多...
前后端分离项目（vue+springboot）集成pageoffice实现在线编辑office文件

前后端分离项目（vue+springboot）集成pageoffice实现在线编辑office文件

前后端分离项目下使用PageOffice原理图 集成步骤 前端 vue 项目 在您Vue项目的根目录下index.html中引用后端项目根目录下pageoffice.js文件。例如&#xff1a; <script type"text/javascript" src"http://localhost:8081/samples-springboot-back/pageof…
阅读更多...
gom传奇引擎无限蜂功能插件安装图文教程

gom传奇引擎无限蜂功能插件安装图文教程

无限蜂功能插件安装教程 1. 百度搜索无限蜂官网,下载功能插件程序&#xff0c;请下载最新版&#xff01;2. 下载无限蜂功能插件&#xff0c;到桌面&#xff0c;并进行解压&#xff0c;如下图所示。 3. 打开无限蜂功能插件控制台(?.?.?)&#xff0c;进行账号注册。 4. 注册成…
阅读更多...
InnoDB之Undo log格式

InnoDB之Undo log格式

1. 前言 InnoDB有两大日志模块&#xff0c;分别是redo log和undo log。为了避免磁盘随机写&#xff0c;InnoDB设计了redo log&#xff0c;数据写入时只写缓冲页和redo log&#xff0c;脏页由后台线程异步刷盘&#xff0c;哪怕系统崩溃也能根据redo log恢复数据。但是我们漏了一…
阅读更多...
STC51单片机32——液晶1602显示

STC51单片机32——液晶1602显示

//用LCD循环右移显示字符 //开发板上的跳帽连接Vcc #include<reg51.h> //包含单片机寄存器的头文件 #include<intrins.h> //包含_nop_()函数定义的头文件 sbit EP2^7; //使能信号位&#xff0c;将E位定义为P2.7引脚 sbit RSP2^6; //寄存器选择位&#…
阅读更多...
Js逆向教程-09常见的加密方式

Js逆向教程-09常见的加密方式

作者&#xff1a;虚坏叔叔 博客&#xff1a;https://xuhss.com 早餐店不会开到晚上&#xff0c;想吃的人早就来了&#xff01;&#x1f604; Js逆向教程-09常见的加密方式 常见的加密方式 一、js逆向流程 抓包调试扣去js改写本地运行 二、常见的加密方式 2.1取盐校验 不可…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023