【Android 异步操作】AsyncTask 异步任务 ( AsyncTask 异步任务执行方法 execute 方法相关源码解析 )

简介: 【Android 异步操作】AsyncTask 异步任务 ( AsyncTask 异步任务执行方法 execute 方法相关源码解析 )

文章目录

一、AsyncTask 异步任务执行方法 execute() 引入

二、AsyncTask 异步任务执行方法 execute()

三、sDefaultExecutor 线程池解析

四、executeOnExecutor 方法解析

五、AsyncTask 异步任务执行方法 execute() 相关源码注释





一、AsyncTask 异步任务执行方法 execute() 引入


上一篇博客中 【Android 异步操作】AsyncTask 异步任务 ( 参数简介 | 方法简介 | 使用方法 | AsyncTask 源码分析 ) , 讲解了 AsyncTask<Params, Progress, Result> 异步任务的构造函数 ;


异步任务执行有两个方法 :


构造异步任务 : 调用 AsyncTask 的构造函数 , 创建 AsyncTask 异步任务对象 ;

执行异步任务 : 调用 AsyncTask 异步任务对象的 execute() 方法 , 执行异步任务 ;

本篇博客中讲解执行函数 AsyncTask<Params, Progress, Result> execute(Params… params) ;


// 1. 创建 AsyncTask 异步任务
MyAsyncTask mMyAsyncTask = new MyAsyncTask();
// 2. 执行 AsyncTask 异步任务
mMyAsyncTask.execute();





二、AsyncTask 异步任务执行方法 execute()


AsyncTask<Params, Progress, Result> execute(Params… params) 方法作用 : AsyncTask 异步任务的 execute() 函数作用就是提交任务 , 其提交的任务就是 FutureTask , 其使用的是 线程池 提交任务 ;



① 参数 : 使用指定的参数 , 执行任务 ;


② 返回值 : 这个任务返回 AsyncTask<Params, Progress, Result> 本身对象 , 以便调用者可以持有该异步任务的引用 ;


③ 任务调度 : 该方法在队列上调度一个任务 , 该任务在一个单独的后台线程 , 或线程池中执行 ; 第一次引入后 , 异步任务在单独后台线程中被串行执行 ;


④ 不同版本的执行任务载体 :


Android 1.6(API 级别 4)及以下的版本是在一个后台线程中串行执行 ;

Android 2.0(API 级别 5)及以上的版本是在线程池中串行执行 ;

Android 3.0(API 级别 11)及以上的版本有回复到在一个后台线程中串行执行 ;

在该类中 , 最终调用了 executeOnExecutor() 方法 , 使用 sDefaultExecutor 默认串行线程池执行任务 ;


public abstract class AsyncTask<Params, Progress, Result> {
    @MainThread
    public final AsyncTask<Params, Progress, Result> execute(Params... params) {
        return executeOnExecutor(sDefaultExecutor, params);
    }
}


如果同时调用 AsyncTask 异步任务的 execute() 函数执行任务 , 其任务会逐个串行执行 , 不是并行的 ;


AsyncTask<Params, Progress, Result> 对象的 execute() 执行的任务是有序的 ;






三、sDefaultExecutor 线程池解析


上述执行异步任务的方法 executeOnExecutor() , 传入了 sDefaultExecutor 线程池作为参数 , 本节分析 sDefaultExecutor 线程池 ;



sDefaultExecutor 是成员变量 , 其声明类型是 Executor , 实际类型是自定义的线程池 SerialExecutor() ;



SerialExecutor 是一个线程池 , 执行任务 , 每次只执行一个任务 , 按照串行顺序执行 ; 该序列对于特定进程来说是全局的 , 即一个进程只有一个该序列 ;



在该线程池中 , 维护了如下两个成员 :


任务队列 ArrayDeque mTasks

当前执行任务 Runnable mActive


该线程池中 void execute(final Runnable r) 执行任务方法 :


执行当前传入的任务 : 自己创建一个 Runnable , 在其 run() 方法中执行传入的参数的 r 的 run() 方法 ;

执行下一个任务 : 执行完毕当前任务后 , 调用 scheduleNext() 执行下一个任务


scheduleNext() 方法 用于执行下一个任务 , 从队列中取出一个任务 , 如果取出的任务不为空 , 那么就执行该任务 ; 调用 SerialExecutor 类的 execute(final Runnable r) 方法执行该任务 ;


