引用：(來自源碼文件)
* AsyncTask可以在UI線程中使用。它通過操作thread和handler可以執(zhí)行后臺工作并將結(jié)果發(fā)布到UI線程壳坪。
* AsyncTask被設(shè)計為圍繞Thread和Handler進行工作而不是單純的線程池框架舶得。
AsyncTask適用于最多耗時幾秒的這種短操作。
如果你想保持線程的長連接爽蝴，建議使用java.util.concurrent包提供的Executor沐批、ThreadPoolExecutor和FutureTask纫骑。
* 一個異步操作的定義是在工作線程執(zhí)行計算操作并且在主線程返回結(jié)果。
它由三個參數(shù)Params九孩、Progress和Result組成先馆。
由四個步驟onPreExecute、doInBackground躺彬、onProgressUpdate和onPostExecute組成煤墙。
* AsyncTask必須由子類繼承使用。子類至少要實現(xiàn)doInBackground方法宪拥，并且經(jīng)常會用到onPostExecute方法仿野。
下面是一個實現(xiàn)子類：
* 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");
* }
* }
* 一旦創(chuàng)建了實例，可以通過execute方法啟動她君。
* 一個異步任務(wù)要有這三類數(shù)據(jù)：
Params：發(fā)送給異步任務(wù)的參數(shù)设预。
Progress：在后臺任務(wù)計算的時候發(fā)布出來的單位進度。
Result：后臺任務(wù)執(zhí)行完畢后返回的結(jié)果犁河。
并不是每一個都要有鳖枕。可以通過使用Void來略過桨螺。
* 4個過程步驟宾符。當(dāng)一個異步任務(wù)執(zhí)行的時候會經(jīng)過這四個方法。
onPreExecute()
doInBackground
onProgressUpdate
onPostExecute
onPreExecute：任務(wù)執(zhí)行之前在UI線程調(diào)用灭翔。這個回調(diào)通常用于任務(wù)配置魏烫，比如在用戶界面顯示一個進度條。
doInBackground：onPreExecute方法執(zhí)行完畢后在后臺線程立即調(diào)用肝箱。這一步用于后臺費時計算操作哄褒。這一步會傳入之前的參數(shù)。
計算的結(jié)果必須被return返回傳遞給下一步煌张。這里也可以使用publishProgress方法發(fā)布一個或多個進度單位呐赡。這些值會被傳入UI線程的onProgressUpdate方法。
onProgressUpdate：在調(diào)用publishProgress方法后此方法在UI進程調(diào)用骏融。此方法的執(zhí)行時間是不確定的链嘀。用戶可以在后臺任務(wù)執(zhí)行時在
這個方法里隨意更新進度條。例如你能夠顯示進度動畫或者顯示進度log档玻。
onPostExecute：在后臺任務(wù)結(jié)束后怀泊，此方法在UI線程執(zhí)行。計算的結(jié)果會通過參數(shù)傳到這里误趴。
* 取消任務(wù)霹琼。
可以在任何時候調(diào)用cancel方法取消任務(wù)。調(diào)用這個方法之后，onInBackground執(zhí)行后就調(diào)用onCanceled方法而不是onPostExecute枣申。
為了確保任務(wù)能夠即使取消树灶，應(yīng)該在doInBackground中持續(xù)檢測isCancelled方法。
* 線程規(guī)則糯而。為了確保線程能夠正確運行應(yīng)該遵守下面幾個規(guī)則天通。
AsyncTask必須在UI線程中啟動。在版本16之后會自動這樣做熄驼。
任務(wù)實例必須在UI線程中創(chuàng)建像寒。
execute方法必須在UI線程中調(diào)用。
不要主動調(diào)用onPreExecute和onPostExecute方法和doInBackground和onProgressUpdate瓜贾。
一個task任務(wù)只能執(zhí)行一次诺祸，再次啟動會拋出異常。
版本4開始AsynckTasks是串行執(zhí)行的祭芦，版本11之后就改成了線程池并發(fā)執(zhí)行筷笨，
* 串行執(zhí)行可以避免一些應(yīng)用問題，如果實在想并發(fā)執(zhí)行龟劲，可以使用executeOnExecutor(Executor, Object[])方法
源碼部分：
先看源碼中所有static靜態(tài)對象
private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();
private static final int CORE_POOL_SIZE = CPU_COUNT + 1;
private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;
private static final int KEEP_ALIVE = 1;
private static final ThreadFactory sThreadFactory = new ThreadFactory() {
private final AtomicInteger mCount = new AtomicInteger(1);
public Thread newThread(Runnable r) {
return new Thread(r, "AsyncTask #" + mCount.getAndIncrement());
}
};
private static final BlockingQueue<Runnable> sPoolWorkQueue =
new LinkedBlockingQueue<Runnable>(128);
/**
* An {@link Executor} that can be used to execute tasks in parallel.
* 翻譯：并發(fā)執(zhí)行的Executor
*/
public static final Executor THREAD_POOL_EXECUTOR
= new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);
上面的靜態(tài)數(shù)據(jù)都是為了創(chuàng)建并發(fā)線程池執(zhí)行器THREAD_POOL_EXECUTOR的胃夏。
public static final Executor SERIAL_EXECUTOR = new 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();
}
}
});
if (mActive == null) {
scheduleNext();
}
}
protected synchronized void scheduleNext() {
if ((mActive = mTasks.poll()) != null) {
THREAD_POOL_EXECUTOR.execute(mActive);
}
}
}
聲明并創(chuàng)建串型線程執(zhí)行器SERIAL_EXECUTOR
@MainThread
public static void execute(Runnable runnable) {
sDefaultExecutor.execute(runnable);
}
使用默認線程執(zhí)行器執(zhí)行指定的Runnable。默認執(zhí)行器默認是串型的昌跌。該方法只能在UI線程調(diào)用仰禀。
//Handler定義為static靜態(tài)防止持有外部類導(dǎo)致內(nèi)存溢出
private static InternalHandler sHandler;
private static class InternalHandler extends Handler {
public InternalHandler() {
super(Looper.getMainLooper());
}
@SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})
@Override
public void handleMessage(Message msg) {
AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;
switch (msg.what) {
case MESSAGE_POST_RESULT:
// There is only one result
result.mTask.finish(result.mData[0]);
break;
case MESSAGE_POST_PROGRESS:
result.mTask.onProgressUpdate(result.mData);
break;
}
}
}
創(chuàng)建靜態(tài)內(nèi)部Handler對象，構(gòu)造中使用了Looper.getMainLooper()蚕愤，也就是綁定了UI線程的Looper對象答恶，所有Handler是執(zhí)行在UI線程中的，而不是當(dāng)前子線程萍诱。handleMessage方法處理兩個事件：1悬嗓、返回第一個Result結(jié)果數(shù)據(jù)。2裕坊、返回進度Progress數(shù)據(jù)包竹。兩個方法都是運行在UI線程。
/**
* @param <Params>
* @param <Result>
*
* Callable與Runanble沒有什么不同碍庵，只是Runnable沒有返回映企，Callable有返回，而且Callable只能配合ExecuotrService在線程池中使用静浴。
*/
private static abstract class WorkerRunnable<Params, Result> implements Callable<Result> {
Params[] mParams;
}
@SuppressWarnings({"RawUseOfParameterizedType"})
private static class AsyncTaskResult<Data> {
final AsyncTask mTask;
final Data[] mData;
AsyncTaskResult(AsyncTask task, Data... data) {
mTask = task;
mData = data;
}
}
聲明WorkerRunnable<Params,Result>工作線程類，繼承自Callable<Result>挤渐，Callable與Runanble沒有什么不同苹享，只是Runnable沒有返回，Callable有返回，而且Callable只能配合ExecuotrService在線程池中使用得问。
聲明AsyncTaskResult結(jié)果封裝類囤攀，封裝了一個AsyncTask對象mTask和它對應(yīng)的Data結(jié)果數(shù)組。
public AsyncTask() {
mWorker = new WorkerRunnable<Params, Result>() {
public Result call() throws Exception {
mTaskInvoked.set(true);
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
//noinspection unchecked
Result result = doInBackground(mParams);
Binder.flushPendingCommands();
return postResult(result);
}
};
mFuture = new FutureTask<Result>(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);
}
}
};
}
private Result postResult(Result result) {
@SuppressWarnings("unchecked")
Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,
new AsyncTaskResult<Result>(this, result));
message.sendToTarget();
return result;
}
AsyncTask構(gòu)造器宫纬，也是初始化的地方焚挠，會初始化一個WorkerRunnable對象，因為它繼承自Callable漓骚，所以重寫call方法蝌衔，在call方法中會執(zhí)行doInBackground()方法，也就是是線程中執(zhí)行的耗時操作蝌蹂，并調(diào)用postResult返回doInBackground的Result結(jié)果噩斟。
初始化一個FutureTask對象，F(xiàn)utureTask繼承了Runnable和Future孤个。所以可以執(zhí)行run方法也可以通過get取回結(jié)果剃允。重寫計算結(jié)束時調(diào)用的done方法，在里面調(diào)用postResultIfNotInvoked(get())齐鲤，它最后也會執(zhí)行postResult方法返回結(jié)果斥废。
postResult方法就是將當(dāng)前對象和結(jié)果封裝成AsyncTaskResult對象并發(fā)送給內(nèi)部Handler。在Handle中就會調(diào)用onPostExecute(result)方法给郊。
@WorkerThread
protected final void publishProgress(Progress... values) {
if (!isCancelled()) {
getHandler().obtainMessage(MESSAGE_POST_PROGRESS,
new AsyncTaskResult<Progress>(this, values)).sendToTarget();
}
}
@MainThread
protected void onProgressUpdate(Progress... values) {
}
在doInBackground()執(zhí)行子線程耗時任務(wù)時营袜，可以直接調(diào)用publishPorgress方法發(fā)送進度消息給內(nèi)部Handler，Handler就是執(zhí)行UI線程的onProgressUpdate方法更新進度了丑罪。
