AsyncTask源码解析

AsyncTask是Android平台提供的一个多线程框架，它可以很简单的用于更新UI线程，你可以在后台执行操作，并将操作的结果Push到UI线程。同时你完全不需要去操作线程和Handler。AsyncTask与Java中的多线程框架不同，它只适合用于短小的任务（最多几秒钟）。为什么会有这样的要求？这就涉及到内存泄漏，后面我们会说。

在使用AsyncTask前，我们需要实现AsyncTask，并定义三种类型，分别是请求参数、进度参数、返回结果，其中进度参数通常用来更新进度。在AsyncTask中执行异步任务的时候，AsyncTask会依次调用onPreExecute、doInBackground、 onProgressUpdate、onPostExecute这四个回调方法，我们可以在这些回调方法中执行相关操作。

我们首先说说AsyncTask的变迁历史，在Android 1.6 开始，AsyncTask是使用线程池同时执行多个任务，但是为了避免多线程给应用程序带来的错误，从Android 3.0开始，AsyncTask默认后台只开启一个线程，这里的改变就是将默认的Executor换做了SerialExecutor。

初始化

AsyncTask中含有几个重要的静态成员变量，会在类加载的时候进行初始化：

THREAD_POOL_EXECUTOR：ThreadExecutor实例，用于执行Task。
sPoolWorkQueue：LinkedBlockingQueue<Runnable>实例，用于存放THREAD_POOL_EXECUTOR需要执行的Runable。
sDefaultExecutor：SerialExecutor实例，将Task 线性提交给ThreadExecutor执行。
sHandler：主线程的Handler，用于在主线程回调结果、界面刷新。

同时还有两个成员变量：

public AsyncTask() {
    mWorker = new WorkerRunnable<Params, Result>() {
        public Result call() throws Exception {
            ...
            Result result = doInBackground(mParams);
            ...
            return postResult(result);
        }
    };

    mFuture = new FutureTask<Result>(mWorker) {
        @Override
        protected void done() {
            try {
                postResultIfNotInvoked(get());
                ...
            } catch (CancellationException e) {
                postResultIfNotInvoked(null);
            }
        }
    };
}

mWorker：Callable接口的实现，作为Task的执行过程，在这里主要是调用doInBackground，并获取result。
mFuture：FutureTask的子类，FutureTask是RunnableFuture的子类，它接受一个Callable。其实FutureTask就是包装了Callable，并且可以对Callable进行取消操作。

Task执行

@MainThread
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) {
    ...
    mStatus = Status.RUNNING;

    onPreExecute();

    mWorker.mParams = params;
    exec.execute(mFuture);

    return this;
}

在上面的代码中我们可以看到execute方法默认使用SerialExecutor，当然我们也可以调用executeOnExecutor来使用自己的Executor。在执行Task之前会回调onPreExecute方法，然后通过Executor执行Task。

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

从上面的代码可以看出，SerialExecutor先将Task加入到一个队列中，然后通过ThreadExecutor来执行mFuture。在前面mFuture的初始化代码中，mFuture会回调doInBackground方法，然后调用postResult将运行结果发送到主线程。

由于中间通过SerialExecutor执行Task，ThreadExecutor只会创建一个线程。

private Result postResult(Result result) {
    @SuppressWarnings("unchecked")
    Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,
            new AsyncTaskResult<Result>(this, result));
    message.sendToTarget();
    return result;
}

主线程调用

在AsyncTask的说明中我们可以看到：

There are a few threading rules that must be followed for this class to work properly:

  1. The AsyncTask class must be loaded on the UI thread. This is done automatically as of JELLY_BEAN.
  2. The task instance must be created on the UI thread.
  3. execute(Params...) must be invoked on the UI thread.
  4. Do not call onPreExecute(), onPostExecute(Result), doInBackground(Params...), onProgressUpdate(Progress...) manually.
  5. The task can be executed only once (an exception will be thrown if a second execution is attempted.)

对于第一点，在JELLY_BEAN版本前，AsyncTask的加载必须在主线程执行，在JELLY_BEAN时，在ActivityThread中进行AsyncTask的类加载。

//以下是 Android JELLY_BEAN 的代码

//ActivityThread.java
public static ActivityThread systemMain() {
    HardwareRenderer.disable(true);
    ActivityThread thread = new ActivityThread();
    thread.attach(true);

    ActivityThread thread = new ActivityThread();
    thread.attach(false);

    AsyncTask.init();

    ...
 }

//AsyncTask.java
public static void init() {
    //当前在ActivityThread中，即主线程中
    sHandler.getLooper();
}

对于第二点和第三点，与UI更新有关，我们可以在源码中看到，onPreExecute，onProgressUpdate等方法都注释有@MainThread。如果我们不需要更新UI，可以在其他线程中创建AsyncTask的实例。

内存泄漏

在本文开始的时候，我们就提到AsyncTask只适合 “短小” 的任务。如果AsyncTask是Activity的内部类，就会持有Activity的引用，AsyncTask中任务时间过长，可能导致Activity不能及时回收，从而导致内存泄漏。

文章目录

初始化

Task执行

主线程调用

内存泄漏