public abstract class AsyncTask<Params, Progress, Result> {
    static {
        /**
         * 自定义的线程池 : 
         * CORE_POOL_SIZE : 核心线程数 
         * MAXIMUM_POOL_SIZE : 最大线程数 
         * KEEP_ALIVE_SECONDS : 闲置时间 , 非核心线程一旦闲置超过一定时间 , 就会被回收
         * TimeUnit.SECONDS : 闲置时间单位 , 秒
         * sPoolWorkQueue : 线程队列 , 任务队列 
         * sThreadFactory : 线程工厂 , 用于生产线程 
         */  
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, TimeUnit.SECONDS,
                sPoolWorkQueue, sThreadFactory);
        threadPoolExecutor.allowCoreThreadTimeOut(true);
        THREAD_POOL_EXECUTOR = threadPoolExecutor;
    }
    
    private static class SerialExecutor implements Executor {
        protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
            	// 线程池执行任务 
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }
    }
}

public class ThreadPoolExecutor extends AbstractExecutorService {
    /**
     * 在将来的某个时间执行给定的任务. 
     * 该任务可能在一个新线程中执行, 也可能在当前线程池中已存在的线程中执行.
     * 
     * 如果任务不能被提交执行, 或该线程池失效, 或该线程池线程个数由于超过最大线程数,
     * 任务被 RejectedExecutionHandler 处理. 
     *
     * @param command 向线程池中提交的任务 
     * @throws RejectedExecutionException 如果任务不能被接受, 抛出该异常
     * @throws NullPointerException 如果任务为空, 抛出该异常 
     */
    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
        /*
         * 三个步骤:
         *
         * 1. 如果当前运行线程数小于核心线程数 , 尝试启动新线程执行该任务, 该任务是线程的第一个任务.
         * 调用 addWorker 方法会检查运行状态, 和线程运行个数, 避免在不应该添加线程时执行错误操作.
         *
         * 2. 如果任务成功加入队列, 需要双重检查 ( 进入该方法后, 线程池可能关闭 ), 
         * 在进入该方法后, 是否添加了一个线程, 或者线程池是否关闭.
         * 因此, 我们应该再次检查运行状态, 如果需要, 将任务放回队列中, 或者启动一个新线程.
         *
         * 3. 如果不能将任务入队, 尽量添加一个新线程. 
         * 如果添加失败, 此时线程池可能关闭, 或者运行线程数等于最大线程数, 需要拒绝该任务.
         */
        int c = ctl.get();
        // 当前运行的线程数 小于 核心线程数 
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        
  		// 确保处于运行状态, 然后将任务添加到队列中
        if (isRunning(c) && workQueue.offer(command)) {
            int recheck = ctl.get();
            // 如果不处于运行状态, 从队列中移除
            if (! isRunning(recheck) && remove(command))
                reject(command);	// 拒绝任务
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        // 尝试添加任务 
        else if (!addWorker(command, false))
            reject(command);
    }
}