android线程(二)AsyncTask源码分析(二)

浏览数：33 / 时间：2015年06月11日

转载请注明出处：http://blog.csdn.net/itachi85/article/details/45055365

请看这篇文章之前看一下本作的前篇http://blog.csdn.net/itachi85/article/details/45041923

3.AsyncTask中的线程池

AsyncTask中一共定义了两个线程池一个是此前我们已经介绍了线程池SerialExecutor，这个是目前我们调用AsyncTask.execute()方法默认使用的线程池，这个在前一篇文章中已经讲到过了，另一个是3.0版本之前的默认线程池THREAD_POOL_EXECUTOR。现在我们来回顾一下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();
            }
        }

这个默认的线程池同一时间只能处理一个任务，一个任务完成以后才可以执行下一个任务，相当于Executors.newSingleThreadPool()。上面的arrayDeque是一个装载Runnable的队列，如果我们一次性启动了很多个任务，在第一次运行execute()方法的时候会调用ArrayDeque的offer()方法将传入的Runnable对象添加到队列的尾部，然后判断mActive对象是不是等于null，第一次运行等于null，于是调用scheduleNext()方法。另外在finally中也调用了scheduleNext()方法，这样保证每次当一个任务执行完毕后，下一个任务才会执行。我们来看看scheduleNext()方法的源码：

  protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }

首先从runnable队列的头部取值，如果不为空就赋值给mActive对象，然后调用THREAD_POOL_EXECUTOR去执行取出的Runnable对象。THREAD_POOL_EXECUTOR源码：

  private static final int CORE_POOL_SIZE = 5;
    private static final int MAXIMUM_POOL_SIZE = 128;
    private static final int KEEP_ALIVE = 1;
...
  public static final Executor THREAD_POOL_EXECUTOR
            = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
                    TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);

这是3.0版本之前的线程池，同一时刻能够运行的线程数为5个，workQueue总大小为128。当我们启动10个任务，只有5个任务能够优先执行，其余的任务放在workQueue中，当workQueue大于128时就会调用RejectedExecutionHandler来做拒绝处理。当然在3.0之前是并没有SerialExecutor这个类的。如果不希望用默认线程池我们也可以使用这个3.0版本之前的线程池

AsyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, null);

同时3.0版本也提供了executeOnExecutor这个方法可以传入AsyncTask定义的线程池也可以传入Executor定义的4种线程池，不知道这四种线程池的可以看http://blog.csdn.net/itachi85/article/details/44874511

传入CachedThreadPool:

                LikeListTask mLikeListTask=new LikeListTask();
		mLikeListTask.executeOnExecutor(Executors.newCachedThreadPool(), null);

当然我们也可以传入自定义的线程池：

Executor exec =new ThreadPoolExecutor(0,  Integer.MAX_VALUE,     
				  0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());    
		new LikeListTask().executeOnExecutor(exec, null);