zoukankan      html  css  js  c++  java
  • Java线程池,isShutDown、isTerminated的作用与区别

    isShutDown当调用shutdown()或shutdownNow()方法后返回为true。 
    isTerminated当调用shutdown()方法后,并且所有提交的任务完成后返回为true;
    isTerminated当调用shutdownNow()方法后,成功停止后返回为true;
    如果线程池任务正常完成,都为false

    import java.util.concurrent.Callable;
     
    public class ShortTask implements Callable {
        @Override
        public Object call() throws Exception {
            System.out.println("短任务");
            return null;
        }
    }
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.TimeUnit;
     
    public class LongTask implements Callable {
        @Override
        public Object call() throws Exception {
            System.out.println("长任务");
            TimeUnit.SECONDS.sleep(5);
            return null;
        }
    }
    

      

    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
     
    public class Main {
     
        public static void main(String[] args) {
            ScheduledExecutorService service = Executors.newScheduledThreadPool(4);
            service.submit(new ShortTask());
            service.submit(new ShortTask());
            service.submit(new LongTask());
            service.submit(new ShortTask());
            System.out.println("isShutdown:" + service.isShutdown());
            System.out.println("isTerminated:" + service.isTerminated());
            service.shutdown();
    //        List<Runnable> list = service.shutdownNow();
    //        System.out.println(list.size());
            System.out.println("isShutdown:" + service.isShutdown());
            System.out.println("isTerminated:" + service.isTerminated());
            try {
                while (!service.awaitTermination(1, TimeUnit.SECONDS)) {
                    System.out.println("线程池没有关闭");
                    System.out.println("isTerminated:" + service.isTerminated());
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
     
            System.out.println("线程池已经关闭");
            System.out.println("isTerminated:" + service.isTerminated());
        }
    }
     
    

      

     
    /*
    执行service.shutdown();
    短任务
    短任务
    长任务
    短任务
    isShutdown:false
    isTerminated:false
    isShutdown:true
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池已经关闭
    isTerminated:true*/
     
    /*
    执行List<Runnable> list = service.shutdownNow();
    System.out.println(list.size());
    短任务
    短任务
    长任务
    isShutdown:false
    isTerminated:false
    1
    isShutdown:true
    isTerminated:false
    线程池已经关闭
    isTerminated:true
    */
     
    /*
    如果不执行shutdown,也不执行shutdownNow:
    短任务
    短任务
    长任务
    短任务
    isShutdown:false
    isTerminated:false
    isShutdown:false
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    线程池没有关闭
    isTerminated:false
    ......一直这样输出
    */
    

      

  • 相关阅读:
    使用Twitter异常检测框架遇到的坑
    Python从入门到精通
    Windows中几个内存相当的指标
    Windows应用程序进程级别统一监控实践
    基于时序数据的微内核预警引擎架构设计
    Flink1.4.0连接Kafka0.10.2时遇到的问题
    wait和sleep的区别
    JVM几种垃圾回收器介绍
    二叉树的非递归遍历
    段页式内存管理
  • 原文地址:https://www.cnblogs.com/felixzh/p/11840763.html
Copyright © 2011-2022 走看看