Java并发包之ThreadPoolExecutor

Posted 2020-10-16 zwh1988

概述

　　ThreadPoolExecutor作为java.util.concurrent包对外提供基础实现，以内部线程池的形式对外提供管理任务执行，线程调度，线程池管理等等服务。

构造参数

　　corePoolSize  核心线程数。maximumPoolSize 最大线程数。keepAliveTime最大存活时间。unit时间单位。workQueue阻塞任务队列。threadFactory新建线程工厂。handler当提交任务数超过maxmumPoolSize+workQueue之和时，任务会交给RejectedExecutionHandler来处理。

　　1.当线程池小于corePoolSize时，新提交任务将创建一个新线程执行任务，即使此时线程池中存在空闲线程。

　　2.当线程池达到corePoolSize时，新提交任务将被放入workQueue中，等待线程池中任务调度执行

　　3.当workQueue已满，且maximumPoolSize>corePoolSize时，新提交任务会创建新线程执行任务

　　4.当提交任务数超过maximumPoolSize时，新提交任务由RejectedExecutionHandler处理

　　5.当线程池中超过corePoolSize线程，空闲时间达到keepAliveTime时，关闭空闲线程

　　6.当设置allowCoreThreadTimeOut(true)时，线程池中corePoolSize线程空闲时间达到keepAliveTime也将关闭

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {
        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)
            throw new IllegalArgumentException();
        if (workQueue == null || threadFactory == null || handler == null)
            throw new NullPointerException();
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = unit.toNanos(keepAliveTime);
        this.threadFactory = threadFactory;
        this.handler = handler;
    }