Java 线程池

为什么使用线程池?

1. 背景:经常创建和销毁,使用量特别大的资源,比如并发情况下的线程,对性能影响很大
2. 思路:提前创建好多个线程,放入线程池中,使用时直接获取,使用完放回池中,可以避免频繁创建销毁,实现重复利用,类似于生活中的单车
3. 好处:

1. 提高响应速度(减少了创建新线程的时间)
2. 降低资源消耗(重复利用线程池中的线程,不需要每次都创建)
3. 便于线程管理

1. corePoolSize:核心池的大小
2. maxmumPoolSize:最大线程数
3. keepAliveTime:线程没有任务时最多保持多长时间后终止

如何使用线程池

JDK5.0起提供了线程池相关API:ExecutorService和Executor

1. ExecutorService:真正的线程池接口:常见子类ThreadPoolExecutor

1. Void execute(Runnable command):执行任务/命令,没有返回值,一般用来执行Runnable
2. <T>Future<T> submit(Callable<T>task):执行任务,有返回值,一般又来执行Callable
3. Void shutdown():关闭线程池

2. Executor:工具类，线程池的工厂类,用于创建并返回不同类型的线程池

ExecutorService 也属于JUC(并发)下的

//newFixedThreadPool参数为线程池大小

ExecutorService executorService= Executors.newFixedThreadPool(10);

一般线程池使用步骤

1. 创建服务,创建线程池   newFixedThreadPool(10);
2. 建完线程池把线程丢进去 执行runnable接口的实现类   execute(new ThreadPool());
3. 关闭连接   shutdown();

package com.wyh.thread;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
 * @program: Thread
 * @description: 测试线程池
 * @author: 魏一鹤
 * @createDate: 2022-01-22 21:08
 **/
public class TestThreadPool {
public static void main(String[] args){
//1 创建服务,创建线程池
        //newFixedThreadPool参数为线程池大小
        ExecutorService executorService= Executors.newFixedThreadPool(10);
//2 创建完线程池把线程丢进去 执行runnable接口的实现类
        executorService.execute(new ThreadPool());
        executorService.execute(new ThreadPool());
        executorService.execute(new ThreadPool());
        executorService.execute(new ThreadPool());
        executorService.execute(new ThreadPool());
//3 关闭连接
        executorService.shutdown();
    }
}
class ThreadPool implements  Runnable{
    @Override
public void run() {
            System.out.println(Thread.currentThread().getName());
    }
}

Java通过Executors提供三种线程池，分别为：

1. newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。
2. newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
3. newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

线程池核心参数

1. corePoolSize（核心线程数）
   

（1）核心线程会一直存在，即使没有任务执行；

（2）当线程数小于核心线程数的时候，即使有空闲线程，也会一直创建线程直到达到核心线数；

（3）设置allowCoreThreadTimeout=true（默认false）时，核心线程会超时关闭。

2. queueCapacity（任务队列容量）
   

也叫阻塞队列，当核心线程都在运行，此时再有任务进来，会进入任务队列，排队等待线程执行。

3. maxPoolSize（最大线程数）
   

（1）线程池里允许存在的最大线程数量；

（2）当任务队列已满，且线程数量大于等于核心线程数时，会创建新的线程执行任务；

（3）线程池里允许存在的最大线程数量。当任务队列已满，且线程数量大于等于核心线程数时，会创建新的线程执行任务。

4. keepAliveTime（线程空闲时间）
   

（1）当线程空闲时间达到keepAliveTime时，线程会退出（关闭），直到线程数等于核心线程数；

（2）如果设置了allowCoreThreadTimeout=true，则线程会退出直到线程数等于零

5. allowCoreThreadTimeout（允许核心线程超时）
   
6. rejectedExecutionHandler（任务拒绝处理器）
   

（1）当线程数量达到最大线程数，且任务队列已满时，会拒绝任务；

（2）调用线程池shutdown()方法后，会等待执行完线程池的任务之后，再shutdown()。如果在调用了shutdown()方法和线程池真正shutdown()之间提交任务，会拒绝新任务。

线程池参数默认值

corePoolSize = 1

queueCapacity = Integer.MAX_VALUE

maxPoolSize = Integer.MAX_VALUE

keepAliveTime = 60秒

allowCoreThreadTimeout = false

rejectedExecutionHandler = AbortPolicy()