Java 高级应用-多线程-(四)FutureTask的介绍及使用

这篇具有很好参考价值的文章主要介绍了Java 高级应用-多线程-(四)FutureTask的介绍及使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Java多线程之FutureTask的介绍及使用

FutureTask属于java.util.concurrent 包;FutureTask表示可取消的异步计算。FutureTask类提供了一个Future的基本实现 ,具有启动和取消计算的方法,查询计算是否完整,并检索计算结果。结果只能在计算完成后才能检索; 如果计算尚未完成,则get方法将阻止。 一旦计算完成,则无法重新启动或取消计算(除非使用runAndReset()调用计算 )

Java 高级应用-多线程-(四)FutureTask的介绍及使用
从上面的FutureTask类图中可以看出,FutureTask实现了RunnableFuture接口,RunnableFuture接口继承了Runnable接口和Future接口,所以FutureTask兼备Runnable和Future两种特性

Java 高级应用-多线程-(四)FutureTask的介绍及使用

1、构造方法

public FutureTask(Callable callable) 创建一个 FutureTask ,它将在运行时执行给定的 Callable 。 参数: callable表示可调用任务 。
public FutureTask(Runnable runnable,V result) 创建一个 FutureTask ,将在运行时执行给定的 Runnable ,并安排 get将在成功完成后返回给定的结果。 参数:runnable 表示可运行的任务 ;result 表示成功完成后返回的结果。
2、常用的方法

public boolean isCancelled() 如果此任务在正常完成之前取消,则返回 true 。
public boolean isDone() 返回true如果任务已完成。
public V get() 等待计算完成,然后检索其结果。
public V get(long timeout, TimeUnit unit)如果需要等待最多在给定的时间计算完成,然后检索其结果(如果可用)。
public boolean cancel(boolean mayInterruptIfRunning)尝试取消执行此任务。
protected void set(V v)将此未来的结果设置为给定值,除非此未来已被设置或已被取消。

案例
通过示例进行多任务计算,通过get()方法可以异步获取执行结果。

1、创建一个计算任务类,实现Callable接口,重写call方法

package com.hz.thread.FutureTask;

import java.util.concurrent.Callable;

// 创建一个计算任务类,实现Callable接口,重写call方法
 
public class ComputeTask implements Callable<Integer> {

    private String taskName;//任务名称

    //任务构造器
    public ComputeTask(String taskName) {
        this.taskName = taskName;
        System.out.println("创建【计算任务】开始,计算任务名称:" + taskName);
    }

    //计算任务的方法
    @Override
    public Integer call() throws Exception {
        Integer result = 0;
        for (int i = 1; i <=50; i++) {
            result = +i;
        }
        System.out.println("【计算任务】"+taskName +"执行完成。");
        return result;
    }
}

2、创建一个测试类

package com.hz.thread.FutureTask;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

