线程池的原理和基本使用~

线程池的基本原理:

无论是之前在JavaSE基础中,我们学习过的常量池,还是在操作数据库时,我们学习过数据库连接池,以及接下来要学习的线程池,均是一种池化思想,其目的就是为了提高资源的利用率,线程池顾名思义就是对线程对象的一种优化,如果不使用线程池,那么我们对线程的操作即为手动创建线程对象执行任务任务执行完毕释放线程对象,映射到我们生活为我们每次打电话都需要买一个手机,每次打完电话就将手机扔掉,那么这样一来,无疑是非常的铺张浪费,而线程池就类似于将手机重复利用而不是每次都换新的,它能很好地提高资源的利用率并且由于线程对象是提前创建好的,因此也能够提高程序的响应速度

下面我使用日常生活中最常见的一个例子来说明线程池的原理

我们可以将海底捞作为一个线程池,那么海底捞中的桌子可以看作是线程对象,假设当前店中已经有3张空闲的桌子可以使用,此时来了4组可以需要吃饭,那么服务员会根据先后顺序先安排前3组客人进行就餐,剩下的一组客人需要进入等待区,随后来的客人都会进入等待区,但是等待区的位置也不是无穷无尽的啊,假设我们的等待区只能最多让2个用户进行等待,当前如果又来了一个客人,那么就会出现他们既没有空闲的餐桌供他们使用,等待区也没有空闲的位置,那么此时由于客人并发量太大了,海底捞的老板就会触发一种应急方案,就是在当前餐厅空旷的区域加桌子,那么等待区中的第一位客人就可以从等待区中出来了呀,刚刚没有办法处理的客人此时就可以加入等待区中,加桌子是挺好的,但是也不能无限加啊,因为餐厅可使用的地方是有限的,当达到最大值后,又来了一位客人,那么服务员只好拒绝接待该客人!

使用Java简单模拟实现线程池:

package org.example;

import java.util.concurrent.*;

public class Main {
   
    public static void main(String[] args) {
   
        //3-->表示核心的线程对象数量,也就是上述海底捞例子中没加桌子前的餐厅桌子数量
        //5-->表示最大线程对象的数量,也就是上述海底捞例子中该餐厅最多可容纳的桌子数量
        //1和后面的TimeUnit.SECONDS表示1秒钟没有任务,就可以停止工作了
        //ArrayBlockingQueue-->表示一个等待队列
        //defaultThreadFactory-->调用默认的工厂
        //AbortPolicy拒绝策略
        //ExecutorService是Java提供的线程池
        ExecutorService executorService=new ThreadPoolExecutor(3,5,1L, TimeUnit.SECONDS,new ArrayBlockingQueue<>(3), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
        for (int i=0;i<9;i++){
   
            executorService.execute(()->{
   
                System.out.println(Thread.currentThread().getName()+"办理业务");
            });
        }
        executorService.shutdown();
    }
}

输出如下所示:

当前线程池最多可容纳线程的数量为8,那么到第九个线程就会触发拒绝策略

pool-1-thread-1办理业务
pool-1-thread-5办理业务
pool-1-thread-4办理业务
pool-1-thread-3办理业务
pool-1-thread-2办理业务
pool-1-thread-4办理业务
pool-1-thread-1办理业务
pool-1-thread-5办理业务
Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task org.example.Main$$Lambda$1/1283928880@682a0b20 rejected from java.util.concurrent.ThreadPoolExecutor@3d075dc0[Running, pool size = 5, active threads = 5, queued tasks = 3, completed tasks = 0]
	at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
	at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
	at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
	at org.example.Main.main(Main.java:15)

相关推荐

  1. 线原理基本使用~

    2023-12-08 22:16:02       61 阅读
  2. 线运行原理使用案例

    2023-12-08 22:16:02       67 阅读
  3. Linux:线创建基本使用

    2023-12-08 22:16:02       32 阅读
  4. SpringBoot线使用扩展

    2023-12-08 22:16:02       33 阅读
  5. 线CountDownLatch搭配使用

    2023-12-08 22:16:02       35 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-08 22:16:02       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-08 22:16:02       100 阅读
  3. 在Django里面运行非项目文件

    2023-12-08 22:16:02       82 阅读
  4. Python语言-面向对象

    2023-12-08 22:16:02       91 阅读

热门阅读

  1. 信息学奥赛一本通1003:对齐输出

    2023-12-08 22:16:02       60 阅读
  2. IntelliJ IDEA 的 HTTP 客户端的高级用法

    2023-12-08 22:16:02       59 阅读
  3. shell_80.Linux函数的递归

    2023-12-08 22:16:02       59 阅读
  4. postgresql自带指令命令系列一

    2023-12-08 22:16:02       41 阅读
  5. 命令模式-C++实现

    2023-12-08 22:16:02       47 阅读