开发者社区> 韩曙亮> 正文

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

简介: 【Android 异步操作】AsyncTask 异步任务 ( FutureTask 模拟 AsyncTask 执行过程 | AsyncTask 执行过程回顾 | FutureTask 分析 )
+关注继续查看

文章目录

一、FutureTask 使用流程

二、FutureTask 模拟 AsyncTask 执行过程

三、AsyncTask 执行过程回顾

四、FutureTask 分析





一、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";
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        // 手写 AsyncTask
        future();
    }
    private void future(){
        /*
            FutureTask 间接实现了 Runnable 和 Future 接口 ,
            可以得到子线程耗时操作的执行结果 , AsyncTask 异步任务就是使用了该机制 ;
            需要开发者传入 Callable 或者 Runnable 实现类对象 , 在该对象中定义要在子线程中执行的操作
         */
        FutureTask<String> futureTask = new FutureTask<String>(new MyCallable()){
            /**
             * 该方法在 MyCallable 的 call() 方法执行完毕后
             * 自动回调
              */
            @Override
            protected 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>{
        @Override
        public 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();
}


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
C#.NET使用Task,await,async,异步执行控件耗时事件(event),不阻塞UI线程和不跨线程执行UI更新,以及其他方式比较
原文:C#.NET使用Task,await,async,异步执行控件耗时事件(event),不阻塞UI线程和不跨线程执行UI更新,以及其他方式比较 使用Task,await,async,异步执行事件(event),不阻塞UI线程和不跨线程执行UI更新   使用Task,await,async 的异步模式 去执行事件(event) 解决不阻塞UI线程和不夸跨线程执行UI更新报错的最佳实践,附加几种其他方式比较 由于是Winform代码和其他原因,本文章只做代码截图演示,不做界面UI展示,当然所有代码都会在截图展示。
3656 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
20100 0
不同操作系统之间的软件管理理念的分析_学习笔记
时间:2017.11.30作者:李强参考:man,info,magedu讲义,神奇的internet声明:以下英文纯属个人翻译,英文B级,欢迎纠正,以下内容纯属个人理解,并没有对错,只是参考,盗版不纠,才能有限,希望不误人子弟为好。
795 0
【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )
【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )
22 0
与众不同 windows phone (11) - Background Task(后台任务)之警报(Alarm)和提醒(Reminder)
原文:与众不同 windows phone (11) - Background Task(后台任务)之警报(Alarm)和提醒(Reminder) [索引页][源码下载] 与众不同 windows phone (11) - Background Task(后台任务)之警报(Alarm)和提醒(Reminder) 作者:webabcd介绍与众不同 windows phone 7.
692 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
18390 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
24948 0
+关注
韩曙亮
专注 Android 领域
2605
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载