线程池简单理解，ThreadPoolExecutor,

超、凢脫俗 2023-10-10 15:56 61阅读 0赞

## 线程池 ##

线程任务–>线程–>线程通信–>线程池

**线程池的作用**

> 进程会申请资源，拿来给线程用，所以线程是非常占用系统资源的，那么我们用线程池来统一管理线程就能够很好的解决这种资源管理问题，以提高性能和速度。  
> 因为不需要创建、销毁线程，每次需要用的时候我就去线程池中调取，用完了之后再放回去，所以节省了很多资源开销，可以提高系统的运行速度。  
> 而统一的管理和调度，可以合理分配内部资源，根据系统的当前情况调整线程的数量。
> 
> 好处如下：
> 
> 1.  节省资源消耗：通过重复利用现有的线程来执行任务，避免多次创建和销毁线程。
> 2.  提高相应速度：因为省去了创建线程这个步骤，所以在拿到任务时，可以立刻开始执行。
> 3.  提供附加功能：线程池的可拓展性使得我们可以自己加入新的功能，比如说定时、延时来执行某些线程。

**执行过程**  
将线程和任务解藕，从而使线程池同时管理任务和线程。当任务提交到线程池里之后，需要经过以下流程：

![在这里插入图片描述][28e60d1dfb2b4bb69b1270c2f12f5720.png]

1.  首先它检查**核心线程池**是否已满。这个核心线程池，就是不管用户量多少线程池始终维护的线程的池子。比如说线程池的总容量最多能装 100 个线程，核心线程池我们设置为 50，那么就无论用户量有多少，都保持 50 个线程活着。这个数字当然是根据具体的业务需求来决定的。
2.  阻塞队列，就是 `BlockingQueue`
3.  最后判断线程池是否已满，就是判断是不是已经有 100 个线程了，而不是 50 个。
4.  如果已经满了，所以不能继续创建线程了，就需要按照**饱和策略**或者叫做**拒绝策略**来处理。这个饱和策略我们下文再讲。

**ThreadPoolExecutor**典型的线程池使用

指定线程构造器

构造方法：相关参数如下

public ThreadPoolExecutor(int corePoolSize, //核心线程数量
                                  int maximumPoolSize,//     最大线程数
                                  long keepAliveTime, //       最大空闲时间
                                  TimeUnit unit,         //        时间单位
                                  BlockingQueue<Runnable> workQueue,   //   任务队列
                                  ThreadFactory threadFactory,    // 线程工厂
                                  RejectedExecutionHandler handler  //  饱和处理机制
    	)

线程池实现API

package com.pan.threadpool;
    
    import java.util.concurrent.*;
    
    public class ThreadPools {
        
    
        public static void main(String[] args) {
        
            //1.创建线程池对象
            ExecutorService pool = new ThreadPoolExecutor(3,5,6,
                    TimeUnit.SECONDS,new ArrayBlockingQueue<>(5),
                    Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
            //2.给任务线程池处理，模拟
            //十几个线程，排队执行，一次三个三个地进行
            Runnable target = new MyRunnable();
            //核心线程数量只有三个，
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            pool.execute(target);
            //立即关闭，即使任务没有完成也会关闭，会丢失任务
            pool.shutdownNow();
            //等待线程执行完毕，停止。
            pool.shutdown();
    
        }
    
    }

MyRunnable ,线程任务类

package com.pan.threadpool;
    
    public class MyRunnable implements Runnable {
        
        @Override
        public void run() {
        
            //循环测试以下
            for (int i = 0;i<5;i++){
        
                System.out.println(Thread.currentThread().getName()+"输出了：hello word!"+ i);
            }
            try {
        
                System.out.println(Thread.currentThread().getName()+"本任务与线程已绑定~~");
                //休眠10秒
                Thread.sleep(10000);
            } catch (InterruptedException e) {
        
                e.printStackTrace();
            }
        }
    }

[28e60d1dfb2b4bb69b1270c2f12f5720.png]: https://img-blog.csdnimg.cn/28e60d1dfb2b4bb69b1270c2f12f5720.png