【并发编程七：Java中的线程池（4）-线程池规范、监控、关闭】

曾经终败给现在 2023-10-09 14:09 36阅读 0赞

【衔接上一章 [【并发编程六：Java中的线程池（3）-线程池的应用】][Java_3_-]】

#### 学习路线 ####

*   *  1.12创建线程池的方式及阿里规范
     *  1.13线程池的扩展
     *  1.14线程池的监控
     *  1.15线程池关闭
     *   *  shutdownNow()
         *  shutdown()
     *  1.16线程池是否需要关闭，怎么关闭？

### 1.12创建线程池的方式及阿里规范 ###

java.util.concurrent.Executors
    Executor, 
    ExecutorService, 
    ScheduledExecutorService,
    ThreadFactory,
    Callable的工厂和工具方法类，提供了一系列的静态工具方法

![在这里插入图片描述][3d72d6347c074a98a6b2ca74af9a3d90.png]  
![在这里插入图片描述][225776e9c5f4402fa903eef82ca39815.png]  
![在这里插入图片描述][e2643709ee8543db8d9d6be67cf49999.png]

### 1.13线程池的扩展 ###

\**线程池里面提供了几个空方法（钩子方法）：*  
\*

beforeExecute、afterExecute和terminated方法，
    可以在任务执行前、执行后和线程池关闭前执行一些代码来扩展线程池的行为

比如，任务的平均执行时间、最大执行时间和最小执行时间等，或者输出一些日志信息、发出通知等帮助我们诊断线程池运行时出现的一些问题；通过继承并覆盖线程池的这几个空方法来实现对线程池的扩展；  
代码MyThreadPoolExecutor;

import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.util.concurrent.*;
    
    /**
     * 自定义线程池对jdk线程池扩展
     *
     */
    public class MyThreadPoolExecutor extends ThreadPoolExecutor {
        
    
        private static final Logger logger = LoggerFactory.getLogger(MyThreadPoolExecutor.class);
    
        private final ThreadLocal<Long> startTimeThreadLocal = new ThreadLocal<>();
    
        public MyThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
        }
    
        public MyThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {
        
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory);
        }
    
        public MyThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) {
        
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, handler);
        }
    
        public MyThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
        
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
        }
    
        @Override
        protected void beforeExecute(Thread t, Runnable r) {
        
            super.beforeExecute(t, r);
            startTimeThreadLocal.set(System.currentTimeMillis());
            logger.info("线程-{}-任务开始执行时间：{}", t.getName() + t.getId(), startTimeThreadLocal.get());
        }
    
        @Override
        protected void afterExecute(Runnable r, Throwable t) {
        
            super.afterExecute(r, t);
            long endTime = System.currentTimeMillis();
            long executeTime = endTime - startTimeThreadLocal.get();
            logger.info("线程-{}-任务执行结束时间：{}ms", Thread.currentThread().getName() + Thread.currentThread().getId(), executeTime);
        }
    
        @Override
        protected void terminated() {
        
            super.terminated();
            startTimeThreadLocal.remove();
            logger.info("线程-{}-执行完毕退出.", Thread.currentThread().getName() + Thread.currentThread().getId());
            //TODO 发个通知
        }
    
        public static void main(String[] args) {
        
            MyThreadPoolExecutor myThreadPoolExecutor = new MyThreadPoolExecutor(
                    8,
                    16,
                    15,
                    TimeUnit.SECONDS,
                    new ArrayBlockingQueue<Runnable>(512),
                    Executors.defaultThreadFactory(),
                    new AbortPolicy());
    
            for (int i = 0; i < 5; i++) {
        
                myThreadPoolExecutor.execute(() -> {
        
                    logger.info("线程-{}-正在执行......", Thread.currentThread().getName() + Thread.currentThread().getId());
                });
            }
            //关闭线程池
            //myThreadPoolExecutor.shutdown();
        }
    }

### 1.14线程池的监控 ###

线程池在运行过程中出现问题，我们怎么能排查和定位到问题所在呢？监控！  
怎么监控？

*  1、线程池运行时埋点，每一次运行任务都进行采集统计；
 *  2、定时采集线程池的运行数据；
 *  第一种方式的监控是实时监控线程池的运行指标，对性能有一定影响；
 *  第二种方式的监控是定时采集线程池运行数据，并将监控数据持久化，便于后续查看以及用于排查问题；  
    线程池的历史运行数据的存储，可以采用时序数据库（TSDB）进行存储，可能大部分公司主要还是用MySQL、ElasticSearch等来存储；  
    监控线程池时使用到的属性：
 *  **taskCount**：线程池需要执行的任务数量；
 *  **completedTaskCount**：线程池在运行过程中已完成的任务数量，小于或等于taskCount；
 *  **largestPoolSize**：线程池里曾经创建过的最大线程数量，通过这个数据可以知道线程池是否曾经满过，如该数值等于线程池的最大大小，则表示线程池曾经满过；
 *  **poolSize**：线程池的线程数量，因为默认情况下核心线程不销毁，非核心线程在超时后自动销毁，所以最小也等于核心线程数；
 *  **activeCount**：获取活动的线程数；  
    这些数据都可以通过线程池对象给我们提供的API拿到；

### 1.15线程池关闭 ###

#### shutdownNow() ####

*  1、停止接收新的任务请求；
 *  2、将正在执行的任务interrupt中断；
 *  3、忽略任务队列里面的任务，也就是任务队列里面的任务不会执行了；
 *  4、返回没有执行的任务集合；

#### shutdown() ####

*  1、停止接收新的任务请求；
 *  2、内部正在执行的任务和任务队列中等待的任务会继续执行直至完成；
 *  3、等所有任务都执行完成后才会关闭线程池；

### 1.16线程池是否需要关闭，怎么关闭？ ###

*  1、局部线程池一定要shutdown（在代码中声明的临时线程池）；
 *  2、全局公用的线程池，不能随便shutdown；  
    ***关闭就是两个方法 shutdown() / shutdownNow()；***

**【衔接下一章[【并发编程八：线程安全问题分析及锁的介绍（1）】][1]】**

[Java_3_-]: https://blog.csdn.net/weixin_43333483/article/details/124556950?spm=1001.2014.3001.5502
[3d72d6347c074a98a6b2ca74af9a3d90.png]: https://img-blog.csdnimg.cn/3d72d6347c074a98a6b2ca74af9a3d90.png
[225776e9c5f4402fa903eef82ca39815.png]: https://img-blog.csdnimg.cn/225776e9c5f4402fa903eef82ca39815.png
[e2643709ee8543db8d9d6be67cf49999.png]: https://img-blog.csdnimg.cn/e2643709ee8543db8d9d6be67cf49999.png
[1]: https://blog.csdn.net/weixin_43333483/article/details/124557527?spm=1001.2014.3001.5502