图文并茂讲线程池
基本组成
1、线程池管理器（ThreadPool）：用于创建并管理线程池，包括 创建线程池，销毁线程池，添加新任务； 2、工作线程（PoolWorker）：线程池中线程，在没有任务时处于等待状态，可以循环的执行任务； 3、任务接口（Task）：每个任务必须实现的接口，以供工作线程调度任务的执行，它主要规定了任务的入口，任务执行完后的收尾工作，任务的执行状态等； 4、任务队列（taskQueue）：用于存放没有处理的任务。提供一种缓冲机制。
- 降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗。
- 提高响应速度。当任务到达时，任务可以不需要的等到线程创建就能立即执行。
- 提高线程的可管理性。使用线程池可以进行统一的分配，调优和监控，延时执行、定时循环执行的策略等。
java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类
构造参数
java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类
构造参数
public ThreadPoolExecutor(
int corePoolSize, //该线程池中核心线程数最大值。线程池新建线程的时候，如果当前线程总数小于corePoolSize，则新建的是核心线程，如果超过corePoolSize，则新建的是非核心线程 核心线程默认情况下会一直存活在线程池中，即使这个核心线程啥也不干(闲置状态)。如果指定ThreadPoolExecutor的allowCoreThreadTimeOut这个属性为true，那么核心线程如果不干活(闲置状态)的话，超过一定时间(时长下面参数决定)，就会被销毁掉
int maximumPoolSize,//（线程不够用时能够创建的最大线程数）线程总数 = 核心线程数 + 非核心线程数
long keepAliveTime, //非核心线程闲置超时时长
TimeUnit unit, // keepAliveTime的单位，TimeUnit是一个枚举类型
BlockingQueue<Runnable> workQueue, //任务队列：维护着等待执行的Runnable对象 当所有的核心线程都在干活时，新添加的任务会被添加到这个队列中等待处理，如果队列满了，则新建非核心线程执行任务
ThreadFactory threadFactory, //创建新线程，Executors.defaultThreadFactory()
RejectedExecutionHandler handler) //线程池的饱和策略
通过ThreadPoolExecutor.execute(Runnable command)方法即可向线程池内添加一个任务
当一个任务被添加进线程池时：
1、线程数量未达到corePoolSize，则新建一个线程(核心线程)执行任务 2、线程数量达到了corePools，则将任务移入队列BlockingQueue等待 3、如果无法将任务加入BlockingQueue（队列已满），则在非corePool中创建新的线程来处理任务（注意，执行这一步骤需要获取全局锁）。 4、队列已满，总线程数又达到了maximumPoolSize，(RejectedExecutionHandler)抛出异常
四种java实现好的线程池
CachedThreadPool()
可缓存线程池： 线程数无限制 有空闲线程则复用空闲线程，若无空闲线程则新建线程 一定程序减少频繁创建/销毁线程，减少系统开销
FixedThreadPool()
定长线程池： 可控制线程最大并发数（同时执行的线程数） 超出的线程会在队列中等待
ScheduledThreadPool()
定长线程池： 支持定时及周期性任务执行。
SingleThreadExecutor()
单线程化的线程池： 有且仅有一个工作线程执行任务 所有任务按照指定顺序执行，即遵循队列的入队出队规则
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
scheduledThreadPool.schedule(new Runnable() {
public void run() {
System.out.println("delay 3 seconds");
}
}, 3, TimeUnit.SECONDS);
}
}
线程池的状态
线程池风险：
死锁、资源不足、并发错误、 线程泄漏、请求过载
执行execute()方法和submit()方法的区别是什么呢？
- execute() 方法用于提交不需要返回值的任务，所以无法判断任务是否被线程池执行成功与否；
- submit()方法用于提交需要返回值的任务。线程池会返回一个future类型的对象，通过这个future对象可以判断任务是否执行成功，并且可以通过future的get()方法来获取返回值，get()方法会阻塞当前线程直到任务完成，而使用
get（long timeout，TimeUnit unit）方法则会阻塞当前线程一段时间后立即返回，这时候有可能任务没有执行完。
source: //490.github.io/Java多线程与并发/