🍊一. 认识线程池
关于“池”的概念，我们接触过字符串常量池，数据库连接池，它们都被用作共享和缓存资源，通俗的将就是使用的时候直接从池子里拿，线程池也一样，在初始化的时候，就创建一定数量元素，后面需要使用线程就直接从线程池中取
我们之前使用多线程的时候都会创建线程和销毁线程，但是创建和销毁都会耗费大量资源，所以线程池的作用就是减小创建和销毁时的损耗
🍬举例形象说明线程池：
我们假设线程池为一个快递公司，里面有正式员工，但是在双11，双12因为快递量大所以有临时工，但是高峰期过后需要解雇临时工，快递都放在仓库，当仓库满了之后就不在接收快递，快递员送快递是从仓库拿快递然后送
🍉二. 原生线程池（ThreadPoolExecutor）
ThreadPoolExecutor提供了更多的参数，可以进一步细化线程池的行为
🍬ThreadPoolExecutor的构造方法：
🍬构造方法参数解析：对应上述例子来结合理解
🍃corePoolSize，核心线程数：正式员工
🍃maximumPoolSize，最大线程数：正式员工和临时员工总数
🍃keepAliveTime，空闲时间：临时工空闲（keepAliveTime,TimeUnit结合来决定何时解雇临时工）
🍃TimeUnit，空闲时间单位：空闲时间（keepAliveTime,TimeUnit结合来决定何时解雇临时工）
🍃workQueue，阻塞队列：快递仓库
🍃threadFactory：使用工厂对象提供的方法来创建线程（了解）
🍃RejectedExecutionHandler，拒绝策略：仓库满了不再接收快递
🍬拒绝策略：
🍂AbortPolicy()： 以抛出异常的方式拒绝（默认的拒绝策略）
🍂CallerRunsPolicy()： 让调用的线程来处理
🍂DiscardOldestPolicy()： 丢弃时间最久的任务（先进先出）
🍂DiscardPolicy()： 丢弃新来的任务
👁🗨️实现代码：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
//使用原生api来创建(ThreadPoolExecutor)
public class ThreadPool {
public static void main(String[] args) {
ThreadPoolExecutor pool = new ThreadPoolExecutor(
3, //线程核心数
10, //最大线程数
60, //空闲时间
TimeUnit.SECONDS, //空闲时间单位
new ArrayBlockingQueue(100), //阻塞队列
new ThreadPoolExecutor.AbortPolicy() //默认拒绝策略，抛出异常
// new ThreadPoolExecutor.CallerRunsPolicy() 让调用线程自己处理
// new ThreadPoolExecutor.DiscardOldestPolicy() 丢弃时间最久任务
// new ThreadPoolExecutor.DiscardPolicy() 丢弃新来的任务
);
//提交任务使用：submit/execute
for(int i = 0;i < 10;i++){
pool.execute(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
});
}
}
}
🍏三. ExecutorService和 Executors创建线程池
这种创建方式对应就是ThreadPoolExecutor构造参数中的threadFactory参数，使用工厂对象提供的创建方式
ExecutorService 表示一个线程池实例
Executors 是一个工厂类, 能够创建出几种不同风格的线程池
提交任务到线程池中的阻塞队列中：
🍁execute(Runnable task)
🍁submit(Runnable task)
🍁submit(Callable task)
🍬Executors创建线程池的几种方式：
☘️newFixedThreadPool：创建固定线程数的线程池
☘️newCachedThreadPool：创建线程数目动态增长的线程池
☘️newSingleThreadExecutor：创建只包含单个线程的线程池
☘️newScheduledThreadPool：创建有计划任务的线程池（带有定时器功能）
👁🗨️示例代码：
//创建有缓存的线程池
ExecutorService pool1 = Executors.newCachedThreadPool();
//创建有固定大小的线程池
ExecutorService pool2 = Executors.newFixedThreadPool(4);
//创建有计划任务的线程池
ExecutorService pool3 = Executors.newScheduledThreadPool(4);
//创建只有单个线程的线程池
ExecutorService pool4 = Executors.newSingleThreadExecutor();
👁🗨️注意：这种创建的方式在以后的工作中不建议用
🍂在工作中要阻塞队列设置大小，如果不设置大小，在某个时间会导致内存不够，出现OOM（内存溢出）
🍂拒绝策略要自己扩展实现（比如任务记录在日志或者数据库里）
🫐四. 线程池的工作流程
结合上述快递公司例子说明：
🍋五. 线程池的模拟实现
前提说明：
🍁这里阻塞队列的实现采用链表的方式阻塞
🍁我们要求线程池创建的时候，就创建线程不停的从队列中取任务来执行
🍁这里创建5个员工
👁🗨️代码实现：
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
public class MyThreadPool {
private BlockingDeque queue = new LinkedBlockingDeque();
//员工的数量
public MyThreadPool(int num){
for(int i = 0;i < num;i++){
//线程池创建的时候，就创建线程不停的从队列中取任务来执行
new Thread(new Runnable() {
@Override
public void run() {
while(true){ //不停的取任务
try {
Runnable task = queue.take(); //获取任务
task.run(); //执行任务
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();
}
}
//放任务
public void execute(Runnable task){
try {
queue.put(task);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws InterruptedException {
MyThreadPool pool = new MyThreadPool(5);
while(true){
pool.execute(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
});
Thread.sleep(1000);
}
}
}
部分打印结果：
