Android AsyncTask源码解读
生活随笔
收集整理的這篇文章主要介紹了
Android AsyncTask源码解读
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
屢思路
1. 初始 AsyncTask
AsyncTask 這個類的聲明如下：
public abstract class AsyncTask<Params, Progress, Result> {..... } 復制代碼是一個抽象類 Params 表示輸入參數的類型 Progress 表示后臺任務的執行進度 Result 表示返回結果的類型
2.使用
在 AsyncTask 這個類的頂部有一些代碼注釋，里面講述了如何使用一個 AsyncTask,如下：
* <p>Here is an example of subclassing:</p>* <pre class="prettyprint">* private class DownloadFilesTask extends AsyncTask<URL, Integer, Long> {* protected Long doInBackground(URL... urls) {* int count = urls.length;* long totalSize = 0;* for (int i = 0; i < count; i++) {* totalSize += Downloader.downloadFile(urls[i]);* publishProgress((int) ((i / (float) count) * 100));* // Escape early if cancel() is called* if (isCancelled()) break;* }* return totalSize;* }** protected void onProgressUpdate(Integer... progress) {* setProgressPercent(progress[0]);* }** protected void onPostExecute(Long result) {* showDialog("Downloaded " + result + " bytes");* }* }* </pre>//user <p>Once created, a task is executed very simply:</p>* <pre class="prettyprint">* new DownloadFilesTask().execute(url1, url2, url3);* </pre> 復制代碼3. 內部重要方法
- onPreExecute()
在主線程中運行，異步任務之前會被調用，一般用于做一些準備工作；
- doInBackground()
在線程池中運行，此方法一般用于執行異步任務，通過publishProgress 方法來更新進度；
- onProgressUpdate()
主線程中運行，當通過publishProgress 方法調用后，onProgressUpdate() 方法會被調用；
- onPostExecute()
主線程中運行，將返回的結果展示。
4.源碼分析
從它的 execute 方法開始：
@MainThreadpublic final AsyncTask<Params, Progress, Result> execute(Params... params) {//sDefaultExecutor 定義如下，線程池return executeOnExecutor(sDefaultExecutor, params);}private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR; public static final Executor SERIAL_EXECUTOR = new SerialExecutor(); 復制代碼@MainThreadpublic final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,Params... params) {//首先判斷是不是 PENDINGif (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)");}}//將狀態設置為 RUNNING 狀態mStatus = Status.RUNNING;//1.調用了 onPreExecute() 方法onPreExecute();//將參數封裝到 mWorker.mParams 中去了mWorker.mParams = params;//調用execute 將mFuture 傳進去了exec.execute(mFuture);return this;} 復制代碼為了弄明白整體流程，首頁要搞明白上面的 mWorker mFuture 是干嘛的。
- mWorker
postResult(result) 方法
private Result postResult(Result result) {@SuppressWarnings("unchecked")Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,new AsyncTaskResult<Result>(this, result));message.sendToTarget();return result;}復制代碼發送一條 MESSAGE_POST_RESULT 的消息，并且將result 存入到了 AsyncTaskResult中的 mData 中去了， 其中 AsyncTaskResult
@SuppressWarnings({"RawUseOfParameterizedType"})private static class AsyncTaskResult<Data> {final AsyncTask mTask;final Data[] mData;AsyncTaskResult(AsyncTask task, Data... data) {mTask = task;mData = data;}} 復制代碼getHandler 獲取一個 Handler ,我們看下 handleMessage 的MESSAGE_POST_RESULT 對這條消息的處理：
private static class InternalHandler extends Handler {public InternalHandler(Looper looper) {super(looper);}@SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})@Overridepublic void handleMessage(Message msg) {AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;switch (msg.what) {case MESSAGE_POST_RESULT://是他是他 就是他// There is only one resultresult.mTask.finish(result.mData[0]);break;case MESSAGE_POST_PROGRESS:result.mTask.onProgressUpdate(result.mData);break;}}} 復制代碼其中 result 是 AsyncTaskResult 類型，前面我們見到過的，mTask 當時我們傳的是 this 也就是當前的 AsyncTask ,調用finish 方法，將mData 返回的結果傳入進去，還記得我們前面看過的嗎，將返回的結果存入AsyncTaskResult.mData中去了。
下面看下 finish方法：
private void finish(Result result) {//判斷是否取消，如果取消了，就不執行onPostExecute 了if (isCancelled()) {onCancelled(result);} else {//4. 就執行onPostExecute 方法了onPostExecute(result);}// 將狀態標志為 finishmStatus = Status.FINISHED;} 復制代碼ok ，上述都是 mWorker 工作的，接下來是我們一開始說的 mFuture
- mFuture
postResultIfNotInvoked(get()); 如下：
private void postResultIfNotInvoked(Result result) {final boolean wasTaskInvoked = mTaskInvoked.get();//wasTaskInvoked 為true ,之前在 mWorker 中設置了為true //mWorker = new WorkerRunnable<Params, Result>() { // public Result call() throws Exception {// mTaskInvoked.set(true);if (!wasTaskInvoked) {postResult(result);}} 復制代碼FutureTask :
我們知道mWorker implement Callable 接口，傳入賦值給了callable 變量public FutureTask(Callable<V> callable) {if (callable == null)throw new NullPointerException();this.callable = callable;this.state = NEW; // ensure visibility of callable}public void run() {if (state != NEW ||!U.compareAndSwapObject(this, RUNNER, null, Thread.currentThread()))return;try {//callable 變量又賦值給了 cCallable<V> c = callable;if (c != null && state == NEW) {V result;boolean ran;try {//這里調用c.call 實際上就是調用 mWorker.call 方法 //，由我們上面的分析知道，在mWorker.call 方法中最終會返回 result 結果result = c.call();ran = true;} catch (Throwable ex) {result = null;ran = false;setException(ex);}if (ran)set(result);}} finally {// runner must be non-null until state is settled to// prevent concurrent calls to run()runner = null;// state must be re-read after nulling runner to prevent// leaked interruptsint s = state;if (s >= INTERRUPTING)handlePossibleCancellationInterrupt(s);}} 復制代碼ok ，這是 mFuture,還剩下最后一個：
exec.execute(mFuture);
exec 就是 sDefaultExecutor ,其實 就是 SerialExecutor,如下：
private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;public static final Executor SERIAL_EXECUTOR = new SerialExecutor(); 復制代碼SerialExecutor 如下：
private static class SerialExecutor implements Executor {final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();Runnable mActive;public synchronized void execute(final Runnable r) {mTasks.offer(new Runnable() {public void run() {try {r.run();} finally {scheduleNext();}}});//第一次肯定為null ，執行 scheduleNextif (mActive == null) {scheduleNext();}}protected synchronized void scheduleNext() {//給 mActivie 賦值，mTasks.poll 會從第一個開始取if ((mActive = mTasks.poll()) != null) {THREAD_POOL_EXECUTOR.execute(mActive);}}} 復制代碼上面我們將 mFuture 傳入，實際就是 r. mTask 是 ArrayDeque<Runnable> 姑且認為它是這個排隊序列的吧?？聪耾ffer 方法：
/**插入一個 element 在隊尾* Inserts the specified element at the end of this deque.** <p>This method is equivalent to {@link #offerLast}.** @param e the element to add* @return {@code true} (as specified by {@link Queue#offer})* @throws NullPointerException if the specified element is null*/public boolean offer(E e) {return offerLast(e);} 復制代碼看注釋，也就是說是每次執行一個任務，都是在當前 deque 的隊尾開始排隊的。并且執行是串行的，因為當第二個線程過來的時候，判斷 mActive 不為 null 將不會執行 scheduleNext.(我這個是8.0)源碼，其實在 android 3.0 之后 AsyncTask 都是采用串行執行任務的。
各個版本的不同如下： android 1.6之前 ------ 串行 android 1.6-3.0 之間 ----- 并行 android 3.0 之后 ----- 串行
盡管如此，我們仍然可以通過 調用 executeOnExecutor 來并行執行任務。
ok ， 回到那個 execute 方法中，我們說調用了 r.run 實際山就是 調用 mFuture.run 方法： 上面我們展示過在 mFuture.run 方法中如下：
try {//這里調用c.call 實際上就是調用 mWorker.call 方法 //，由我們上面的分析知道，在mWorker.call 方法中最終會返回 result 結果result = c.call();ran = true;} catch (Throwable ex) {result = null;ran = false;setException(ex);} 復制代碼最終調用mWorker.call 方法，而在 mWorker.call 方法中，我們完成一系列的任務，調用了 doInBackground onPostExecute 完成了整個的調用過程。
有的人可能已經注意到了 還差一個 onProgressUpdate 方法還沒被調用，我們知道只有調用那個 publishProgress 方法的時候才能調用 onProgressUpdate ,那下面我們卡夏 publishProgress 方法：
@WorkerThreadprotected final void publishProgress(Progress... values) {//如果沒取消if (!isCancelled()) {//會發送一個 MESSAGE_POST_PROGRESS 的消息 getHandler().obtainMessage(MESSAGE_POST_PROGRESS,new AsyncTaskResult<Progress>(this, values)).sendToTarget();}} 復制代碼private static class InternalHandler extends Handler {public InternalHandler(Looper looper) {super(looper);}@SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})@Overridepublic void handleMessage(Message msg) {AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;switch (msg.what) {case MESSAGE_POST_RESULT:// There is only one resultresult.mTask.finish(result.mData[0]);break;case MESSAGE_POST_PROGRESS://是他是他 就是他//3. 調用了 onProgressUpdate 方法了result.mTask.onProgressUpdate(result.mData);break;}}} 復制代碼會調用 AsyncTask 的 onProgressUpdate 方法了。結束。
總結
以上是生活随笔為你收集整理的Android AsyncTask源码解读的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Openstack平台搭建（先电版）
- 下一篇： Android组件化专题 - 组件化配置