threadPoolExecutor 中的 shutdown() 、 shutdownNow() 、 awaitTermination() 的用法和区别

客官°小女子只卖身不卖艺 2021-06-24 16:12 564阅读 0赞

最近在看并发编程，在使用到ThreadPoolExecutor时，对它的三个关闭方法（shutdown()、shutdownNow()、awaitTermination()）产生了兴趣，同时又感到迷惑。查了些资料，自己写了测试代码，总算有了个比较清晰的认识。下面一起来看看这三个方法：

# **shutdown()** #

将线程池状态置为SHUTDOWN,并不会立即停止：  
停止接收外部submit的任务  
内部正在跑的任务和队列里等待的任务，会执行完  
等到第二步完成后，才真正停止

# shutdownNow() #

将线程池状态置为STOP。企图立即停止，事实上不一定：  
跟shutdown()一样，先停止接收外部提交的任务  
忽略队列里等待的任务  
尝试将正在跑的任务interrupt中断  
返回未执行的任务列表  
它试图终止线程的方法是通过调用Thread.interrupt()方法来实现的，但是大家知道，这种方法的作用有限，如果线程中没有sleep 、wait、Condition、定时锁等应用, interrupt()方法是无法中断当前的线程的。所以，ShutdownNow()并不代表线程池就一定立即就能退出，它也可能必须要等待所有正在执行的任务都执行完成了才能退出。  
但是大多数时候是能立即退出的

# awaitTermination #

接收人timeout和TimeUnit两个参数，用于设定超时时间及单位。当等待超过设定时间时，会监测ExecutorService是否已经关闭，若关闭则返回true，否则返回false。一般情况下会和shutdown方法组合使用。

看个例子：

package com.secbro.test.thread;
    
    import java.util.concurrent.Callable;
    
    /**
     * @author zhuzhisheng
     * @Description
     * @date on 2016/6/1.
     */
    public class Task implements Callable{
        @Override
        public Object call() throws Exception {
            System.out.println("普通任务");
            return null;
        }
    }

package com.secbro.test.thread;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.TimeUnit;
    
    /**
     * @author zhuzhisheng
     * @Description
     * @date on 2016/6/1.
     */
    public class LongTask implements Callable{
        @Override
        public Object call() throws Exception {
            System.out.println("长时间任务");
            TimeUnit.SECONDS.sleep(5);
            return null;
        }
    }

package com.secbro.test.thread;
    
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    /**
     * @author zhuzhisheng
     * @Description
     * @date on 2016/6/1.
     */
    public class TestShutDown {
    
        public static void main(String[] args) throws InterruptedException{
            ScheduledExecutorService service = Executors.newScheduledThreadPool(4);
    
            service.submit(new Task());
            service.submit(new Task());
            service.submit(new LongTask());
            service.submit(new Task());
    
    
            service.shutdown();
    
            while (!service.awaitTermination(1, TimeUnit.SECONDS)) {
                System.out.println("线程池没有关闭");
            }
    
            System.out.println("线程池已经关闭");
        }
    
    }

输出：

普通任务
    普通任务
    长时间任务
    普通任务
    线程池没有关闭
    线程池没有关闭
    线程池没有关闭
    线程池没有关闭
    线程池已经关闭