线程池简洁版

骑猪看日落 2024-04-20 07:21 86阅读 0赞

⭐**简单说两句**⭐

> **作者：****后端小知识**
> 
> **CSDN**个人主页：[后端小知识][Link 1]
> 
> ?**GZH**：`后端小知识`
> 
> ?欢迎关注?点赞?收藏⭐️留言?

#### 文章目录 ####

*  一、线程池简洁版
 *   *  1.1 概念
     *  1.2 线程池的主要处理流程
     *  1.3 线程池的使用
     *   *  1.3.1 概述
         *  1.3.2 三种创建方式
         *  1.3.3 使用 ThreadPoolExecutor创建
     *  1.4 线程池的7种参数
     *  1.5 用哪一个线程池

## 一、线程池简洁版 ##

![在这里插入图片描述][57ab127aa5f74bb09bd3105011712175.png]

**每个人有自己的生活方式，每个人有自己对待感情的态度**

### 1.1 概念 ###

使用线程池的好处

*  降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的销耗。
 *  提高响应速度。当任务到达时，任务可以不需要等待线程创建就能立即执行。
 *  提高线程的可管理性。线程是稀缺资源，如果无限制的创建，不仅会销耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控。

### 1.2 线程池的主要处理流程 ###

这几张图先看一下，打个照面，等会读完再回来看下，会有意想不到的收货额

![image-20220607231717490][]

**hreadPoolExecutor执行示意图**

![image-20220607231904080][]

### 1.3 线程池的使用 ###

#### 1.3.1 概述 ####

首先，Java中的线程池是通过**Executor**框架实现的，该框架中用到了**Executor**，**Executors**，**ExecutorService**，ThreadPoolExecutor这几个类

#### 1.3.2 三种创建方式 ####

//执行长期任务性能好，创建一个线程池，一池有N个固定的线程，有固定线程数的线程
    ExecutorService threadPool = Executors.newFixedThreadPool(5); 
    //一个任务一个任务的执行，一池一线程
    ExecutorService threadPool = Executors.newSingleThreadExecutor(); 
    //执行很多短期异步任务，线程池根据需要创建新线程，
    //但在先前构建的线程可用时将重用它们。可扩容，遇强则强
    ExecutorService threadPool = Executors.newCachedThreadPool();

小案例

private static void threadPoolDemo() {
        
            ExecutorService threadPool = Executors.newFixedThreadPool(5); //一池 5 个线程
    //        ExecutorService threadPool = Executors.newSingleThreadExecutor(); //
    //        ExecutorService threadPool = Executors.newCachedThreadPool();
            // 池化技术使用后需要释放
            try {
        
                // 模拟 10个顾客办理业务，目前池子有 5个工作线程提高服务
                for (int i = 1; i <= 10; i++) {
        
                    try {
         TimeUnit.SECONDS.sleep(1); }catch (InterruptedException e){
         e.printStackTrace(); }
                    threadPool.execute(() -> {
        
                        System.out.println(Thread.currentThread().getName() + "\t 办理业务");
                    });
                    // try { TimeUnit.SECONDS.sleep(4); }catch (InterruptedException e){ e.printStackTrace(); }
                }
            }catch (Exception e){
        
                e.printStackTrace();
            }finally {
        
                threadPool.shutdown();
            }
        }

#### 1.3.3 使用 ThreadPoolExecutor创建 ####

先放代码，现在看不懂先看下面的

public static void main(String[] args) {
        
    //        threadPoolDemo();
            ExecutorService threadPool = new ThreadPoolExecutor(
                    2,
                    5,
                    2L,
                    TimeUnit.SECONDS,
                    new LinkedBlockingQueue<>(3),
                    Executors.defaultThreadFactory(),
                    new ThreadPoolExecutor.AbortPolicy()
            );
    
            try {
        
                for(int i=1;i<=8;i++){
        
    //                TimeUnit.SECONDS.sleep(1);
                    threadPool.execute(()->{
        
                        System.out.println(Thread.currentThread().getName()+"\t 办理业务");
                    });
                }
            }catch (Exception e){
        
                e.printStackTrace();
            }finally {
        
                threadPool.shutdown();
            }
        }

### 1.4 线程池的7种参数 ###

我们查阅底层源码可知ThreadPoolExecutor的构造方法有七个参数，这个参数是按照ThreadPoolExecutor里面的参数顺序来写的

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th align="center">解释</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>corePoolSize</td> 
   <td align="center"><font>线程池中的常驻核心线程数</font></td> 
  </tr> 
  <tr> 
   <td>maximumPoolSize</td> 
   <td align="center"><font>线程池中能够容纳同时执行的最大线程数</font>，此值必须大于等于1</td> 
  </tr> 
  <tr> 
   <td>keepAliveTime</td> 
   <td align="center"><font>多余的空闲线程的存活时间</font><br>当前池中线程数量超过corePoolSize时，当空闲时间<br>达到keepAliveTime时，多余线程会被销毁直到<br>只剩下corePoolSize个线程为止</td> 
  </tr> 
  <tr> 
   <td>unit</td> 
   <td align="center">keepAliveTime的单位</td> 
  </tr> 
  <tr> 
   <td>workQueue</td> 
   <td align="center">任务队列，被提交但未被执行的任务</td> 
  </tr> 
  <tr> 
   <td>threadFactory</td> 
   <td align="center">表示生成线程池中工作线程的线程工厂，用于创建线程，<font>一般默认的即可</font></td> 
  </tr> 
  <tr> 
   <td>handler</td> 
   <td align="center">拒绝策略，表示当队列满了，并且工作线程大于等于线程池的最大线程数（maximumPoolSize）时如何来拒绝请求执行的runnable的策略</td> 
  </tr> 
 </tbody> 
</table>

### 1.5 用哪一个线程池 ###

前面1.3中说了有三种创建方式，那么我们在实际开发中，用哪一个比较好呢？

答案是：**都不用**

我们只使用自定义的，原因是

![image-20220608232209882][]

图中说的方式正是我们上面1.3.3中代码

【都看到这了，点点赞点点关注呗，爱你们】??

![抽象工厂  引导关注][9ab1edb3ef4fd834353102741eb120bc.png]

**结语**

`谢谢你的阅读`，由于作者水平有限，难免有不足之处，若读者发现问题，还请批评，在留言区留言或者私信告知，我一定会尽快修改的。若各位大佬有什么好的解法，或者有意义的解法都可以在评论区展示额，万分谢谢。  
写作不易，望各位老板点点赞，加个关注!???

**作者：****后端小知识**

**CSDN**个人主页：[后端小知识][Link 1]

?**GZH**：`后端小知识`

?欢迎关注?点赞?收藏⭐️留言?

[Link 1]: https://blog.csdn.net/m0_46833224
[57ab127aa5f74bb09bd3105011712175.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/9f73a1b01d034df7b61031baf211f9ab.png
[image-20220607231717490]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/1f23a3e684f4401084401777853e94e0.png
[image-20220607231904080]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/e1a038c39a5c4ff2951c202a7da79cb9.png
[image-20220608232209882]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/9e8bf7dbeba849829733eb3eced491da.png
[9ab1edb3ef4fd834353102741eb120bc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/ac49e36c3bc347908a15f1c54dc7fc1c.png