标签：
我们知道，Android应用的主线程（UI 线程）肩负着绘制用户界面和及时响应用户操作的重任，为了避免“用户点击按钮后没反应”这样的糟糕用户体验，我们就要确保主线程时刻保持着较高的响应性。为了做到这一点，我们就要把耗时的任务移出主线程，那么耗时的任务交给谁来完成呢？答案就是工作者线程。Android开发中我们通常让主线程负责前台用户界面的绘制以及响应用户的操作，让工作者线程在后台执行一些比较耗时的任务。Android中的工作者线程主要有AsyncTask、IntentService、HandlerThread，它们本质上都是对线程或线程池的封装。关于线程和线程池相关知识的介绍，请参考这两篇博文：Java核心技术点之多线程 深入理解Java之线程池
总的来说，我们使用工作者线程是因为主线程已经有很多活要干了，累活就得交给别人干。AsyncTask是我们日常中广泛使用的一种工作者线程，它的方便之处在于可以在后台任务执行完毕时根据返回结果相应的更新UI。下面我们来研究一下它的工作原理。
AsyncTask是对Handler与线程池的封装。使用它的方便之处在于能够更新用户界面，当然这里更新用户界面的操作还是在主线程中完成的，但是由于AsyncTask内部包含一个Handler，所以可以发送消息给主线程让它更新UI。另外，AsyncTask内还包含了一个线程池。使用线程池的主要原因是避免不必要的创建及销毁线程的开销。设想下面这样一个场景：有100个只需要0.1ms就能执行完毕的任务，如果创建100个线程来执行这些任务，执行完任务的线程就进行销毁。那么创建与销毁进程的开销就很可能成为了影响性能的瓶颈。通过使用线程池，我们可以实现维护固定数量的线程，不管有多少任务，我们都始终让线程池中的线程轮番上阵，这样就避免了不必要的开销。‘
在这里简单介绍下AsyncTask的使用方法，为后文对它的工作原理的研究做铺垫，关于AsyncTask的详细介绍大家可以参考官方文档或是相关博文。
AsyncTask是一个抽象类，我们在使用时需要定义一个它的派生类并重写相关方法。AsyncTask类的声明如下：
public abstract class AsyncTask<Params, Progress, Result>
我们可以看到，AsyncTask是一个泛型类，它的三个类型参数的含义如下：
我们再来看一下AsyncTask类主要为我们提供了哪些方法：
onPreExecute() //此方法会在后台任务执行前被调用，用于进行一些准备工作 doInBackground(Params... params) //此方法中定义要执行的后台任务，在这个方法中可以调用publishProgress来更新任务进度（publishProgress内部会调用onProgressUpdate方法） onProgressUpdate(Progress... vaues) //由publishProgress内部调用，表示任务进度更新 onPostExecute(Result result) //后台任务执行完毕后，此方法会被调用，参数即为后台任务的返回结果 onCancelled() //此方法会在后台任务被取消时被调用
以上方法中，除了doInBackground方法由AsyncTask内部线程池执行外，其余方法均在主线程中执行。
AsyncTask的有点在于执行完后台任务后可以很方便的更新UI，然而使用它存在着诸多的限制。先抛开内存泄漏问题，使用AsyncTask主要存在以下局限性：
接下来，我们从源码的角度去探究一下AsyncTask的工作原理，并尝试着搞清楚为什么会存在以上局限性。
首先，让我们来看一下AsyncTask类的构造器都做了些什么：
1 public AsyncTask() { 2 mWorker = new WorkerRunnable<Params, Result>() { 3 public Result call() throws Exception { 4 mTaskInvoked.set(true); 5 6 Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND); 7 //noinspection unchecked 8 Result result = doInBackground(mParams); 9 Binder.flushPendingCommands(); 10 return postResult(result); 11 } 12 }; 13 14 mFuture = new FutureTask<Result>(mWorker) { 15 @Override 16 protected void done() { 17 try { 18 postResultIfNotInvoked(get()); 19 } catch (InterruptedException e) { 20 android.util.Log.w(LOG_TAG, e); 21 } catch (ExecutionException e) { 22 throw new RuntimeException("An error occurred while executing doInBackground()", 23 e.getCause()); 24 } catch (CancellationException e) { 25 postResultIfNotInvoked(null); 26 } 27 } 28 }; 29 }
在第2行到第12行，初始化了mWorker，它是一个派生自WorkRunnable类的对象。WorkRunnable是一个抽象类，它实现了Callable<Result>接口。我们再来看一下第4行开始的call方法的定义，首先将mTaskInvoked设为true表示当前任务已被调用过，然后在第6行设置线程的优先级。在第8行我们可以看到，调用了AsyncTask对象的doInBackground方法开始执行我们所定义的后台任务，并获取返回结果存入result中。最后将任务返回结果传递给postResult方法。关于postResult方法我们会在下文进行分析。
接下来让我们看看对mFuture的初始化。我们可以看到在构造mFuture对象时我们传入了mWorker作为参数。也就是说，mFuture是一个封装了我们的后台任务的FutureTask对象。
我们再来看一下execute方法的源码：
public final AsyncTask<Params, Progress, Result> execute(Params... params) { return executeOnExecutor(sDefaultExecutor, params); }
我们可以看到它接收的参数是Params类型的参数，这个参数会一路传递到doInBackground方法中。execute方法仅仅是调用了executeOnExecutor方法，并将executeOnExecutor方法的返回值作为自己的返回值。我们注意到，传入了sDefaultExecutor作为executeOnExecutor方法的参数，那么sDefaultExecutor是什么呢？简单的说，它是AsyncTask的默认执行器。AsyncTask可以以串行（一个接一个的执行）或并行（一并执行）两种方式来执行后台任务，在Android3.0及以后的版本中，默认的执行方式是串行。这个sDefaultExecutor就代表了默认的串行任务执行器。也就是说我们平常在AsyncTask对象上调用execute方法，使用的是串行方式来执行后台任务。
我们再来看一下executeOnExecutor方法都做了些什么：
1 public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec, 2 Params... params) { 3 if (mStatus != Status.PENDING) { 4 switch (mStatus) { 5 case RUNNING: 6 throw new IllegalStateException("Cannot execute task:" 7 + " the task is already running."); 8 case FINISHED: 9 throw new IllegalStateException("Cannot execute task:" 10 + " the task has already been executed " 11 + "(a task can be executed only once)"); 12 } 13 } 14 15 mStatus = Status.RUNNING; 16 17 onPreExecute(); 18 19 mWorker.mParams = params; 20 exec.execute(mFuture); 21 22 return this; 23 }
从以上代码的第4行到第12行我们可以知道，当AsyncTask对象的当前状态为RUNNING或FINISHED时，调用execute方法会抛出异常，这意味着不能对正在执行任务的AsyncTask对象或是已经执行完任务的AsyncTask对象调用execute方法，这也就解释了我们上面提到的局限中的最后一条。
接着我们看到第17行存在一个对onPreExecute方法的调用，这表示了在执行后台任务前确实会调用onPreExecute方法。
在第19行，把我们传入的execute方法的params参数赋值给了mWorker的mParams成员变量；而后在第20行调用了exec的execute方法，并传入了mFuture作为参数。exec就是我们传进来的sDefaultExecutor。那么接下来我们看看sDefaultExecutor就是是什么。在AsyncTask类的源码中，我们可以看到这句：
private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;
sDefaultExecutor被赋值为SERIAL_EXECUTOR，那么我们来看一下SERIAL_EXECUTOR：
public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
现在，我们知道了实际上sDefaultExecutor是一个SerialExecutor对象，我们来看一下SerialExecutor类的源码：
1 private static class SerialExecutor implements Executor { 2 final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>(); 3 Runnable mActive; 4 5 public synchronized void execute(final Runnable r) { 6 mTasks.offer(new Runnable() { 7 public void run() { 8 try { 9 r.run(); 10 } finally { 11 scheduleNext(); 12 } 13 } 14 }); 15 if (mActive == null) { 16 scheduleNext(); 17 } 18 } 19 20 protected synchronized void scheduleNext() { 21 if ((mActive = mTasks.poll()) != null) { 22 THREAD_POOL_EXECUTOR.execute(mActive); 23 } 24 } 25 }
我们来看一下execute方法的实现。mTasks代表了SerialExecutor这个串行线程池的任务缓存队列，在第6行，我们用offer方法向任务缓存队列中添加一个任务，任务的内容如第7行到第13行的run方法定义所示。我们可以看到，第9行调用了mFuture的run方法，而mFuture的run方法内部会调用mWorker的call方法。正如我们看到的那样，mWorker的call方法内调用了doInBackground方法。也就是说，最终在线程池中执行的内容是mWorker的call方法。
第15行判断mActive（当前正在执行的AsyncTask对象）是否为null，若为null，就调用scheduleNext方法。如第20行到24行所示，在scheduleNext方法中，若缓存队列非空，则调用THREAD_POOL_EXECUTOR.execute方法执行从缓存队列中取出的任务。
通过以上的分析，我们可以知道SerialExecutor所完成的工作主要是把任务加到任务缓存队列中，而真正执行任务的是THREAD_POOL_EXECUTOR。我们来看下THREAD_POOL_EXECUTOR是什么：
public static final Executor THREAD_POOL_EXECUTOR = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE, TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);
从上面的代码我们可以知道，它是一个线程池对象。根据AsyncTask的源码，我们可以获取它的各项参数如下：
1 private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors(); 2 private static final int CORE_POOL_SIZE = CPU_COUNT + 1; 3 private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1; 4 private static final int KEEP_ALIVE = 1; 5 6 private static final ThreadFactory sThreadFactory = new ThreadFactory() { 7 private final AtomicInteger mCount = new AtomicInteger(1); 8 9 public Thread newThread(Runnable r) { 10 return new Thread(r, "AsyncTask #" + mCount.getAndIncrement()); 11 } 12 }; 13 14 private static final BlockingQueue<Runnable> sPoolWorkQueue = 15 new LinkedBlockingQueue<Runnable>(128);
由以上代码我们可以知道：
现在，我们回过头来看一看之前提到的postResult方法的源码：
private Result postResult(Result result) { @SuppressWarnings("unchecked") Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT, new AsyncTaskResult<Result>(this, result)); message.sendToTarget(); return result; }
在以上源码中，先调用了getHandler方法获取AsyncTask对象内部包含的sHandler，然后通过它发送了一个MESSAGE_POST_RESULT消息。我们来看看sHandler的相关代码：
1 private static final InternalHandler sHandler = new InternalHandler(); 2 3 private static class InternalHandler extends Handler { 4 public InternalHandler() { 5 super(Looper.getMainLooper()); 6 } 7 8 @SuppressWarnings({"unchecked", "RawUseOfParameterizedType"}) 9 @Override 10 public void handleMessage(Message msg) { 11 AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj; 12 switch (msg.what) { 13 case MESSAGE_POST_RESULT: 14 // There is only one result 15 result.mTask.finish(result.mData[0]); 16 break; 17 case MESSAGE_POST_PROGRESS: 18 result.mTask.onProgressUpdate(result.mData); 19 break; 20 } 21 } 22 }
从以上代码中我们可以看到，sHandler是一个静态的Handler对象。我们知道创建Handler对象时需要当前线程的Looper，所以我们为了以后能够通过sHandler将执行环境从后台线程切换到主线程，必须在主线程中创建sHandler。这也就解释了为什么必须在主线程中加载AsyncTask类，是为了完成sHandler这个静态成员的初始化工作。
在以上代码第10行开始的handleMessage方法中，我们可以看到，当sHandler收到MESSAGE_POST_RESULT方法后，会调用finish方法，finish方法的源码如下：
1 private void finish(Result result) { 2 if (isCancelled()) { 3 onCancelled(result); 4 } else { 5 onPostExecute(result); 6 } 7 mStatus = Status.FINISHED; 8 }
在第2行，会通过调用isCancelled方法判断AsyncTask任务是否被取消，若取消了则调用onCancelled方法，否则调用onPostExecute方法；在第7行，把mStatus设为FINISHED，表示当前AsyncTask对象已经执行完毕。
经过了以上的分析，我们大概了解了AsyncTask的内部运行逻辑，知道了它默认使用串行方式执行任务。那么如何让它以并行的方式执行任务呢？ 阅读了以上的代码后，我们不难得到结论，只需调用executeOnExecutor方法，并传入THREAD_POOL_EXECUTOR作为其线程池即可。
1. Android SDK Sources
2. 《Android开发艺术探索》
标签：
原文地址：http://www.cnblogs.com/absfree/p/5357678.html
