线程池-shutdownNow

深碍√TFBOYSˉ_ 2022-07-16 10:54 267阅读 0赞

## 1.shutdownNow ##

shutdownNow和shutdown的最主要的区别是：shutdown会等待所有提交的任务执行完成，不管是正在执行还是保存在任务队列中的已提交任务。而shutdownNow会尝试中断正在执行的任务（其主要是中断一些指定方法如sleep方法），并且停止执行等待队列中提交的任务。

**中断Sleep任务**

package com.cweeyii.threadpool;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /** * Created by wenyi on 16/10/16. * Email:caowenyi@meituan.com */
    public class SleepWorker implements Runnable { 
        private static final Logger LOGGER = LoggerFactory.getLogger(SleepWorker.class);
        private String workerName;
    
    
        public String getWorkerName() {
            return workerName;
        }
    
        public void setWorkerName(String workerName) {
            this.workerName = workerName;
        }
    
        @Override
        public void run() {
            String threadName = Thread.currentThread().getName();
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            LOGGER.info("threadName={} 线程结束{}工作", threadName,workerName);
        }
    }
    
    package com.cweeyii.threadpool;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.util.List;
    import java.util.concurrent.*;
    
    /** * Created by wenyi on 16/10/16. * Email:caowenyi@meituan.com */
    public class ShutDownNowSleep { 
        private static final Logger LOGGER = LoggerFactory.getLogger(ShutDownNowSleep.class);
    
        public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
            int workerNum = 2;
            ExecutorService executorService = Executors.newFixedThreadPool(workerNum);
            for (int i = 0; i < workerNum*3; i++) {
                SleepWorker worker=new SleepWorker();
                worker.setWorkerName("worker" + i);
                executorService.submit(worker);
            }
            List<Runnable> workerList=executorService.shutdownNow();
            executorService.awaitTermination(10, TimeUnit.SECONDS);
            LOGGER.info("调用shutdown会立即返回不会等待线程池任务执行完");
            for(Runnable woker:workerList){
                FutureTask<SleepWorker> futureTask=(FutureTask<SleepWorker>)woker;
                futureTask.run();
            }
        }
    }

java.lang.InterruptedException: sleep interrupted
        at java.lang.Thread.sleep(Native Method)
        at com.cweeyii.threadpool.SleepWorker.run(SleepWorker.java:27)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
    java.lang.InterruptedException: sleep interrupted
        at java.lang.Thread.sleep(Native Method)
        at com.cweeyii.threadpool.SleepWorker.run(SleepWorker.java:27)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
    11:45:17.513  INFO (SleepWorker.java:31) - threadName=pool-1-thread-2 线程结束worker1工作
    11:45:17.513  INFO (SleepWorker.java:31) - threadName=pool-1-thread-1 线程结束worker0工作
    11:45:17.516  INFO (ShutDownNowSleep.java:26) - 调用shutdown会立即返回不会等待线程池任务执行完
    11:45:19.521  INFO (SleepWorker.java:31) - threadName=main 线程结束worker2工作
    11:45:21.525  INFO (SleepWorker.java:31) - threadName=main 线程结束worker3工作
    11:45:23.526  INFO (SleepWorker.java:31) - threadName=main 线程结束worker4工作
    11:45:25.527  INFO (SleepWorker.java:31) - threadName=main 线程结束worker5工作

**忽略等待的任务**

