一、FutureTask 使用流程

FutureTask 使用流程 :

① 自定义 Callable 类型 : 实现 Callable<String> 接口 , 实现 call() 方法 , 返回值 String 类型 ;

② 创建 FutureTask 对象 : new FutureTask<String>(new MyCallable()) , 其返回值是 String 类型 , 传入 MyCallable 对象 ;

③ 创建线程池 : 调用 Executors.newCachedThreadPool() 创建线程池 ;

④ 执行 FutureTask 任务 : 调用线程池 executorService.execute(futureTask) 执行 FutureTask 任务 ;

二、FutureTask 模拟 AsyncTask 执行过程

1 . FutureTask 任务 : 普通的线程执行是无法获取到执行结果的 , FutureTask 间接实现了 Runnable 和 Future 接口 , 可以得到子线程耗时操作的执行结果 , AsyncTask 异步任务就是使用了该机制 ;

2 . 执行完毕自动回调方法 : FutureTask<String> 的 done() 方法 , 是在在 MyCallable 的 call() 方法执行完毕后 , 自动回调的方法 ;

3 . 获取执行结果 :

① 获取执行结果 : 在 FutureTask<String> 类中 , 调用 get() 方法 , 可以获取 MyCallable 的 call 方法耗时操作的结果 , 获取的值的类型是 FutureTask<String> 的泛型类型 String 类型 ;

② 非阻塞获取执行结果 : 注意 FutureTask 对象的 get() 最好在 done 中调用 , 可以立刻得到异步操作的执行结果 ;

③ 阻塞获取执行结果 : 如果调用 get() 方法时 , Callable 的 call() 方法还没有执行完毕 , 此时调用线程就会一直阻塞 , 直到 call() 方法是调用完毕 , 返回执行结果 , 此时才会解除阻塞 , 返回执行结果 ;

4 . 代码示例 :

