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;

    /**
    * Title: ShortTask
    * Description:
    * @date 2018/1/28 17:32
    */
    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;

    /**
    * Title: LongTask
    * Description:
    * @date 2018/1/28 17:33
    */
    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
    ......一直这样输出
    */


    英文好的可继续参考源码:


    /**
    * Returns {@code true} if this executor has been shut down.
    *
    * @return {@code true} if this executor has been shut down
    */
    boolean isShutdown();

    /**
    * Returns {@code true} if all tasks have completed following shut down.
    * Note that {@code isTerminated} is never {@code true} unless
    * either {@code shutdown} or {@code shutdownNow} was called first.
    *
    * @return {@code true} if all tasks have completed following shut down
    */
    boolean isTerminated();
    ————————————————
    版权声明:本文为CSDN博主「二十六画生的博客」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
    原文链接:https://blog.csdn.net/u010002184/article/details/79188403

  • 相关阅读:
    5分钟带你了解Kafka的技术架构
    聊聊我的知识体系
    你分得清楚Maven的聚合和继承吗?
    为抖音而生的多闪,如何获取抖音的用户数据?
    消息中间件系列第3讲:使用消息队列需要考虑的几个问题
    消息中间件系列第2讲:如何进行消息队列选型?
    消息中间件系列第1讲:为什么要用消息队列?
    JVM规范系列开篇:为什么要读JVM规范?
    安全编码实践之三:身份验证和会话管理防御
    安全编码实践之二:跨站脚本攻击防御
  • 原文地址:https://www.cnblogs.com/telwanggs/p/12372172.html
Copyright © 2011-2022 走看看