java线程池超详细解析
java线程池超详细解析
- 一、线程池主要核心原理
- 二、线程池代码实现
- 三、自定义线程池
- 1、自定义线程池原理
- 2、自定义线程池参数
- 3、自定义线程池任务拒绝策略
- 3、代码实现
- 四、线程池多大合适呢？
一、线程池主要核心原理
- 创建一个池子，池子中是空的
- 提交任务时，池子会创建新的线程对象，任务执行完毕，线程归还给池子下回再次提交任务时，不需要创建新的线程，直接复用已有的线程即可
- 但是如果提交任务时，池子中没有空闲线程，也无法创建新的线程，任务就会排队等待
二、线程池代码实现
Executors：线程池的工具类，通过调用方法返回不同类型的线程池对象
- public static ExecutorService newCachedThreadPool(); 创建一个没有上限的线程池
- public static ExecutorService newFixedThreadPool(int nThreads); 创建有上限的线程池
具体实现步骤
1、创建线程池
2、提交任务
3、所有的任务全部执行完毕，关闭线程池
执行任务MyRunnable类
package com.hidata.devops.paas.demo;/*** @Description :* @Date: 2023-10-11 09:41*/public class MyRunnable implements Runnable {@Overridepublic void run() {System.out.println(Thread.currentThread().getName() );}}
测试类
import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/*** @Description :* @Date: 2023-10-11 09:42*/public class TestDemo {public static void main(String[] args) {//创建线程池对象ExecutorService executorService = Executors.newFixedThreadPool(3);//提交任务executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());executorService.submit(new MyRunnable());//关闭线程池(一般不会关闭)executorService.shutdown();}}
运行结果
pool-1-thread-1pool-1-thread-3pool-1-thread-2pool-1-thread-1pool-1-thread-2pool-1-thread-3pool-1-thread-2pool-1-thread-1Process finished with exit code 0
总结
- 上述代码中，我们创建的线程池，设置的最大线程数为3，当连续提交了8个任务，可以看到打印的结果，只有三个线程在轮换着执行任务，所以当任务数超过最大线程数时，线程池不会创建新的线程，而是等线程池中有空闲的线程时，会复用该空闲线程，继续执行任务，再次强调一遍：不会创建新线程，因为最大线程数为3
- 实际开发中，线程池一般不会关闭哦
三、自定义线程池
通过Executors工具类调用方法，创建线程池，不够灵活，因为很多的线程池参数都没有办法自定义。所以我们需要自定义线程池。
1、自定义线程池原理
1、创建一个空的池子
2、有任务提交时，线程池会创建线程去执行任务，执行完毕归还线程
不断地提交任务，会有以下三个临界点：
1、当核心线程满时，再提交任务就会排队
2、当核心线程满，队伍满时，会创建临时线程
3、当核心线程满，队伍满，临时线程满时，会触发任务拒绝策略
2、自定义线程池参数
3、自定义线程池任务拒绝策略
3、代码实现
package com.hidata.devops.paas.demo;/*** @Description :* @Date: 2023-10-11 09:41*/public class MyRunnable implements Runnable {@Overridepublic void run() {System.out.println(Thread.currentThread().getName() );}}package com.hidata.devops.paas.demo;import java.util.concurrent.*;/*** @Description :* @Date: 2023-10-11 09:42*/public class TestDemo {public static void main(String[] args) {ThreadPoolExecutor executor = new ThreadPoolExecutor(3,//核心线程数量，不能小于06,//最大线程数，不能小于0，最大数量>=核心线程数量60,//空闲线程最大存活时间TimeUnit.SECONDS,//时间单位new ArrayBlockingQueue<>(3),//任务队列Executors.defaultThreadFactory(),//创建线程工厂new ThreadPoolExecutor.AbortPolicy()//任务拒绝策略);executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.submit(new MyRunnable());executor.shutdown();}}
运行结果
pool-1-thread-2pool-1-thread-4pool-1-thread-3pool-1-thread-3pool-1-thread-1pool-1-thread-4pool-1-thread-2pool-1-thread-5Process finished with exit code 0
四、线程池多大合适呢？
线程池大小不能随便写的，要根据你项目的类型，一般分为两种类型的项目：
- CPU密集型项目：一般是你项目中的计算比较多，但是读取数据库或者读取本地文件操作比较少
- I/O密集型项目：读取数据库操作或者读取文件操作比较多
针对这两种类型的项目，是有一个公式的，先看一下这个复杂的公式：
我们发现公式里面出现了多个关键字：最大并行数，那怎么获取操作系统的最大并行数呢？
java底层虚拟机已经提供了获取操作系统最大并行数的方法了：
int count = Runtime.getRuntime().availableProcessors();System.out.println(count);
也可以打开你电脑的任务管理器，其中逻辑处理器就是最大并行数
心已赠人
ゞ 浴缸里的玫瑰
港控/mmm°
野性酷女
小鱼儿
还没有评论，来说两句吧...