【JUC系列】Executor框架之线程池执行器

JUC系列之线程池执行器

工厂类Executors

可以由工程类Executors创建不同的线程池执行器。

ThreadPoolExecutor 核心构造函数

当核心线程数量小于0时，或最大线程数量不大于0，或最大线程数小于核心线程数量，或当线程数超过corePoolSize时，线程空闲存活时长小于0时，将抛出IllegalArgumentException。

当没有任务队列，或没有线程工厂，或没有拒绝策略时，将抛出NullPointerException。

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {
        if (corePoolSize  scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)周期性执行任务，第一次执行延期时间之后，不等待第一次执行完成就会开始周期计时public ScheduledFuture scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)周期性执行任务，在第一次执行完成之后，延迟固定时长后后开始下一次执行void shutdown()尝试关闭线程池List shutdownNow()立即关闭线程池 
schedule(Runnable command, long delay, TimeUnit unit) 
通过ScheduledFutureTask的构造函数将Runnable/Callable构造为本线程池可以执行的任务类型。同时调用decorateTask方法执行用户自定义的逻辑，decorateTask是一个用户可自定义扩展的方法，默认实现下直接返回封装的RunnableScheduledFuture任务。
 
public ScheduledFuture schedule(Runnable command, long delay, TimeUnit unit) {
    if (command == null || unit == null)
        throw new NullPointerException();
    // 将Runnable转换成RunnableScheduledFuture
    RunnableScheduledFuture t = decorateTask(command, new ScheduledFutureTask(command, null, triggerTime(delay, unit)));
    // 执行任务主方法
    delayedExecute(t);
    return t;
}
 
    protected  RunnableScheduledFuture decorateTask(
        Runnable runnable, RunnableScheduledFuture task) {
        return task;
    }
 
private void delayedExecute(RunnableScheduledFuture task) {
    if (isShutdown())
        // 线程池已经关闭，采用拒绝策略
        reject(task);
    else {
        // 将RunnableScheduledFuture对象加入延迟队列
        super.getQueue().add(task);
        // 判断线程是否关闭，或者任务已经无法运行，任务已经关闭
        if (isShutdown() &&
            !canRunInCurrentRunState(task.isPeriodic()) &&
            remove(task))
            task.cancel(false);
        else
            // 启动任务
            ensurePrestart();
    }
}
 
void ensurePrestart() {
    // 计算工作线程的数量
    int wc = workerCountOf(ctl.get());
    // 若此时的工作线程的数据小于核心线程数则，新建一个核心线程，否则新建非核心线程。
    if (wc