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<String, Double, Float> {
@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<Params, Progress, Result> execute(Params... params) {
return executeOnExecutor(sDefaultExecutor, params);
}
@MainThread // 主线程中执行的方法。外部也可直接调这个方法执行任务，自己传入线程池选择是串行还是并行。
public final AsyncTask<Params, Progress, Result> 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会更灵活。
