JUC原理可视化系列之详解Executors

Coder的技术之路

发布于 2021-05-14 14:24:07

3040

发布于 2021-05-14 14:24:07

文章被收录于专栏：Coder的技术之路

JUC知识网上好多，各种源码详解,看的人是眼花缭乱，但是，看完了之后，能有印象的能有多少呢。别急，JUC可视化系列来了，用可视化的方式，简单明了的让你忘也忘不掉！

Executors工作原理图示

废话不多说，直接上，有点快，平台有限制，没办法~

是不是够清晰，够明了~

结合动画看代码

Executors包装了ThreadPoolExecutor：

 public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads,nThreads,
        0L,TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue<Runnable>());
    }

ThreadPoolExecutor的核心

private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

public void execute(Runnable command) {
        int c = ctl.get();
        //如果工作线程小于核心线程，则添加新线程
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        //如果当前可以接受新任务 && 入队列成功
        if (isRunning(c) && workQueue.offer(command)) {
            //double check，判断线程池是否可以处理任务
            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);
    }

当然，源码的注释写的可能比我更准确些，过了CET-6的同学可以自己浏览下