【Android 异步操作】FutureTask 分析 ( Future 接口解析 | Runnable 接口解析 | Callable 接口解析 )

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
全局流量管理 GTM,标准版 1个月
云解析 DNS,旗舰版 1个月
简介: 【Android 异步操作】FutureTask 分析 ( Future 接口解析 | Runnable 接口解析 | Callable 接口解析 )

文章目录

一、Future 接口

1、Future 接口简介

2、取消任务方法

3、Future 接口源码注释

二、Callable 接口

三、Runnable 接口



上一篇博客 【Android 异步操作】AsyncTask 异步任务 ( FutureTask 模拟 AsyncTask 执行过程 | AsyncTask 执行过程回顾 | FutureTask 分析 ) 中 , 使用 FutureTask 模拟 AsyncTask 执行 , 简单介绍了 FutureTask<V> 类 , 和 RunnableFuture<V> 接口 ;


本篇博客将分析 Future 接口 , 和 Runnable 接口 , 以及 FutureTask 的运行机制 ;



相关参考文档 :


FutureTask

RunnableFuture

Future

Runnable

Callable

FutureTask 实现了 RunnableFuture 接口 , RunnableFuture 接口实现了 Future 接口和 Runnable 接口 , FutureTask 创建时传入 Callable 对象 , 该对象的 call() 方法就是在子线程执行的异步方法 ;






一、Future 接口




1、Future 接口简介


Future 作用 : Future 是 异步计算结果 ;



提供了以下方法 :


检查计算是否完成

检查计算是否取消

等待计算完成 , 获取计算结果

取消任务


获取结果有如下两个条件 :


调用 get() 方法获取计算结果

计算必须执行完成 , 否则会阻塞直到计算完成 , 才能解除阻塞

调用 get() 方法获取计算结果 , 如果计算没有完成 , 该方法会阻塞 , 直到计算完成之后 , 阻塞才会解除 , 同时返回执行结果 ;



取消任务执行 : 调用 cancel() 方法 , 可以取消异步任务的执行 ; 如果计算完毕 , 该任务无法被取消 ;


使用 Future 的可取消性 : 如果想要 使用 Future 的可取消的特性 , 不提供可用结果 , 可以将类型声明为 Future<?> , 并返回 null 作为基础任务的结果 ;




2、取消任务方法


boolean cancel(boolean mayInterruptIfRunning) 方法 : 尝试取消任务的执行 ;



① 取消失败 : 如果任务已经完成 , 或 已经被取消 , 或 因为其它原因 不能被取消 , 该尝试可能会失败 ;


② 取消成功 : 如果取消成功 , 并且该任务在取消时还没有开始执行 , 该任务之后也不会被执行 ;


③ boolean mayInterruptIfRunning 参数 : 如果任务已经开始执行 , mayInterruptIfRunning 参数确定 , 在尝试终止任务时 , 该执行任务的线程 , 是否应该被中断 ;


④ 方法返回值 : 该方法返回时有以下行为 ;


在这之后如果调用 isDone() 方法 , 会返回 true , 说明该任务已经执行完成 ;

在这之后如果调用 isCancelled() 方法 , 会返回 true , 表明该任务已经被取消 ;



3、Future 接口源码注释


package java.util.concurrent;
/**
 * Future 是异步计算结果 ; 
 * 提供了以下方法 : 检查计算是否完成 , 检查计算是否取消 , 获取计算结果 , 取消任务 ; 
 * 
 * 获取结果有如下两个条件 : 调用 get() 方法获取计算结果 , 
 * 计算必须执行完成 , 否则会阻塞直到计算完成 , 才能解除阻塞 ; 
 * 
 * 取消任务执行 : 调用 cancel() 方法 , 可以取消异步任务的执行 ; 如果计算完毕 , 该任务无法被取消 ; 
 * 使用 Future 的可取消性 : 如果想要使用 Future 的可取消的特性 , 不提供可用结果 , 
 * 可以将类型声明为 Future<?> , 并返回 null 作为基础任务的结果 ;
 */
