详解Java线程池的使用及工作原理

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)

ThreadFactory threadFactory = ThreadFactoryBuilder.create().setNamePrefix("myThread-").build();

// 创建线程工厂
ThreadFactory threadFactory = ThreadFactoryBuilder.create().setNamePrefix("myThread-").build();
// 创建线程池
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 10, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), threadFactory, new ThreadPoolExecutor.AbortPolicy());

// 组合值；保存了线程池的工作状态和工作线程数
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

public void execute(Runnable command) {
    	// 任务为空 抛出NPE
        if (command == null)
            throw new NullPointerException();
        // 获取线程池状态
        int c = ctl.get();
        // 如果工作线程数小于核心线程数就创建新线程
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        // 如果线程池处于Running状态，就把任务放在队列尾部
        if (isRunning(c) && workQueue.offer(command)) {
            // 重新检查线程池状态
            int recheck = ctl.get();
            // 如果线程池不是Running状态，就移除刚才添加的任务，并执行拒绝策略
            if (! isRunning(recheck) && remove(command))
                reject(command);
            // 是Running状态，就添加线程
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        // 添加任务失败，执行拒绝策略
        else if (!addWorker(command, false))
            reject(command);
    }
// addWorker()完成线程的创建