tomcat获取执行的线程池信息和线程堆栈的方法详解

//获取webServer线程池
ThreadPoolExecutor executor = (ThreadPoolExecutor) ((TomcatWebServer) applicationContext.getWebServer())
        .getTomcat()
        .getConnector()
        .getProtocolHandler()
        .getExecutor();
Map<String, String> returnMap = new LinkedHashMap<String, String>();
returnMap.put("核心线程数", String.valueOf(executor.getCorePoolSize()));
returnMap.put("最大线程数", String.valueOf(executor.getMaximumPoolSize()));
returnMap.put("活跃线程数", String.valueOf(executor.getActiveCount()));
returnMap.put("池中当前线程数", String.valueOf(executor.getPoolSize()));
returnMap.put("历史最大线程数", String.valueOf(executor.getLargestPoolSize()));
returnMap.put("线程允许空闲时间/s", String.valueOf(executor.getKeepAliveTime(TimeUnit.SECONDS)));
returnMap.put("核心线程数是否允许被回收", String.valueOf(executor.allowsCoreThreadTimeOut()));
returnMap.put("提交任务总数", String.valueOf(executor.getSubmittedCount()));
returnMap.put("历史执行任务的总数(近似值)", String.valueOf(executor.getTaskCount()));
returnMap.put("历史完成任务的总数(近似值)", String.valueOf(executor.getCompletedTaskCount()));
returnMap.put("工作队列任务数量", String.valueOf(executor.getQueue().size()));
returnMap.put("拒绝策略", executor.getRejectedExecutionHandler().getClass().getSimpleName());
System.out.println(returnMap);

count:18
方法2：线程池的线程：Thread[Catalina-utility-1,1,main]
方法2：线程池的线程：Thread[Catalina-utility-2,1,main]
方法2：线程池的线程：Thread[container-0,5,main]
方法2：线程池的线程：Thread[File Watcher,5,main]
方法2：线程池的线程：Thread[Live Reload Server,5,main]
-----------------名字包含了http 默认初始10个线程
-----------------Acceptor线程主要用于监听套接字，将已连接套接字转给Poller线程。
-----------------Poller线程主要用于以较少的资源轮询已连接套接字以保持连接，当数据可用时转给工作线程。
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-1,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-2,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-3,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-4,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-5,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-6,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-7,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-8,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-9,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-exec-10,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-Poller,5,main]
方法2：线程池的线程：Thread[http-nio-0.0.0.0-8089-Acceptor,5,main]
--------------------
方法2：线程池的线程：Thread[DestroyJavaVM,5,main]

Thread mainThread = Thread.currentThread();
ThreadGroup mainThreadThreadGroup = mainThread.getThreadGroup();
//获取线程组中的线程。
int count = mainThreadThreadGroup.activeCount();
System.out.println("count:"+count);
Thread[] threads = new Thread[count];
//enumerate 枚举，recurse 递归
mainThreadThreadGroup.enumerate(threads, true);
Stream.of(threads).filter(Thread::isAlive).forEach(thread -> System.out.println("方法2：线程池的线程：" + thread ));

Map<Thread, StackTraceElement[]> allThread = Thread.getAllStackTraces();
for (Thread t : allThread.keySet()) {
/**
 * 一个线程可以在给定时间点处于一个状态。 这些状态是不反映任何操作系统线程状态的虚拟机状态。
 *
 * 线程状态。 线程可以处于以下状态之一：
 * NEW              尚未启动的线程处于此状态。
 * RUNNABLE         在Java虚拟机中执行的线程处于此状态。
 * BLOCKED          被阻塞等待监视器锁定的线程处于此状态。
 * WAITING          正在等待另一个线程执行特定动作的线程处于此状态。
 * TIMED_WAITING    正在等待另一个线程执行动作达到指定等待时间的线程处于此状态。
 * TERMINATED       已退出的线程处于此状态。
 * */
    StringBuilder sb=new StringBuilder();
    if(!Thread.State.WAITING.equals(t.getState()) &&
       t.getName().indexOf("http")>-1 &&
       !Thread.currentThread().equals(t)) {
        System.out.println(t.getName()+":"+t.getState());
        sb.setLength(0);
        for (StackTraceElement ele : t.getStackTrace()) {
            sb.append(ele.getClassName()).append(".").append(ele.getMethodName()).append(".").append(ele.getFileName()).append("$").append(ele.getLineNumber()).append("\n");
        }
        System.out.println(sb.toString());
    }
}

@RequestMapping(value = "/hello")
public String testHello(Model model) throws InterruptedException {
    Thread.sleep(5000);
    model.addAttribute("currentTime", new Date());
    return "hello";
}

@RequestMapping(value = "/hello2")
public String testHello2(Model model) throws InterruptedException {
    for(int i=0;i<Integer.MAX_VALUE;i++){
        for(int j=0;j<Integer.MAX_VALUE;j++){}
    }
    model.addAttribute("currentTime", new Date());
    return "hello";
}