public interface Future<V> {
    /**
     * 尝试取消任务的执行 ; 
     * 如果任务已经完成 , 或已经被取消 , 或因为其它原因不能被取消 , 该尝试可能会失败 ;
     * 如果取消成功 , 并且该任务在取消时还没有开始执行 , 该任务之后也不会被执行 ;
     * 如果任务已经开始执行 , mayInterruptIfRunning 参数确定 , 在尝试终止任务时 , 
     * 该执行任务的线程 , 是否应该被中断 ; 
     * 该方法返回时 
     *  - 在这之后如果调用 isDone() 方法 , 会返回 true , 说明该任务已经执行完成 ; 
     *  - 在这之后如果调用 isCancelled() 方法 , 会返回 true , 表明该任务已经被取消 ; 
     *
     * @param mayInterruptIfRunning 
     *    true 执行该任务的线程应该被中断 ; 
     *    false 执行中的线程应该被执行完成 ; 
     * 
     * @return 任务无法取消时会返回 false , 一般是任务已经执行完成 ; 
     *      成功取消任务 , 返回 true ; 
     */
    boolean cancel(boolean mayInterruptIfRunning);
    /**
     * 如果任务在正常完成前被取消 , 就返回 true ;
     */
    boolean isCancelled();
    /**
     * 如果任务执行完毕 , 返回 true ;
     * 影响任务执行的因素 : 
     *  - 正常终止
     *  - 出现异常
     *  - 用户取消 
     * 上述所有情况出现 , 都表示任务执行完毕 ; 
     */
    boolean isDone();
    /**
     * 等待任务完成 , 返回执行结果 ; 
     */
    V get() throws InterruptedException, ExecutionException;
    /**
     * 等待任务完成 , 返回执行结果 ; 
     *
     * @param 最长等待时间
     * @param 等待时间单位
     * @return 任务执行结果 
     */
    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}





二、Callable 接口


Callable<V> 简介 : Callable 是一个任务 , 返回 V 类型结果 , 或者 抛出异常 ; 实现类需要实现 call() 方法 , 该方法没有参数 ;



Callable<V> 与 Runnable 对比 :


该 Callable 接口与 Runnable 接口类似 , 两个接口都设计为实现类的对象实例 , 可能都要 在另外的线程执行 ;


Runnable 接口的 run() 方法 不返回返回值 , 不能抛出检查出的异常 ;


Callable<V> 接口的 call() 方法可以 返回返回值 , 可以抛出异常 ;



package java.util.concurrent;
/**
 * Callable<V> 是一个任务 , 返回 V 类型结果 , 或者抛出异常 ; 
 * 实现类需要实现 call() 方法 , 该方法没有参数 ; 
 * 
 * 该 Callable<V> 接口与 Runnable 接口类似 , 
 * 两个接口都设计为实现类的对象实例 , 可能都要在另外的线程执行 ; 
 * 
 * Runnable 接口的 run() 方法不返回返回值 , 不能抛出检查出的异常 ; 
 */
@FunctionalInterface
public interface Callable<V> {
    /**
     * 计算出一个结果 , 如果无法完成 , 抛出异常 ; 
     */
    V call() throws Exception;
}




三、Runnable 接口


Runnable 接口作用 : Runnable 接口的实现类实例 , 需要在一个线程中被执行 ; 该实现类必须实现 run() 方法 , 该方法返回值和参数都是 void ;



Runnable 接口设计 :


设计原则 : 该接口被设计为 , 为那些处于活动状态的对象 , 并且这些对象想要执行代码 , 提供一个通用协议 ;


如 : Thread 类实现了 Runnable 方法 ;


活动状态 : 处于活动状态的含义是 , 线程已经被开始了 , 还不能被停止 , 如果想要执行代码 , 必须在其它线程中执行 ;



创建线程优先策略 :


创建线程 : Runnable 为类提供了不需要继承 Thread 类 , 之外的活动的途径 ; 一个类实现了 Runnable 接口 , 在不继承 Thread 的前提下运行 , 方法是将其传入 Thread 构造函数 ;


推荐方案 :在大部分情况下 , 如果你只打算去覆盖 run 方法 , 并且没有其它的方法 , 应该使用 Runnable 接口 , 不建议使用 Thread 类 ;



不要轻易去继承一个类 , 除非开发者想要去修改或者增强父类的某些行为 ;



/**
 * Runnable 接口的实现类实例 , 需要在一个线程中被执行 ; 
 * 该实现类必须实现 run() 方法 , 该方法返回值和参数都是 void ; 
 * 
 * 该接口被设计为 , 为那些处于活动状态的对象 , 并且这些对象想要执行代码 , 提供一个通用协议 ; 
 * 如 : Thread 类实现了 Runnable 方法 ; 
 * 处于活动状态的含义是 , 线程已经被开始了 , 还不能被停止 , 如果想要执行代码 , 必须在其它线程中执行 ; 
 * 
 * 另外 , Runnable 为类提供了不需要继承 Thread 类 , 之外的活动的途径 ; 
 * 一个类实现了 Runnable 接口 , 在不继承 Thread 的前提下运行 , 方法是将其传入 Thread 构造函数 ; 
 * 在大部分情况下 , 如果你只打算去覆盖 run 方法 , 并且没有其它的方法 , 
 * 应该使用 Runnable 接口 , 不建议使用 Thread 类 ; 
 * 
 * 类不应该继承一个类 , 除非开发者想要去修改或者增强父类的某些行为 , 这是很重要的 ; 
 */