package kim.hsl.aa;import androidx.appcompat.app.AppCompatActivity;import android.os.Bundle;
import android.util.Log;import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;public class MainActivity extends AppCompatActivity {public static final String TAG = "MainActivity";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 手写 AsyncTaskfuture();}private void future(){/*FutureTask 间接实现了 Runnable 和 Future 接口 ,可以得到子线程耗时操作的执行结果 , AsyncTask 异步任务就是使用了该机制 ;需要开发者传入 Callable 或者 Runnable 实现类对象 , 在该对象中定义要在子线程中执行的操作*/FutureTask<String> futureTask = new FutureTask<String>(new MyCallable()){/*** 该方法在 MyCallable 的 call() 方法执行完毕后* 自动回调*/@Overrideprotected void done() {try {/*获取 MyCallable 的 call 方法耗时操作的结果注意 FutureTask 对象的 get() 最好在 done 中调用 , 可以立刻得到异步操作的执行结果如果调用 get() 方法时 , Callable 的 call() 方法还没有执行完毕 ,此时调用线程就会一直阻塞 , 直到 call() 方法是调用完毕 ,返回执行结果 , 此时才会解除阻塞 , 返回执行结果 ;*/String callableResult = get();Log.i(TAG, "执行结果 : " + callableResult);} catch (ExecutionException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}};// 创建线程池 , 通过该线程池执行ExecutorService executorService = Executors.newCachedThreadPool();// 执行 futureTask 耗时操作executorService.execute(futureTask);}/*** 自定义 Callable 类型* 实际的异步操作在该方法中执行*/class MyCallable implements Callable<String>{@Overridepublic String call() throws Exception {Log.i(TAG, "MyCallable call() 耗时操作");return "Success";}}}

5 . 执行结果 :

2020-07-10 20:15:30.724 4325-4461/kim.hsl.aa I/MainActivity: MyCallable call() 耗时操作
2020-07-10 20:15:30.724 4325-4461/kim.hsl.aa I/MainActivity: 执行结果 : Success

三、AsyncTask 执行过程回顾

AsyncTask 异步任务执行流程 :

① 构造函数中 :

创建 Callable 任务 : 创建 WorkerRunnable , 这是 Callable 接口的抽象类 ;
创建了 FutureTask 任务 : 该任务线程执行可以返回线程执行结果 ;

上述 WorkerRunnable 对象 , 就是传递给 FutureTask 的参数 , 与实际的后台任务方法 doInBackground() 就是执行的 WorkerRunnable 的 call() 方法 ;

② 执行异步任务 : 使用 SerialExecutor 自定义的串行线程池 , 调用 SerialExecutor 对象的 execute 方法 , 执行 FutureTask 任务 ;

四、FutureTask 分析

FutureTask<V> 是一个可取消的异步运算 ; 该类提供了一个 Future 实现 , 包含了如下方法 :

开始计算的过程
取消计算过程
检查计算是否完成
获取计算结果

计算结果只能在计算完毕之后获取 ; 如果计算没有完成 , 计算方法将会阻塞 ;

计算过程是一次性的 , 计算已经完成后 , 无法重新开始或取消 , 除非调用重置方法

该类实现了 RunnableFuture 接口 ;

/*** 一个可取消的异步计算 ; * 该类提供了一个 Future 实现 , 包含了如下方法 : *  - 1. 开始计算的过程 *  - 2. 取消计算过程 *  - 3. 检查计算是否完成*  - 4. 获取计算记过 * 计算结果只能在计算完毕之后获取 ; * 如果计算没有完成 , 计算方法将会阻塞 ; * 计算过程是一次性的 , 计算已经完成后 , 无法重新开始或取消 , 除非调用重置方法*/
public class FutureTask<V> implements RunnableFuture<V> {}

RunnableFuture 接口说明 : 既是 Future , 又是 Runnable ; 执行 run 方法后 , Future 也同时完成 , 并且允许查询执行结果 ;

/*** 既是 Future , 又是 Runnable ; * 执行 run 方法后 , Future 也同时完成 , 允许查询执行结果 ; * * @param <V> 返回结果 , V 泛型类型*/
public interface RunnableFuture<V> extends Runnable, Future<V> {/*** 为计算的执行结果设置这个 Future , 除非该任务被取消 ; */void run();
}

【Android 异步操作】AsyncTask 异步任务 ( FutureTask 模拟 AsyncTask 执行过程 | AsyncTask 执行过程回顾 | FutureTask 分析 )相关推荐

【Android 异步操作】AsyncTask 异步任务 ( 参数简介 | 方法简介 | 使用方法 | AsyncTask 源码分析 )
文章目录一.AsyncTask 参数简介二.AsyncTask 方法简介三.AsyncTask 基本用法四.AsyncTask 构造函数源码解析五.AsyncTask 构造函数相关源码注释 ...
【Android 异步操作】AsyncTask 异步任务 ( AsyncTask 异步任务执行方法 execute 方法相关源码解析 )
文章目录一.AsyncTask 异步任务执行方法 execute() 引入二.AsyncTask 异步任务执行方法 execute() 三.sDefaultExecutor 线程池解析四.exe ...
Android开发--AsyncTask异步任务（二）
一.什么是异步操作异步操作是指把消耗时间的操作放在另一个线程内执行,变成两个线程独立并行执行的状态.通常涉及网络的操作大多数放在异步任务中. 二.异步任务AsyncTask 1.建立异步任务 pub ...
【Android】AsyncTask异步类
一.关于AysncTask AsyncTask使得多线程编程更加简单,AsyncTask能在后台线程执行异步任务,并且在UI线程更新界面,而不再需要用户去操作Thread和Handler.AysncT ...
Android中的AsyncTask异步任务的简单实例
在 Android中的AsyncTask异步任务的简单介绍一文中,已经对安卓异步任务操作做了简单的介绍,这里,直接将上文中的异步任务做了一个实例,实现异步操作更新UI线程,相比开启子线程更新来 ...
Android AsyncTask异步线程
(图) 在开发Android移动客户端的时候往往要使用多线程来进行操作,我们通常会将耗时的操作放在单独的线程执行,避免其占用主线程而给用户带来不好的用户体验.但是在子线程中 ...
android服务绑定异步,Android中异步类AsyncTask用法总结
本文总结分析了Android中异步类AsyncTask用法.分享给大家供大家参考,具体如下: 最近整理笔记的时候,看到有关AsyncTask不是很理解,重新疏导了一下,有在网上找了一些资料,个人不敢独 ...
android异步任务更新进度条,Android的AsyncTask异步任务浅析
Android的AsyncTask异步任务浅析实现原理内部封装了2个线程池+1个Handler(InternalHandler),1个线程池SerialExecutor任务排队,一个线程池THRE ...
Android异步处理二：AsynTask介绍和使用AsyncTask异步更新UI界面
做一下如何同构AsyncTask异步任务来更新UI界面. (1)AsyncTask的介绍通过上图中的AsyncTask的源码结构图可以看到,主要用于重载的方法是doInBackground(),on ...

【Android 异步操作】AsyncTask 异步任务 ( FutureTask 模拟 AsyncTask 执行过程 | AsyncTask 执行过程回顾 | FutureTask 分析 )

文章目录

一、FutureTask 使用流程

二、FutureTask 模拟 AsyncTask 执行过程

三、AsyncTask 执行过程回顾

四、FutureTask 分析

【Android 异步操作】AsyncTask 异步任务 ( FutureTask 模拟 AsyncTask 执行过程 | AsyncTask 执行过程回顾 | FutureTask 分析 )相关推荐

最新文章

热门文章