线程池(ThreadPoolExecutor)

两个好处：

1、线程可以重复利用，不用对同步任务进行不断的创建销毁

2、可以限制和管理资源，如线程

 

两个结果组成：

Set workers 表示每个正在跑的线程，在run中，先是处理第一个Task，处理完后会从workQueue中尝试拿到一个Task进行处理，如果没有，结束(keepAliveTime可以调节结束的延时)、删除这个worker

BlockingQueue<Runnable> workQueue 表示poolSize快要超出corePoolSize的时候，将对象放到阻塞队列里面去。如果阻塞队列也放不进去，继续放入workSet集合里面，如果workset超出了maximumPoolSize，就只能RejectedExecutionHandler来处理

 

 

shutdown  如果这个worker空闲了(如果线程正在跑，会有runlock锁住，然后tryLock返回false，就表示该worker不是空闲状态)，就interrupt这个worker对应的线程。(所以如果在run里面做死循环的话，可以保证不是空闲的)

shutdownNow就不tryLock，直接执行worker.thread.interrupt()

 

ThreadPoolExecutor状态

RUNNING          表示接受新任务，同时处理队列中已有的任务

SHUTDOWN(shutdown)      表示不接受新任务，但会等剩余任务(包括workqueue里面的任务)都运行完

STOP(shutdownnow)               表示不接受新任务，不处理队列中的任务，interrupt workers里面的所有线程

TERMINATE      表示所有的线程已经终止

 

Executors.newFixedThreadPool(int nThreads)

创建的时候corePoolSize和maximumPoolSize一样都是nThreads，queue为LinkedBlockingQueue。也就是说，如果workset放满了，就放到queue里面等待，如果queue也放满了(基本不会出现这种情况，没设值，默认为Integer.MAX_VALUE)，就只能RejectExecutionHandler来处理。

Executors.newCachedThreadPool()

创建的时候corePoolSize为0，maximumPoolSize为Integer.MAX_VALUE，queue为SynchronousQueue。也就是说，先将任务放入queue里面，如果workset里面的poolsize为0，会在workset里面创建一个空任务去抓取SynchronousQueue里面的等待任务。如果不为0，就等待任务workset里面的某个任务先处理完了再去抓。如果有新任务进来，先判断是否能放入queue(这里是SynchronousQueue，只能放一个)，如果不能，就直接放入workset里面。

 

两种线程池缺点：

fixedThreadPool会出现内存不可控制的情况，因为LinkedBlockingQueue没有数量限制。

cachedThreadPool更容易出现内存不可控制，因为maximumPoolSize为Integer.MAX_VALUE，很可能会创建许多线程(线程所占的内存比一个任务对象所占内存肯定大很多)。所以它适合于任务小，处理速度非常快的场景