@FunctionalInterface
public interface Runnable {
    /**
     * 当一个对象实现了 Runnable 接口 , 用于创建一个线程时 , 
     * 启动线程会在该线程中 , 调用该对象的 run() 方法 ; 
     * 
     * run() 方法的通用规则是 , 在该方法中可以执行任何操作 ; 
     */
    public abstract void run();
}


目录
相关文章
|
2月前
|
机器学习/深度学习 数据采集 存储
时间序列预测新突破:深入解析循环神经网络(RNN)在金融数据分析中的应用
【10月更文挑战第7天】时间序列预测是数据科学领域的一个重要课题,特别是在金融行业中。准确的时间序列预测能够帮助投资者做出更明智的决策,比如股票价格预测、汇率变动预测等。近年来,随着深度学习技术的发展,尤其是循环神经网络(Recurrent Neural Networks, RNNs)及其变体如长短期记忆网络(LSTM)和门控循环单元(GRU),在处理时间序列数据方面展现出了巨大的潜力。本文将探讨RNN的基本概念,并通过具体的代码示例展示如何使用这些模型来进行金融数据分析。
398 2
|
4月前
|
并行计算 Java 大数据
Callable和Future
Callable和Future
|
1月前
|
数据采集 自然语言处理 搜索推荐
基于qwen2.5的长文本解析、数据预测与趋势分析、代码生成能力赋能esg报告分析
Qwen2.5是一款强大的生成式预训练语言模型,擅长自然语言理解和生成,支持长文本解析、数据预测、代码生成等复杂任务。Qwen-Long作为其变体,专为长上下文场景优化,适用于大型文档处理、知识图谱构建等。Qwen2.5在ESG报告解析、多Agent协作、数学模型生成等方面表现出色,提供灵活且高效的解决方案。
160 49
|
26天前
|
测试技术 开发者 Python
使用Python解析和分析源代码
本文介绍了如何使用Python的`ast`模块解析和分析Python源代码,包括安装准备、解析源代码、分析抽象语法树(AST)等步骤,展示了通过自定义`NodeVisitor`类遍历AST并提取信息的方法,为代码质量提升和自动化工具开发提供基础。
43 8
|
24天前
|
调度 开发者
核心概念解析:进程与线程的对比分析
在操作系统和计算机编程领域,进程和线程是两个基本而核心的概念。它们是程序执行和资源管理的基础,但它们之间存在显著的差异。本文将深入探讨进程与线程的区别,并分析它们在现代软件开发中的应用和重要性。
43 4
|
1月前
|
数据采集 存储 自然语言处理
基于Qwen2.5的大规模ESG数据解析与趋势分析多Agent系统设计
2022年中国上市企业ESG报告数据集,涵盖制造、能源、金融、科技等行业,通过Qwen2.5大模型实现报告自动收集、解析、清洗及可视化生成,支持单/多Agent场景,大幅提升ESG数据分析效率与自动化水平。
108 0
|
2月前
|
存储 SQL 分布式计算
湖仓一体架构深度解析:构建企业级数据管理与分析的新基石
【10月更文挑战第7天】湖仓一体架构深度解析:构建企业级数据管理与分析的新基石
150 1
|
2月前
|
Java C++
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
38 0
|
3月前
|
存储 缓存 自然语言处理
深度解析ElasticSearch:构建高效搜索与分析的基石
【9月更文挑战第8天】在数据爆炸的时代,如何快速、准确地从海量数据中检索出有价值的信息成为了企业面临的重要挑战。ElasticSearch,作为一款基于Lucene的开源分布式搜索和分析引擎,凭借其强大的实时搜索、分析和扩展能力,成为了众多企业的首选。本文将深入解析ElasticSearch的核心原理、架构设计及优化实践,帮助读者全面理解这一强大的工具。
268 7
|
4月前
|
Java
Java中Runnable和Callable有什么不同
【8月更文挑战第9天】Java中Runnable和Callable有什么不同
21 1

推荐镜像

更多