程序员必会之最详细的ThreadPoolExecutor 线程池七大参数含义
线程池的 7 大参数整理。
public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
corePoolSize 线程池中长期存活的线程数
ThreadPoolExecutor 在创建之初，是不会立即初始化corePoolSize数量的Thread的，而是通过外部request来一个一个的创建，当达到corePoolSize数目之后，就会维持至少corePoolSize数目的Thread在pool中，哪怕他们都处于空闲状态（idle）。corePoolSize >= 0。
maximumPoolSize 线程池中的最大线程数量
maximumPoolSize >= corePoolSize，maximumPoolSize>0
- 若当前线程池中线程数 < corePoolSize，则每来一个任务就创建一个线程去执行。
- 若当前线程池中线程数 >= corePoolSize，会尝试将任务添加到任务队列。如果添加成功，则任务会等待空闲线程将其取出并执行(针对的是有界队列)。
- 若队列已满，且当前线程池中线程数 < maximumPoolSize，创建新的线程。
- 若当前线程池中线程数 >= maximumPoolSize，则会采用拒绝策略。
keepAliveTime 空闲线程存活时间
当线程池线程数量超过corePoolSize时，多余的空闲线程会在多长时间内被销毁。
销毁的线程数=maximumPoolSize(最大线程数)-corePoolSize(核心线程数)。
TimeUnit 时间单位
空闲线程存活时间的描述单位，有以下选项：
- TimeUnit.DAYS：天
- TimeUnit.HOURS：小时
- TimeUnit.MINUTES：分
- TimeUnit.SECONDS：秒
- TimeUnit.MILLISECONDS：毫秒
- TimeUnit.MICROSECONDS：微妙
- TimeUnit.NANOSECONDS：纳秒
BlockingQueue
提交但未执行的任务队列，有以下选项：
- LinkedBlockingQueue：用链表实现的队列，可以是有界的，也可以是无界的，但在Executors中默认使用无界的。当有新的任务来到时，若系统的线程数小于corePoolSize，线程池会创建新的线程执行任务, 当系统的线程数量等于corePoolSize后，因为是无界的任务队列，总是能成功将任务添加到任务队列中，所以线程数量不再增加。若任务创建的速度远大于任务处理的速度，无界队列会快速增长，直到内存耗尽。
- SynchronousQueue：一个不存储元素的阻塞队列，SynchronousQueue没有容量，所以实际上提交的任务不会被添加到任务队列，总是将新任务提交给线程执行，如果没有空闲的线程，则尝试创建新的线程，如果线程数量已经达到最大值（maximumPoolSize），则执行拒绝策略。
- ArrayBlockingQueue：一个由数组结构组成的有界阻塞队列。
- PriorityBlockingQueue：一个支持优先级排序的无界阻塞队列。
- DelayQueue：一个使用优先级队列实现的无界阻塞队列，只有在延迟期满时才能从中提取元素。
- LinkedTransferQueue：一个由链表结构组成的无界阻塞队列。与SynchronousQueue类似，还含有非阻塞方法。
- LinkedBlockingDeque：一个由链表结构组成的双向阻塞队列。
ThreadFactory 创建线程的工厂
线程池创建线程时调用的工厂方法，通过此方法可以设置线程的优先级、线程命名规则以及线程类型(用户线程还是守护线程)等。一般情况下使用默认的，即Executors类的静态方法defaultThreadFactory()，也可以自定义。
import JAVA.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class Test {
public static void mAIn(String[] args) {
// 创建线程工厂
ThreadFactory threadFactory = new ThreadFactory() {
@Override
public Thread newThread(Runnable runnable) {
// 创建线程池中的线程
Thread thread = new Thread(runnable);
// 设置线程名称
thread.setName("Thread-" + runnable.hashCode());
// 设置线程优先级（最大值：10）
thread.setPriority(Thread.MAX_PRIORITY);
//......
return thread;
}
};
// 创建线程池
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
5,
10,
0L,
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(10),
threadFactory
);
try{
threadPoolExecutor.submit(new Runnable() {
@Override
public void run() {
Thread thread = Thread.currentThread();
System.out.println(String.format("线程：%s，线程优先级：%d",thread.getName(), thread.getPriority()));
}
});
}catch (Exception e) {
} finally {
threadPoolExecutor.shutdown();
}
}
}
Executors.defaultThreadFactory()
RejectedExecutionHandler
拒绝策略。当线程池的任务超出线程池队列可以存储的最大值之后，执行的策略。
- AbortPolicy策略：直接抛出异常，阻止系统正常工作。（线程池的默认策略）。
- DiscardOldestPolicy策略：丢弃任务队列中最早添加的任务，并尝试提交当前任务。
- CallerRunsPolicy策略：调用主线程执行被拒绝的任务，这提供了一种简单的反馈控制机制，将降低新任务的提交速度。
- DiscardPolicy策略：忽略并抛弃当前任务。
new一个线程池
