### ?AsyncTask源碼分析及個(gè)人理解
#### ?PS.閱讀源碼是開(kāi)發(fā)者必備的能力，既然是能力那么就可以不斷培養(yǎng)翠桦，逐漸增強(qiáng)的横蜒。
#### 一：整體概括
? ? ? ?1.我們都知道AsyncTask在執(zhí)行過(guò)程中的四個(gè)常用的方法：
```java
@MainThread
protected void onPreExecute() {}
@WorkerThread
protected abstract Result doInBackground(Params... params);
@SuppressWarnings({"UnusedDeclaration"})
@MainThread
protected void onProgressUpdate(Progress... values) {}
@SuppressWarnings({"UnusedDeclaration"})
@MainThread
protected void onPostExecute(Result result) {}
```
上述的四個(gè)方法，
onPreExecute是在task執(zhí)行之前調(diào)用的销凑。
doInBackground是在執(zhí)行過(guò)程中調(diào)用丛晌，可以看到方法上標(biāo)注的執(zhí)行線程，這在工作線程中被執(zhí)行斗幼。
onProgressUpdate是在task執(zhí)行過(guò)程中澎蛛，反映執(zhí)行的進(jìn)度的。執(zhí)行的線程可以看出是在主線程中孟岛。
onPostExecute這個(gè)方法是task在執(zhí)行完耗時(shí)任務(wù)之后瓶竭，將結(jié)果回調(diào)的方法督勺，可以看出這個(gè)方法也是在主線程中被調(diào)用的。
? ? ?2.上述方法上標(biāo)注的執(zhí)行線程智哀。有主線程 也有工作線程瓷叫。在安卓開(kāi)發(fā)過(guò)程中大家都知道安卓是單線程模式，也就是說(shuō)安卓在執(zhí)行過(guò)程中是在主線程中這個(gè)線程去處理關(guān)鍵任務(wù)送巡，其他耗時(shí)操作應(yīng)該放到子線程中去做。那么咱們就分析下這些線程是如何實(shí)現(xiàn)煮寡，以及怎么調(diào)用的外臂。
在一開(kāi)始查看AsyncTask源碼時(shí)，對(duì)于頂部的實(shí)現(xiàn)就有線程池的生聲明。注意，這些聲明的變量時(shí)靜態(tài)的，也就是說(shuō)這是類共用的。
```java
//獲取當(dāng)前可用的cpu數(shù)量下梢，這里有個(gè)疑問(wèn)番电，如果正在執(zhí)行任務(wù)的時(shí)候cpu忙碌，是不是會(huì)取到0？這是個(gè)問(wèn)題
private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();
//這個(gè)就是針對(duì)上邊的這個(gè)疑問(wèn)的兜底，反正至少有2個(gè)cpu可供使用
private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT -1, 4));
private static final int MAXIMUM_POOL_SIZE =CPU_COUNT *2 +1;
private static final int KEEP_ALIVE_SECONDS =30;
//定義的線程池，真正干活就是下邊定義的線程池
public static final ExecutorTHREAD_POOL_EXECUTOR;
static {
ThreadPoolExecutor threadPoolExecutor =new ThreadPoolExecutor(
CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, TimeUnit.SECONDS,
? ? ? ? ? ? sPoolWorkQueue, sThreadFactory);
? ? threadPoolExecutor.allowCoreThreadTimeOut(true);
? ? THREAD_POOL_EXECUTOR = threadPoolExecutor;
}
//雖然這里又重新定義了Executor，但是內(nèi)部調(diào)用還是上邊聲明的THREAD_POOL_EXECUTOR，除非是單獨(dú)再設(shè)定執(zhí)行的線程池。不過(guò)一般使用很少這么用吧。
public static final ExecutorSERIAL_EXECUTOR =new SerialExecutor();
private static class SerialExecutorimplements Executor {
final ArrayDequemTasks =new ArrayDeque();
? ? RunnablemActive;
? ? public synchronized void execute(final Runnable r) {
mTasks.offer(new Runnable() {
public void run() {
try {
r.run();
? ? ? ? ? ? ? ? }finally {
scheduleNext();
? ? ? ? ? ? ? ? }
}
});
? ? ? ? if (mActive ==null) {
scheduleNext();
? ? ? ? }
}
protected synchronized void scheduleNext() {
if ((mActive =mTasks.poll()) !=null) {
THREAD_POOL_EXECUTOR.execute(mActive);
? ? ? ? }
}
}
```
好裳朋，上邊的線程池已經(jīng)定義了√韪回到上邊的問(wèn)題：如何控制是在主線程中執(zhí)行還是在子線程中執(zhí)行惭缰。我們都知道骡送，AsyncTask必須在主線程中聲明，并且必須在主線程中調(diào)用。為什么會(huì)有這樣的要求，因?yàn)閮?nèi)部實(shí)現(xiàn)使用的handler就是執(zhí)行線程中的looper,如果在子線程中執(zhí)行，會(huì)直接報(bào)錯(cuò)，因?yàn)锳syncTask已經(jīng)做了檢查。
3.準(zhǔn)備工作已經(jīng)做好了锥惋，那么去看看如何調(diào)用：
```java
//在定義一個(gè)task之后，真正調(diào)用的方式如下：
task.execut();
可以看到內(nèi)部的實(shí)現(xiàn)具體調(diào)用方法是
@MainThread
public final AsyncTaskexecuteOnExecutor(Executor exec,
? ? ? ? Params... params) {
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;
//onPreExecute（）方法已經(jīng)被調(diào)用了仍秤，因?yàn)楫?dāng)前是在主線程苇本，所以方法調(diào)用也是在主線程中的俺夕。
? ? onPreExecute();
? ? mWorker.mParams = params;
//下邊就是真正執(zhí)行任務(wù)的地方了 ?exec是excutor悬荣，執(zhí)行的參數(shù)是runnable.mFuture這個(gè)參數(shù)是在初始化的時(shí)候創(chuàng)建的嚼蚀，具體創(chuàng)建 下邊分析守谓。
? ? exec.execute(mFuture);
return this;
}
//這是創(chuàng)建AsyncTask的時(shí)候 創(chuàng)建的mFuture,可以看出平酿，他是對(duì)Runnable的包裝。
public AsyncTask(@Nullable Looper callbackLooper) {
mHandler = callbackLooper ==null || callbackLooper == Looper.getMainLooper()
?getMainHandler()
:new Handler(callbackLooper);
? ? mWorker =new WorkerRunnable() {
public Result call()throws Exception {
mTaskInvoked.set(true);
? ? ? ? ? ? Result result =null;
? ? ? ? ? ? try {
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
? ? ? ? ? ? ? ? //noinspection unchecked
? ? ? ? ? ? ? ? result = doInBackground(mParams);
? ? ? ? ? ? ? ? Binder.flushPendingCommands();
? ? ? ? ? ? }catch (Throwable tr) {
mCancelled.set(true);
? ? ? ? ? ? ? ? throw tr;
? ? ? ? ? ? }finally {
postResult(result);
? ? ? ? ? ? }
return result;
? ? ? ? }
};
? ? mFuture =new FutureTask(mWorker) {
@Override
? ? ? ? protected void done() {
try {
postResultIfNotInvoked(get());
? ? ? ? ? ? }catch (InterruptedException e) {
android.util.Log.w(LOG_TAG, e);
? ? ? ? ? ? }catch (ExecutionException e) {
throw new RuntimeException("An error occurred while executing doInBackground()",
? ? ? ? ? ? ? ? ? ? ? ? e.getCause());
? ? ? ? ? ? }catch (CancellationException e) {
postResultIfNotInvoked(null);
? ? ? ? ? ? }
}
};
可以看到 當(dāng)一個(gè)任務(wù)被放到線程池中執(zhí)行痒钝。調(diào)用的是mFuture持有的mWorker的call方法秉颗。這個(gè)方法內(nèi)部就是真正執(zhí)行耗時(shí)操作蚕甥。
public Result call()throws Exception {
mTaskInvoked.set(true);
? ? Result result =null;
? ? try {
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
? ? ? ? //noinspection unchecked
? ? ? ? result = doInBackground(mParams);
? ? ? ? Binder.flushPendingCommands();
? ? }catch (Throwable tr) {
mCancelled.set(true);
? ? ? ? throw tr;
? ? }finally {
postResult(result);
? ? }
return result;
}
可以看到doInBackground方法在此被調(diào)用爱沟。而此時(shí)線程是子線程铃辖。也就是我們常用的編寫耗時(shí)操作的地方。當(dāng)這個(gè)操作執(zhí)行完之后，回調(diào)用postResult方法碴裙，這個(gè)方法是使用handler發(fā)送一個(gè)消息，因?yàn)閔andler是在主線程中創(chuàng)建点额，所以這個(gè)handler處理消息當(dāng)然也就在主線程中了舔株。這個(gè)消息沒(méi)有直接調(diào)用onPostResult方法，而是調(diào)用了AsyncTask的finish方法珍手。這個(gè)方法如下：
private void finish(Result result) {
if (isCancelled()) {
onCancelled(result);
? ? }else {
onPostExecute(result);
? ? }
mStatus = Status.FINISHED;
}
會(huì)根據(jù)是否取消來(lái)調(diào)用對(duì)于的方法办铡。正常來(lái)講，調(diào)用onPostExecute方法琳要，將結(jié)果告知被調(diào)用放寡具。此次任務(wù)完成。
```
4.上述分析的只是一個(gè)task被執(zhí)行完成稚补。對(duì)于上述的線程池來(lái)講童叠，因?yàn)槭庆o態(tài)的，所以使用方是所有的對(duì)象共用孔厉。也就是說(shuō)創(chuàng)建多個(gè)task任務(wù)來(lái)執(zhí)行拯钻，他們會(huì)被封裝成runnable來(lái)保存在隊(duì)列中一個(gè)一個(gè)被執(zhí)行。在AsyncTask類的說(shuō)明中可以看到撰豺，這個(gè)類是在執(zhí)行小的耗時(shí)不長(zhǎng)的任務(wù)比較高效粪般，如果是計(jì)算型任務(wù)，或者是耗時(shí)長(zhǎng)的操作污桦，還是建議使用線程池來(lái)搞亩歹。
5.對(duì)于源碼分析以及個(gè)人的思考，源碼在某種程度上絕對(duì)是十分高效的。相對(duì)絕大多數(shù)的開(kāi)發(fā)者來(lái)講小作，使用源碼或者針對(duì)源碼的封裝在性能上絕對(duì)是可靠的亭姥。學(xué)習(xí)源碼可以讓我們看到設(shè)計(jì)者的思想，和他們使用技術(shù)顾稀。對(duì)于日常開(kāi)發(fā)很有幫助达罗。