public abstract class AsyncTask<Params, Progress, Result> {
    private static final String LOG_TAG = "AsyncTask";
    /**
     * 自定义线程池 ; 
     * 一个线程池 , 执行任务 , 每次只执行一个任务 , 按照串行顺序执行 ; 
     * 该序列对于特定进程来说是全局的 , 即一个进程只有一个该序列 ; 
     */
    public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
    @UnsupportedAppUsage
    private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;
    /**
     * 自定义线程池 ; 
     * 一个线程池 , 执行任务 , 每次只执行一个任务 , 按照串行顺序执行 ; 
     * 该序列对于特定进程来说是全局的 , 即一个进程只有一个该序列 ; 
     */
    private static class SerialExecutor implements Executor {
      // 任务队列 
        final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();
        // 当前执行的任务 
        Runnable mActive;
  // 执行任务
        public synchronized void execute(final Runnable r) {
          // 自己创建一个 Runnable , 在其 run() 方法中执行如下方法 : 
          // 传入的 execute(final Runnable r) 方法参数的 r 的 run() 方法 ; 
            mTasks.offer(new Runnable() {
                public void run() {
                    try {
                        r.run();
                    } finally {
                      // 执行完毕当前任务后 , 执行下一个任务
                        scheduleNext();
                    }
                }
            });
    // 如果当前任务为空 , 那么执行下一个任务 
            if (mActive == null) {
                scheduleNext();
            }
        }
  /**
   * 执行下一个任务 
   * 从队列中取出一个任务 , 如果取出的任务不为空 , 那么就执行该任务 ; 
   * 调用 SerialExecutor 类的 execute(final Runnable r) 方法执行该任务 ; 
   */
        protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
              // 执行队列中的任务的操作 
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }
    }
}





四、executeOnExecutor 方法解析


executeOnExecutor 方法是异步任务执行的核心方法 ;



执行流程如下 :



① 判定合法性 : AsyncTask 异步任务只能执行一次 , 必须确保该 AsyncTask 异步任务没有执行过 , 如果执行过直接抛出异常 ;


② 设置运行状态 : 将该异步任务状态设置成 Status.RUNNING 状态 , 防止第二次被执行 ;


③ 主线程初始化 : 执行 onPreExecute() 方法 , 用户可以在该方法中初始化 UI , 该操作在 UI 主线程中运行 ;


④ 子线程后台任务执行 : 执行 FutureTask 中的 Callable 任务 , 也就是异步任务 , 该操作在子线程中运行 ;



public abstract class AsyncTask<Params, Progress, Result> { 
    /**
     * 使用指定的参数 , 执行任务 ; 
     * 这个任务返回 AsyncTask<Params, Progress, Result> 本身对象 , 
     * 一遍调用者可以持有该异步任务的引用 ; 
     * 
     * 该方法通常与 THREAD_POOL_EXECUTOR 一同使用 , 允许多个任务在一个线程池中串行执行 , 
     * 该线程池由 AsyncTask 异步任务管理 , 也可以使用自己的线程池定制相关行为 ; 
     */
    @MainThread
    public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
            Params... params) {
        // 首先判定当前状态是否合法 , 确保该 AsyncTask 异步任务没有执行过 , 
        // 每个 AsyncTask 异步任务创建后只能执行一次 ; 
        if (mStatus != Status.PENDING) {
            switch (mStatus) {
                case RUNNING:
                    throw new IllegalStateException("Cannot execute task:"
                            + " the task is already running.");
                case FINISHED:
                    throw new IllegalStateException("Cannot execute task:"
                            + " the task has already been executed "
                            + "(a task can be executed only once)");
            }
        }
  // 设置状态为执行状态 
        mStatus = Status.RUNNING;
  // 执行 doInBackground() 之前执行的方法 
        onPreExecute();
  // 设置 WorkerRunnable 的 Params[] mParams 参数
        mWorker.mParams = params;
        // 执行 FutureTask 中的 Callable 任务
        exec.execute(mFuture);
        return this;
    }
}






五、AsyncTask 异步任务执行方法 execute() 相关源码注释


