一、前言
相比较于进程，创建线程 / 销毁线程 的开销是相对较小的，但是太过频繁的创建线程 / 销毁线程，其开销也很大。这时候我们就需要使用线程池来减少每次启动和销毁线程的损耗。事先把需要使用的线程先创建好，然后放到线程池中，后面需要使用的时候，直接从池里面获取，如果用完了就还给池。
二、关于变量捕获
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() { @Override public void run() { //注意这里使用的是n,而不是i System.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() { @Override public void run() { System.out.println("hello"+n); } }); } } }
