一、前言

相比较于进程，创建线程 / 销毁线程的开销是相对较小的，但是太过频繁的创建线程 / 销毁线程，其开销也很大。这时候我们就需要使用线程池来减少每次启动和销毁线程的损耗。事先把需要使用的线程先创建好，然后放到线程池中，后面需要使用的时候，直接从池里面获取，如果用完了就还给池。

二、关于变量捕获

 public static void main(String[] args) {ExecutorService pool = Executors.newFixedThreadPool(10);for (int i = 0; i < 1000; i++) {int n = i;pool.submit(new Runnable() {@Overridepublic void run() {//注意这里使用的是n,而不是iSystem.out.println("hello " + n);}});}}

这里for循环里面的变量 i 是主线程里的局部变量 (在主线程的栈上)，随着主线程这里的代码块执行结束就销毁了，很可能主线程这里for执行完了,当前run的任务在线程池里还没排到,此时i就已经要销毁了。这里就是一个变量捕获，很明显,此处的run方法属于Runnable。这个方法的执行时机,不是立刻马上而是在未来的某个节点(后续在线程池的队列中,排到他了,就让对应的线程去执行)。为了避免作用域的差异,导致后续执行run的时候i已经销毁,于是就有了变量捕获,也就是让run方法把刚才主线程的i给往当前run的栈上拷贝一份。

三、针对ThreadPoolExecutor的构造方法参数的解释

API文档：https://docs.oracle.com/javase/8/docs/api/

corePoolSize 核心线程数

maximumPoolSize 最大线程数

ThreadPoolExecutor相当于把里面的线程分成两类:一类是正式员工(核心线程)，一类是临时工（除核心线程外的线程），这两者之和就是最大线程数，核心线程理论上是可以摸鱼的，但是临时工不可以摸鱼，临时工摸鱼有时间限制，一旦超过了keepAliveTime规定的摸鱼时间，那么就会被销毁。

keepAliveTime，unit 除核心线程外的线程数可以休息的时间（临时工可以摸鱼的最大时间）

BlockingQueue<Runnable> workQueue 线程池的任务队列

ThreadFactory threadFactory 线程工厂，用于创建线程

RejectedExecutionHandler handler 描述了线程池的拒绝策略

拒绝策略1：ThreadPoolExecutor.AbortPolicy（如果任务队列满了，就直接抛出异常）

拒绝策略2：ThreadPoolExecutor.CallerRunsPolicy（如果队列满了，多出来的任务，是哪个线程加的，就由谁负责）

拒绝策略3：ThreadPoolExecutor.DiscardOldestPolicy（如果队列满了，就抛弃最早的任务，接受最新的任务）

拒绝策略4：ThreadPoolExecutor.DiscardPolicy（如果队列满了，就抛弃最新的任务）

四、自实现线程池

class MyThreadPoll{private BlockingQueue<Runnable> queue = new LinkedBlockingDeque<>();public MyThreadPoll(int n){//创建线程for (int i = 0; i < n; i++) {Thread t = new Thread(()->{while (true){try {Runnable runnable = queue.take();runnable.run();} catch (InterruptedException e) {e.printStackTrace();}}});t.start();}}//注册任务给线程池public void submit(Runnable runnable){try {queue.put(runnable);} catch (InterruptedException e) {e.printStackTrace();}}
}
public class ThreadDemo26 {public static void main(String[] args) {MyThreadPoll poll = new MyThreadPoll(10);for (int i = 0; i < 1000; i++) {int n = i;poll.submit(new Runnable() {@Overridepublic void run() {System.out.println("hello"+n);}});}}
}