public abstract class AsyncTask<Params, Progress, Result> {
    private static final String LOG_TAG = "AsyncTask";
    /**
     * 自定义线程池 ; 
     * 一个线程池 , 执行任务 , 每次只执行一个任务 , 按照串行顺序执行 ; 
     * 该序列对于特定进程来说是全局的 , 即一个进程只有一个该序列 ; 
     */
    public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
    @UnsupportedAppUsage
    private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;
    /**
     * 自定义线程池 ; 
     * 一个线程池 , 执行任务 , 每次只执行一个任务 , 按照串行顺序执行 ; 
     * 该序列对于特定进程来说是全局的 , 即一个进程只有一个该序列 ; 
     */
    private static class SerialExecutor implements Executor {
      // 任务队列 
        final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();
        // 当前执行的任务 
        Runnable mActive;
  // 执行任务
        public synchronized void execute(final Runnable r) {
          // 自己创建一个 Runnable , 在其 run() 方法中执行如下方法 : 
          // 传入的 execute(final Runnable r) 方法参数的 r 的 run() 方法 ; 
            mTasks.offer(new Runnable() {
                public void run() {
                    try {
                        r.run();
                    } finally {
                      // 执行完毕当前任务后 , 执行下一个任务
                        scheduleNext();
                    }
                }
            });
    // 如果当前任务为空 , 那么执行下一个任务 
            if (mActive == null) {
                scheduleNext();
            }
        }
  /**
   * 执行下一个任务 
   * 从队列中取出一个任务 , 如果取出的任务不为空 , 那么就执行该任务 ; 
   * 调用 SerialExecutor 类的 execute(final Runnable r) 方法执行该任务 ; 
   */
        protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
              // 执行队列中的任务的操作 
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }
    }
    /**
     * 使用指定的参数 , 执行任务 ; 
     * 这个任务返回 AsyncTask<Params, Progress, Result> 本身对象 , 
     * 一遍调用者可以持有该异步任务的引用 ; 
     * 
     * 该方法在队列上调度一个任务 , 该任务在一个单独的后台线程  , 或线程池中执行 ; 
     * 第一次引入后 , 异步任务在单独后台线程中被串行执行 ; 
     * Android 1.6(API 级别 4)及以下的版本是在一个后台线程中串行执行 ; 
     * Android 2.0(API 级别 5)及以上的版本是在线程池中串行执行 ; 
     * Android 3.0(API 级别 11)及以上的版本有回复到在一个后台线程中串行执行 ; 
     *
     * <p>改方法必须在 UI 线程中调用 
     *
     * @param 要执行的任务的参数.
     *
     * @return 返回异步任务 AsyncTask 本身 .
     */
    @MainThread
    public final AsyncTask<Params, Progress, Result> execute(Params... params) {
        return executeOnExecutor(sDefaultExecutor, params);
    }
    /**
     * 使用指定的参数 , 执行任务 ; 
     * 这个任务返回 AsyncTask<Params, Progress, Result> 本身对象 , 
     * 一遍调用者可以持有该异步任务的引用 ; 
     * 
     * 该方法通常与 THREAD_POOL_EXECUTOR 一同使用 , 允许多个任务在一个线程池中串行执行 , 
     * 该线程池由 AsyncTask 异步任务管理 , 也可以使用自己的线程池定制相关行为 ; 
     */
    @MainThread
    public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
            Params... params) {
        // 首先判定当前状态是否合法 , 确保该 AsyncTask 异步任务没有执行过 , 
        // 每个 AsyncTask 异步任务创建后只能执行一次 ; 
        if (mStatus != Status.PENDING) {
            switch (mStatus) {
                case RUNNING:
                    throw new IllegalStateException("Cannot execute task:"
                            + " the task is already running.");
                case FINISHED:
                    throw new IllegalStateException("Cannot execute task:"
                            + " the task has already been executed "
                            + "(a task can be executed only once)");
            }
        }
  // 设置状态为执行状态 
        mStatus = Status.RUNNING;
  // 执行 doInBackground() 之前执行的方法 
        onPreExecute();
  // 设置 WorkerRunnable 的 Params[] mParams 参数
        mWorker.mParams = params;
        // 执行 FutureTask 中的 Callable 任务
        exec.execute(mFuture);
        return this;
    }
}




目录
相关文章
|
15天前
|
XML Java Android开发
Android实现自定义进度条(源码+解析)
Android实现自定义进度条(源码+解析)
48 1
|
1月前
|
Java 数据库 Android开发
Android异步之旅:探索AsyncTask
Android异步之旅:探索AsyncTask
22 0
|
3月前
|
Android开发 Python
Python封装ADB获取Android设备wifi地址的方法
Python封装ADB获取Android设备wifi地址的方法
60 0
|
3月前
|
Android开发 开发者
Android网络和数据交互: 请解释Android中的AsyncTask的作用。
Android网络和数据交互: 请解释Android中的AsyncTask的作用。
21 0
|
3月前
|
存储 算法 安全
AVB数据解析:Android verified boot 2.0 vbmeta 数据结构解析
AVB数据解析:Android verified boot 2.0 vbmeta 数据结构解析
119 0
|
15天前
|
Android开发
Android调用相机与相册的方法2
Android调用相机与相册的方法
17 0
|
22天前
|
监控 算法 Unix
【Linux 异步操作】深入理解 Linux 异步通知机制:原理、应用与实例解析
【Linux 异步操作】深入理解 Linux 异步通知机制:原理、应用与实例解析
55 0
|
1月前
|
编译器 开发工具 Android开发
Android 12 新特性深度解析
【2月更文挑战第15天】 随着移动操作系统的不断进化,Android 12带来了一系列创新功能与性能提升。本文将深入剖析Android 12的核心新特性,包括隐私仪表盘、通知管理、设备控制以及性能优化等方面,为开发者和用户提供全面的更新指南。
|
3月前
|
JSON Java Android开发
Android网络和数据交互: 请解释Android中的JSON解析库,如Gson。
Android网络和数据交互: 请解释Android中的JSON解析库,如Gson。
24 0
|
3月前
|
安全 Java 数据安全/隐私保护
Android和iOS应用程序加固方法详解:混淆、加壳、数据加密、动态加载和数字签名实现
Android和iOS应用程序加固方法详解:混淆、加壳、数据加密、动态加载和数字签名实现
65 0

推荐镜像

更多