public class Demo {
    public static void main(String[] args) {
        //任务集合
        List<FutureTask<Integer>> futureTasks  = new ArrayList<>();
        //创建固定长度的线程池
        ExecutorService pool = Executors.newFixedThreadPool(5);
        for (int i = 1; i <= 10; i++) {
            //实例化FutureTask,传入计算任务类
            FutureTask<Integer> futureTask = new FutureTask<>(new ComputeTask(i + ""));
            //添加到任务集合中
            futureTasks.add(futureTask);
            //提交任务到线程池
            pool.submit(futureTask);
        }
        System.out.println("所有【计算任务】提交完毕,主线程开始执行");

        System.out.println("【主线程任务】开始============");
        //主线程睡眠5秒,模拟主线程做某些任务
        try {
            Thread.sleep(5000);
            System.out.println("【主线程任务】开始执行某些任务============");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("【主线程任务】结束============");

        //用于打印任务执行结果
        Integer result = 0;
        for (FutureTask<Integer> task : futureTasks) {
            try {
                //FutureTask的get()方法会自动阻塞,知道得到任务执行结果为止
                result += task.get();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
        //关闭线程池
        pool.shutdown();
        System.out.println("多线程多任务执行结果:" + result);

    }

}

3、输出结果如下:

创建【计算任务】开始,计算任务名称:1
创建【计算任务】开始,计算任务名称:2
创建【计算任务】开始,计算任务名称:3
创建【计算任务】开始,计算任务名称:4
创建【计算任务】开始,计算任务名称:5
创建【计算任务】开始,计算任务名称:6
创建【计算任务】开始,计算任务名称:7
创建【计算任务】开始,计算任务名称:8
创建【计算任务】开始,计算任务名称:9
创建【计算任务】开始,计算任务名称:10
所有【计算任务】提交完毕,主线程开始执行
【主线程任务】开始============
【计算任务】1执行完成。
【计算任务】2执行完成。
【计算任务】6执行完成。
【计算任务】7执行完成。
【计算任务】9执行完成。
【计算任务】10执行完成。
【计算任务】8执行完成。
【计算任务】4执行完成。
【计算任务】3执行完成。
【计算任务】5执行完成。
【主线程任务】开始执行某些任务============
【主线程任务】结束============
多线程多任务执行结果:500

4、结论
Java 高级应用-多线程-(四)FutureTask的介绍及使用

通过FutureTask类的get()方法可用于异步获取执行结果,无论FutureTask调用多少次run()或者call()方法,它都能确保只执行一次Runable或Callable任务。文章来源地址https://www.toymoban.com/news/detail-464802.html

到了这里,关于Java 高级应用-多线程-(四)FutureTask的介绍及使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • CountDownLatch介绍和使用【Java多线程必备】

    点击   Mr.绵羊的知识星球  解锁更多优质文章。 目录 一、介绍 二、特性 三、实现原理 四、适用场景 五、注意事项 六、实际应用     CountDownLatch 是 Java 中的一个并发工具类,用于协调多个线程之间的同步。其作用是让某一个线程等待多个线程的操作完成之后再执行。它可

    2024年02月05日
    浏览(53)
  • Java中线程池的使用及原理(附带线程池拒绝策略介绍)

    目录 1.使用线程池的目的 2.线程池的使用及原理 3.生动讲解拒绝策略: 4.自己实现一个简单的线程池 5.线程数的决定方法 6.总结 希望各位大佬能多多点赞关注收藏,有了你们的支持,我也能更有动力的向你们学习不是(手动狗头)!!! 在知道线程池之前,每当我们需要一

    2024年04月17日
    浏览(37)
  • Net 高级调试之七:线程操作相关命令介绍

    一、简介 今天是《Net 高级调试》的第七篇文章。上一篇文章我们说了值类型,引用类型,数组等的内存表现形式。有了这个基础,我们可以更好的了解我们的程序在运行时的状态,内存里有什么东西,它们的结构组成是什么样子的,对我们调试程序是更有帮助的。今天,我

    2024年02月05日
    浏览(53)
  • 【Java中的Thread线程的简单方法介绍和使用详细分析】

    提示:若对Thread没有基本的了解,可以先阅读以下文章,同时部分的方法已经在如下两篇文章中介绍过了,本文不再重复介绍!! 【Java中Tread和Runnable创建新的线程的使用方法】 【Java中的Thread线程的七种属性的使用和分析】 提示:以下是本篇文章正文内容,下面案例可供参

    2024年02月15日
    浏览(42)
  • 高级Java多线程面试题及回答

        高级Java多线程面试题及回答   1)现在有T1、T2、T3三个线程,你怎样保证T2在T1执行完后执行,T3在T2执行完后执行?   这个线程问题通常会在第一轮或电话面试阶段被问到,目的是检测你对”join”方法是否熟悉。这个多线程问题比较简单,可以用join方法实现。   2)在J

    2024年02月06日
    浏览(39)
  • Nmap详细介绍高级应用

    nmap的定义 nmap的定义: nmap是一款开源的网络探测和安全审核工具,可以用来扫描网络主机,确定哪些主机在运行、运行哪些服务以及运行哪个操作系统等信息。它可以通过各种方式对目标主机进行探测,如TCP SYN扫描、UDP扫描、TCP connect() 扫描、FTP bounce攻击扫描等。同时,

    2023年04月10日
    浏览(38)
  • Java并发编程:Callable、Future和FutureTask

    在前面的文章中我们讲述了创建线程的 2 种方式,一种是直接继承 Thread ,另外一种就是实现 Runnable 接口。 这 2 种方式都有一个缺陷就是:在执行完任务之后无法获取执行结果。 如果需要获取执行结果,就必须通过共享变量或者使用线程通信的方式来达到效果,这样使用起

    2024年02月13日
    浏览(38)
  • 【并发编程】Java的Future机制详解(Future接口和FutureTask类)

    目录 一、彻底理解Java的Future模式 二、为什么出现Future机制 2.1 Future 类有什么用? 三、Future的相关类图 2.1 Future 接口 2.2 FutureTask 类 五、FutureTask源码分析 5.1 state字段 5.2 其他变量 5.3 CAS工具初始化 5.4 构造函数 5.5 jdk1.8和之前版本的区别 六、Callable 和 Future 有什么关系? 七、

    2024年02月03日
    浏览(39)
  • Java线程池基础介绍

    1、线程池能够复用已经创建了的线程来执行任务,从而降低了频繁创建和销毁线程所带来的资源消耗; 2、任务创建完成时,不必等待线程的创建,能够立即执行,提高了任务响应的速度。   线程池中长期存活的线程数量。一般情况下,当线程处于空闲状态时也不会被销毁。

    2024年02月11日
    浏览(38)
  • Net 高级调试之二:CLR和Windows加载器及应用程序域介绍

    一、简介 今天是 Net 高级调试的第二篇文章,第一篇文章记录了自己学习 Net 高级调试的第一步,认识一些调试工具,有了工具的倚仗,我们开始仗剑走天涯了,开始Net 高级调试正式的征程了。我先说一下,我的文章,【调试测试】这部分一般分为两个部分,第一部分是要用

    2024年02月08日
    浏览(44)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包