关闭线程池-shutdown与shutdownNow的区别

Posted 2021-07-06 阿拉的梦想

关闭线程池的方式：

• 方式1：
  threadPoolExecutor.shutdownNow();//可以对线程发出中断信号，若中断后线程任务结束，则线程池关闭
• 方式2：
  //threadPoolExecutor.shutdown();//不会对线程发出中断信号，只有等所有任务结束，才关闭

代码验证：

package com.demo;

import java.util.HashSet;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
 * @Author ccl
 * @Date 2021/6/10 16:09
 */
public class OptionDemo {

    public static void main(String[] args) throws InterruptedException {
        //新建一个线程池
        final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                2,//核心线程数
                4,//最大线程数
                5,//空闲时间，仅作用于超过核心线程数的线程，当线程池空闲，会将线程数关闭至corePoolSize
                TimeUnit.SECONDS,//时间单位
                new LinkedBlockingQueue<>(10),//工作队列
                new ThreadPoolExecutor.DiscardPolicy()//拒绝策略
        );
        //使用线程池执行一个任务
        threadPoolExecutor.execute(() -> {
            while (!Thread.currentThread().isInterrupted()) {
                System.out.println("进入while");
                try {
                    Thread.sleep(3000);
                    System.out.println("时间到");
                } catch (InterruptedException e) {
                    System.out.println("被中断");
                    Thread.currentThread().interrupt();
                }
            }

        });
        Thread.sleep(2000);
        //关闭线程池，方式1：
        threadPoolExecutor.shutdownNow();//可以对线程发出中断信号，若中断后线程任务结束，则线程池关闭
        //关闭线程池，方式2：
        //threadPoolExecutor.shutdown();//不会对线程发出中断信号，只有等所有任务结束，才关闭线程池
        System.out.println("线程池isShutdown=" + threadPoolExecutor.isShutdown());
        System.out.println("线程池isTerminated=" + threadPoolExecutor.isTerminated());
        System.out.println("线程池isTerminating=" + threadPoolExecutor.isTerminating());
}

使用shutdownNow关闭线程池的日志：
可以看到isTerminated=true表示线程已经被关闭

进入while
被中断
线程池isShutdown=true
线程池isTerminated=true
线程池isTerminating=false

Process finished with exit code 0

使用shutdown关闭线程池的日志：
看到isTerminated=false表示线程没有被关闭

进入while
线程池isShutdown=true
线程池isTerminated=false
线程池isTerminating=true
时间到
进入while
时间到
进入while
省略循环日志---