package com.cweeyii.threadpool;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.util.List;
    import java.util.concurrent.*;
    
    /** * Created by wenyi on 16/10/16. * Email:caowenyi@meituan.com */
    public class ShutDownNowBusy { 
        private static final Logger LOGGER = LoggerFactory.getLogger(ShutDownNowBusy.class);
    
        public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
            int workerNum = 2;
            ExecutorService executorService = Executors.newFixedThreadPool(workerNum);
            for (int i = 0; i < workerNum*3; i++) {
                BusyWorker worker=new BusyWorker();
                worker.setWorkerName("worker" + i);
                executorService.submit(worker);
            }
            List<Runnable> workerList=executorService.shutdownNow();
            executorService.awaitTermination(10, TimeUnit.SECONDS);
            LOGGER.info("调用shutdown会立即返回不会等待线程池任务执行完");
            for(Runnable woker:workerList){
                FutureTask<BusyWorker> futureTask=(FutureTask<BusyWorker>)woker;
                futureTask.run();
            }
        }
    }
    
    package com.cweeyii.threadpool;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /** * Created by wenyi on 16/10/16. * Email:caowenyi@meituan.com */
    public class BusyWorker implements Runnable { 
        private static final Logger LOGGER = LoggerFactory.getLogger(BusyWorker.class);
    
        private String workerName;
    
    
        public String getWorkerName() {
            return workerName;
        }
    
        public void setWorkerName(String workerName) {
            this.workerName = workerName;
        }
        @Override
        public void run() {
            String threadName = Thread.currentThread().getName();
            try {
                busyMethod();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            LOGGER.info("threadName={} 线程结束{}工作", threadName,workerName);
        }
    
        private void busyMethod() throws InterruptedException{
            int k=0;
            for(long i=0;i<100000L;i++){
                for(long j=0;j<100000L;j++)
                    k++;
            }
        }
    }

11:47:15.086  INFO (BusyWorker.java:31) - threadName=pool-1-thread-1 线程结束worker0工作
    11:47:15.087  INFO (BusyWorker.java:31) - threadName=pool-1-thread-2 线程结束worker1工作
    11:47:15.089  INFO (ShutDownNowBusy.java:26) - 调用shutdown会立即返回不会等待线程池任务执行完
    11:47:19.354  INFO (BusyWorker.java:31) - threadName=main 线程结束worker2工作
    11:47:23.123  INFO (BusyWorker.java:31) - threadName=main 线程结束worker3工作
    11:47:26.912  INFO (BusyWorker.java:31) - threadName=main 线程结束worker4工作
    11:47:30.907  INFO (BusyWorker.java:31) - threadName=main 线程结束worker5工作

发表评论取消回复

表情：

评论列表（有 0 条评论，267人围观）

还没有评论，来说两句吧...

相关阅读

相关线程池的shuwdown()和shutdownNow()和其他方法

本文只是总结结论,至于方法的底层代码原理,想要深入了解的话请再去百度. 线程池运行状态介绍 ThreadPoolExecutor 使用 runState (运行状态)这

偏执的太偏执、/ 2024年03月02日 10:30/ 0 赞/ 35 阅读

相关 Java 线程池、Runnable线程池、Callable线程池

线程池：其实就是一个容纳多个线程的容器，其中的线程可以反复的使用，省去了频繁创建和销毁过程对象的操作，无需反复创建线程面消耗过多资源。为什么要用线程池：合理

青旅半醒/ 2023年02月26日 12:30/ 0 赞/ 50 阅读

相关线程、线程池

目录进程进程的三种基本状态为什么不使用多进程而是使用多线程并发编

水深无声/ 2023年02月15日 10:27/ 0 赞/ 50 阅读

相关 ThreadPoolExecutor源码解读（三）——如何优雅的关闭线程池（shutdown、shutdownNow、awaitTermination）

更多JUC源码解读系列文章请持续关注[JUC源码解读文章目录JDK8][JUC_JDK8]！ -------------------- 文章目录一、前言

怼烎@/ 2022年12月18日 02:56/ 0 赞/ 210 阅读

相关 java基础总结(八十五)--线程池中shutdown()和shutdownNow()方法的区别

[原文链接][Link 1] 一般情况下，当我们频繁的使用线程的时候，为了节约资源快速响应需求，我们都会考虑使用线程池，线程池使用完毕都会想着关闭，关闭的时候一般情况下会用到

﹏ヽ暗。殇╰゛Y/ 2022年10月31日 04:23/ 0 赞/ 162 阅读

相关线程、线程池

创建线程的3种方法： package com.frank.threadPool.createThread; / @author 小石潭记

布满荆棘的人生/ 2022年10月22日 04:27/ 0 赞/ 384 阅读

相关 JAVA线程池shutdown和shutdownNow的区别

shutDown() 当线程池调用该方法时,线程池的状态则立刻变成SHUTDOWN状态。此时，则不能再往线程池中添加任何任务，否则将会抛出RejectedExecut

比眉伴天荒/ 2022年09月25日 14:22/ 0 赞/ 164 阅读

相关面试官：线程池了解吗？说说线程池中 shutdown 和 shutdownNow 的区别？

点击上方“Java基基”，选择“设为星标” 做积极的人，而不是积极废人！每天 14:00 更新文章，每天掉亿点点头发... 源码精品专栏 [原创 | Java

青旅半醒/ 2022年09月16日 14:29/ 0 赞/ 160 阅读

相关关闭线程池 shutdown 和 shutdownNow 的区别

![11ffa9be839e3e3acfca2d155892b949.png][] 程序员的成长之路互联网/程序员/技术/资料共享 [关注][Link 1] 阅读本

朱雀/ 2022年09月14日 08:55/ 0 赞/ 146 阅读

相关线程池-shutdownNow

1.shutdownNow shutdownNow和shutdown的最主要的区别是：shutdown会等待所有提交的任务执行完成，不管是正在执行还是保存在任务队列中的已

深碍√TFBOYSˉ_/ 2022年07月16日 10:54/ 0 赞/ 268 阅读