zoukankan      html  css  js  c++  java
  • shutdown彻底关闭tomcat,以及多线程关闭

      最近做的一个Web项目,发现shutdown.sh后,无法关掉tomcat进程。

      ps -ef | grep tomcat

      返回tomcat进程仍然存在。经过调查发现是因为在Web应用中启动了线程池,shutdown只会关闭web线程(默认监听端口8080),关闭线程(默认监听8005);对于通过线程池(包括Executors创建的ExecutorService),只能是手动清除。使用tomcat容器的好处就在于能够包住应用的生命周期,比如解决这个问题就可以通过实现ServletContextListener里面的contextDestroyed方法,来进行手动删除。

      多线程(线程池)的关闭是几个阶段的,RUNNING->SHUTDOWN->STOPT->IDYING->TERMINATED,线程池对象提供的isShutdown()对应的就是SHUTDOWN阶段,isTerminated()对应的就是TERMINATED阶段,前者只要调用了shutdown,返回就是true,后者只有所有的线程池中的任务结束了(中断处理并退出)才会返回true。

      这意味着,所有的多线程runnable/callable的实现,如果是while(true)模式的,要对于中断异常尽心捕获,并且进行退出。

      while(true){

        try{

        ... ...

        catch (InterruptedException e) {
                    logger.warn("ResponseQueueHandler接收到中断请求,退出程序");
                    return ;
                }catch (Throwable e) {
                  ... ...
                }

      }

      很多时候我们处理异常,都会捕获并且记录下来完事,避免某个处理影响后续处理;但是对于中断异常就要退出处理,只有关闭才会向一个线程发起中断请求(如果有其他实现场景也要触发中断另说),所以只要中断,就退出。

      中断处理的机制,基于我们上面的讨论,如下:

        public static void shutdownThread(ExecutorService service, String serviceName) {
            service.shutdown();
            try {
                if (!service.isTerminated()) {
                    logger.debug("直接关闭失败{}", serviceName);
                    service.awaitTermination(3, TimeUnit.SECONDS);
                    if (service.isTerminated()) {
                        logger.debug("成功关闭{}", serviceName);
                    } else {
                        logger.debug("{}关闭失败,直接shutdownNow!", serviceName);
                        if (service.shutdownNow().size() > 0) {
                            logger.debug("最终{}没有关闭成功", serviceName);
                        } else {
                            logger.debug("shutdownNow终于成功关闭{}", serviceName);
                        }
                    }
                } else {
                    logger.debug("直接成功关闭{}", serviceName);
                }
            } catch (InterruptedException e) {
                logger.warn("接收到中断请求,{}停止操作", serviceName);
            }
        }

      我的应用在实现的时候,FixedScheduleThread,还是newCachableThread都是单独来搞的,现在回想一下,其实应该让他们都来自于同一个ExecutorService,这样,在contextDestroyed里面其实只要关闭一个executorService即可,现在是要关闭一堆。

      对于线程池的关闭(上面的代码是共通关闭线程的方式),需要额外添加一段处理:

            for (Future<String> future : this.runTaskMap.values()) {
                future.cancel(true);
            }

      将线程池中多有得Future都取消,这个过程其实就是中断线程的过程,逐个线程中断后,再对ExecutorService进行shutdown()操作即可。

      kill -9 tomcat_PID将会暴力关闭应该用,kill tomcat_PID将会优雅关闭线程,和调用线程池的shutdown效果一样。

      最后,其实可以有一种更加简单粗暴的方式,那就是在contextDestroyed里面调用exit(0)。刚开始使用的时候,担心会不会把整台机器的JVM都干掉。但是如果搞懂了JVM的原理,其实每一个运行的JAVA程序都有自己的JVM,并不会互相干扰。另外,如果你想要在exit(0)之前做些什么处理,可以为JVM添加钩子,来进行诸如关闭线程的处理:

        @Override
        public void contextInitialized(ServletContextEvent sce) {
            logger.info("新版本 2016-12-12 22:19");
       ... ...
            Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
                @Override
                public void run() {
                    ... ...
                    // ThreadManager.getInstance().shutdown();
                }
            }));
        }

      自行忽略第一行的log,用意是打出来版本号,证明运行的jar包是最新版的。

      我们上面提到的关闭线程的方式可以放置到此处来做。

  • 相关阅读:
    游戏中的View开发
    下载更新包,并且在任务栏提示进度.
    调用android非unbind的服务中的方法(不使用bindService启动的服务)
    判断android系统中Service是否在运行的方法
    如何从Activity中调用Service中的方法
    android官方文档---应用程序基础---服务的理解(app Component---services)
    怎么通过文件名的String,找到对应的资源ID
    疯狂Java之JDBC 笔记
    android应用将json数据打包在本地,进行读取的代码
    STL 堆的使用
  • 原文地址:https://www.cnblogs.com/xiashiwendao/p/6169397.html
Copyright © 2011-2022 走看看