11.线程池使用方式

Myth丶恋晨 2023-10-08 17:31 13阅读 0赞

## 1.使用线程池的好处 ##

在没有线程池的时候，每发布一个任务就需要创建一个新的线程，这样在任务少时是没有问题的。

如果有成千上万的任务呢？

***创建线程时会产生系统开销***，并且每个线程还会占用一定的内存等资源，更重要的是我们创建如此多的线程也会给稳定性带来危害，因为每个系统中，可创建线程的数量是有一个上限的，不可能无限的创建。

***线程执行完需要被回收，大量的线程又会给垃圾回收带来压力***。但我们的任务确实非常多，如果都在主线程串行执行，那效率也太低。

线程池就是来平衡线程与系统资源之间的关系。

**所以线程池解决了：**

*  针对反复创建线程开销大的问题，线程池用一些固定的线程一直保持工作状态并反复执行任务。
 *  其次，针对过多线程占用太多内存资源的问题，解决思路更直接，线程池会根据需要创建线程，控制线程的总数量，避免占用过多内存资源。

## 2.如何使用线程池 ##

### 案例1 ###

/** 
    * cf
    * 描述：     用固定线程数的线程池执行10000个任务 
    */ 
    public class ThreadPoolDemo {
         
     
        public static void main(String[] args) {
         
            ExecutorService service = Executors.newFixedThreadPool(5);
            for (int i = 0; i < 10000; i++) {
         
                service.execute(new Task());
            } 
        System.out.println(Thread.currentThread().getName());
        } 
     
        static class Task implements Runnable {
         
     
            public void run() {
         
                System.out.println("Thread Name: " + Thread.currentThread().getName());
            } 
        } 
    }

首先创建了一个线程池，线程池中有 5 个线程，然后线程池将 10000 个任务分配给这 5 个线程，这 5 个线程反复领取任务并执行，直到所有任务执行完毕，这就是线程池的思想。

线程池不会无限制地扩张线程的数量，始终是这5个线程在工作。

所以使用线程池的好处是：

*  线程池可以解决线程生命周期的系统开销问题，同时还可以加快响应速度。
 *  线程池可以统筹内存和 CPU 的使用，避免资源使用不当。
 *  线程池可以统一管理资源。

## 3.线程池参数详解 ##

### 线程池参数 ###

**1. corePoolSize：核心线程数  
2. maxPoolSize：最大线程数  
3. keepAliveTime+时间单位：空闲线程存活时间  
4. ThreadFactory：线程工厂，用来创建新线程  
5. workQueue：用于存放任务的队列  
6. Handler：处理被拒绝的任务**

### 线程池创建线程流程 ###

![线程池创建线程流程图][acd07cdaf9bb47f480754beec9ba1d34.png]  
当提交任务后，线程池首先会检查当前线程数，如果此时线程数小于核心线程数，比如最开始线程数量为 0，则新建线程并执行任务，随着任务的不断增加，线程数会逐渐增加并达到核心线程数，此时如果仍有任务被不断提交，就会被放入 workQueue 任务队列中，等待核心线程执行完当前任务后重新从 workQueue 中提取正在等待被执行的任务。

此时，假设我们的任务特别的多，已经达到了 workQueue 的容量上限，这时线程池就会启动后备力量，也就是 maximumPoolSize 最大线程数，线程池会在 corePoolSize 核心线程数的基础上继续创建线程来执行任务，假设任务被不断提交，线程池会持续创建线程直到线程数达到 maximumPoolSize 最大线程数，如果依然有任务被提交，这就超过了线程池的最大处理能力，这个时候线程池就会拒绝这些任务，我们可以看到实际上任务进来之后，线程池会逐一判断 corePoolSize、workQueue、maximumPoolSize，如果依然不能满足需求，则会拒绝任务。

### corePoolSize 与 maximumPoolSize ###

corePoolSize 指的是核心线程数，线程池初始化时线程数默认为 0，当有新的任务提交后，会创建新线程执行任务，如果不做特殊设置，此后线程数通常不会再小于 corePoolSize ，因为它们是核心线程，即便未来可能没有可执行的任务也不会被销毁。随着任务量的增加，在任务队列满了之后，线程池会进一步创建新线程，最多可以达到 maximumPoolSize 来应对任务多的场景，如果未来线程有空闲，大于 corePoolSize 的线程会被合理回收。所以正常情况下，线程池中的线程数量会处在 corePoolSize 与 maximumPoolSize 的闭区间内。

### keepAliveTime+时间单位 ###

第三个参数是 keepAliveTime + 时间单位，当线程池中线程数量多于核心线程数时，而此时又没有任务可做，线程池就会检测线程的 keepAliveTime，如果超过规定的时间，无事可做的线程就会被销毁，以便减少内存的占用和资源消耗。

如果后期任务又多了起来，线程池也会根据规则重新创建线程，所以这是一个可伸缩的过程，比较灵活，我们也可以用 setKeepAliveTime 方法动态改变 keepAliveTime 的参数值。

### ThreadFactory ###

第四个参数是 ThreadFactory，ThreadFactory 实际上是一个线程工厂，它的作用是生产线程以便执行任务。我们可以选择使用默认的线程工厂，创建的线程都会在同一个线程组，并拥有一样的优先级，且都不是守护线程，我们也可以选择自己定制线程工厂，以方便给线程自定义命名，不同的线程池内的线程通常会根据具体业务来定制不同的线程名。

### workQueue 和 Handler ###

最后两个参数是 workQueue 和 Handler，它们分别对应阻塞队列和任务拒绝策略。  
一般我们有6中常见队列和4中拒绝策略，下一篇在总结吧~

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