Android的AsyncTask异步任务浅析

实现原理

内部封装了2个线程池+1个Handler(InternalHandler)，1个线程池SerialExecutor任务排队，一个线程池THREAD_POOL_EXECUTOR执行任务。

常用重写的方法

onPreExecute：运行在主线程中，可做UI更新，显示进度条通知等。

doInBackground：在子线程执行任务，接收的参数类型为AsyncTask第一个泛型，返回给onPostExecute的参数类型为AsyncTask第三个泛型。

onProgressUpdate：运行在主线程中，doInBackground中调用publishProgress方法后即可回调到该方法中，用于UI进度更新。接收的参数类型为AsyncTask第二个泛型。

onPostExecute：运行在主线程中，doInBackground任务执行完毕后，就会回调到该方法中。

onCancelled：调用AsyncTask的cancel方法时，会回调到该方法中，内部调用Thread的interrupt方法，告诉线程池要取消任务，Thread在合适时机取消任务。

public class MyTask extends AsyncTask {

@Override // 子线程执行任务

protected Float doInBackground(String... strings) {

publishProgress(5D);

return 1f;

}

@Override // 准备执行doInBackground任务时回调

protected void onPreExecute() {

super.onPreExecute();

}

@Override // doInBackground任务执行结束后回调，接收的参数为doInBackground返回的值

protected void onPostExecute(Float aFloat) {

super.onPostExecute(aFloat);

}

@Override // doInBackground调用publishProgress会回调到该方法中

protected void onProgressUpdate(Double... values) {

super.onProgressUpdate(values);

}

@Override // 调用AsyncTask的任务关闭后回调

protected void onCancelled() {

super.onCancelled();

}

}

注意事项

Android4.1之前，AsyncTask类必须在主线程中加载。Android4.1之后，没有了这个要求，ActivityThread的main方法中自动加载了AsyncTask。

AsyncTask对象要在主线程创建，创建时，AsyncTask构造方法中，会拿到当前线程的Looper，传给new的Handler实例，以保证Handler是在主线程中。

public AsyncTask(@Nullable Looper callbackLooper) {

// 创建AsyncTask对象时，若不传外部的Handler实例，会走到这个构造中

// 拿到当前线程的Looper，传给new的Handler，则Handler在当前创建AsyncTask对象的线程中

// 因此，若要保证Handler执行环境在主线程，必须要在主线程中创建AsyncTask对象

mHandler = callbackLooper == null || callbackLooper == Looper.getMainLooper()

? getMainHandler()

: new Handler(callbackLooper);

......省略无关代码

}

AsyncTask对象的execute方法必须在主线程中调用。execute方法有@MainThread注解。

Android3.0之前AsyncTask调execute方法是并行执行任务，3.0之后增加了SerialExecutor线程池，默认选择该线程池串行执行任务，若想并行执行，则直接调executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, params)方法即可。

MyTask myTask = new MyTask();

// 默认在SerialExecutor线程池中串行执行

myTask.execute("1");

// 并行执行

myTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, "1");

一个AsyncTask对象，只能执行一次execute方法，第二次执行就会抛异常。

@MainThread // 主线程中执行的方法，默认选择SerialExecutor线程池串行执行任务

public final AsyncTask execute(Params... params) {

return executeOnExecutor(sDefaultExecutor, params);

}

@MainThread // 主线程中执行的方法。外部也可直接调这个方法执行任务，自己传入线程池选择是串行还是并行。

public final AsyncTask executeOnExecutor(Executor exec,

Params... params) {

// 一个AsyncTask对象，若多次执行execute，走到这里，会判断任务在执行中或已结束时，都将抛异常

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();

mWorker.mParams = params;

exec.execute(mFuture);

return this;

}

内存泄漏问题。采用静态的AsyncTask继承类，若要引用外部，采用弱引用。

使用多个异步操作并需要进行UI变更时，用AsyncTask会很复杂，替换Handler会更灵活。