AsyncTask 异步执行
AsyncTask 中持有了静态的 InternalHandler (初始化时默认绑定 MainLooper),静态的串行执行任务的线程池和静态的并行执行任务的线程池
但是串行执行任务的线程池并不会自己处理任务,而是调用并行线程池处理任务。执行任务时将任务添加到串行线程池中的 mTask 队列中,队列中会依次取出任务并调用并行线程池来执行任务,在传递任务时通过 WorkderRunnable 和 FutureTask 将参数传递到并行线程池,并行线程池中处理任务时调用 doInBackground 方法,该方法执行在子线程。
并行线程池每执行完一个任务, 都会通过 InternalHandler 发送消息,InternalHandler 处理消息在主线程,收到执行完成消息后,做完成处理(消息中持有当前 AsyncTask 对象的引用,调用该引用完成操作)。
执行结束后串行线程池会从队列中再取出一个任务,如果没有任务则不处理,有任务则继续调用并行线程池处理,所以串行线程池中通过 mTask 队列完成串行执行。
执行流程分析
AsyncTask
InternalHandler
构造函数中默认绑定 MainLooper ,其处理消息在主线程
SerialExecutor sDefaultExecutor 串行执行任务的线程池
Executor THREAD_POOL_EXECUTOR 并行执行任务的线程池
AsyncTask 初始化时,初始化 FutureTask 对象,为一个 Runnable,其保持了 WorkerRunnable 对象的引用,WorkerRunnable 中持有任务参数。
excute 方法中,调用了 ExcuteOnExecutor 方法, 将 SerialExecutor 作为默认线程池处理 FutureTask 任务
ExcuteOnExecutor 会先判断当前异步任务的状态,如果在运行或结束则抛出异常,无异常则修改 AsyncTask 的状态并执行 onPreExcute 方法,接着调用 SerialExecutor 的 execute 方法
SerialExecutor 的 execute 方法将任务添加到其内部的队列 mTasks 中,按顺序依次执行
SerialExecutor 中执行任务时,调用 THREAD_POOL_EXECUTOR 处理任务,执行完毕后再从 mTasks 中取下一个任务,从而实现串行
执行任务时在子线程中,调用被执行的 FutureTask 的 run 方法,其中调用其保持的 WorkerRunnable 对象的 call 方法
call 方法中,会调用 doInBackground 方法从而该方法中的代码执行在子线程,调用 publishProgress 方法通过 InternalHandler 消息机制向主线程发送进度
call 方法中 doInBackground 执行结束后,调用 postResult 方法,通过消息机制,调用 AsyncTask 的 finish 方法
finish 方法中判断如果任务取消则调用 onCancelled 如果未取消则调用 onPostExecute ,最后更新任务的状态
总结
1.6 版本之前串行处理,1.6之后并行处理,3.0之后再次改为串行处理,想要并行执行,直接调用 executeOnExecutor 方法,参数传入 AsyncTask 的静态属性 THREAD_POOL_EXECTOR 线程池。
创建 AsyncTask 类对象,调用 execute 方法启动,默认启动的是顺序执行的,执行过程中线程的切换是通过静态的 InternalHandler 完成的
InternalHandler 创建时自动绑定 MainLooper ,所以处理事件运行在主线程
AsyncTask 实例化时,会创建创建 WorkerRunnable 对象和 FutureTask 对象,在线程池中的线程运行时会在 FutureTask 的 run 方法中调用 WorkerRunnable 的 call 方法,call 方法就运行在了子线程,call方法中调用 doInBackground 方法也就运行在了子线程
doInBackground 执行结束之后会使用 InternalHandler 发消息将当前 AsyncTask 和 返回值传递到主线程
主线程处理消息时调用对应 AsyncTask 的 finish 方法,处理 onCanclelled 和 onPostExecute 方法
子线程运行过程中的进度提交也是通过类似方式,在 doInBackground 中调用 publishProgress 方法,该方法会将进度使用 InternalHandler 提交
主线程收到 InternalHandler 发来的进度之后,通过 onProgressUpdata 接收进度并做相应处理
运行时首先调用 opRreExecute 方法,再通过 Executor 的 excute 方法,将包装了 WorkerRunnable 这个 Runnable 对象的 FutureTask 对象传入线程池,线程池中就会调用 FutureTask 的 run 方法,run 方法中调用 WorkerRunnable 的 call 方法,call 再执行 doInBackGround 方法,最后通过 Handler 提交到主线程执行 onPostExcuete 方法