注：对于面试复习，只需要看文中的自定义线程池中的结论，以及Executors创建4种特定功能的线程池的方式
一：自定义线程池功能
自定义多线程类
class MyTask implements Runnable{
int num;
String name;
public MyTask(int num,String name) {
this.name=name;
this.num=num;
}
@Override
public void run() {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(num+"--"+name);
}
}
创建线程池
创建线程池，其实调用的ThreadPoolExecutor类。根据不同的参数，定义不同形式的线程池。ThreadPoolExecutor类的构造方法，有7个重要参数，分别是
corePoolSize核心线程数；
maximumPoolSize最大线程数 ；
keepAliveTime线程存活时间
TimeUnit 时间单位
BlockingQueue 阻塞对列
ThreadFactory
RejectedExecutionHandler 拒绝策略
阻塞队列有有界对列和无界对列两种
队列如果是无界队列
例如：LinkedBlockingQueue. 则最大线程数maximumPoolSize参数就没有用了。
1.1如果定义的是一个无界队列
BlockingQueue queue =new LinkedBlockingQueue();
1.2 使用ThreadPoolExecutor创建线程池执行任务
/**
*
* int corePoolSize, 核心线程数
* int maximumPoolSize, 最大线程数
* long keepAliveTime, 线程存活时间
* TimeUnit unit, 时间单位
* BlockingQueue<Runnable> workQueue 阻塞对列
* ThreadFactory threadFactory, 通过工厂创建一个线程（可以不需要）
* RejectedExecutionHandler handler 拒绝策略 （可以不需要）
*/
ThreadPoolExecutor executor =new ThreadPoolExecutor(1,2,
60,
TimeUnit.SECONDS,
queue,
Executors.defaultThreadFactory(),
handler);
MyTask t1= new MyTask(1,"成1");
MyTask t2= new MyTask(2,"成2");
MyTask t3= new MyTask(3,"成3");
MyTask t4= new MyTask(4,"成4");
MyTask t5= new MyTask(5,"成5");
MyTask t6= new MyTask(6,"成6");
MyTask t7= new MyTask(7,"成7");
executor.submit(t1);
executor.submit(t2);
executor.submit(t3);
System.out.println(queue.size());
executor.submit(t4);
executor.submit(t5);
executor.submit(t6);
executor.submit(t7);
System.out.println(queue.size());
1.3 执行结果：
2 6
1--成1
2--成2
3--成3
4--成4
5--成5
6--成6
7--成7
1.4 结论
从执行结果来看：当线程池中的阻塞对列是无界队列的话，当有任务过来执行的话，任务小于核心线程数的时候，直接使用核心线程执行任务。如果任务大于核心线程数的时候，则会将多余的任务放进阻塞对列里。
如上述代码来看：核心线程数1，最大线程数10（包含核心线程数那一个）。当来了7个任务的时候，其中会有一个任务会拿到线程去执行，其他任务会全部放入阻塞对列中进行等待。
2.1如果定义的是一个有界阻塞对列
假设有界阻塞对列的大小是1
BlockingQueue queue=new ArrayBlockingQueue(1);
2.3 执行结果
2.3.1 当任务数<=（最大线程数+有界阻塞对列的时候）执行的结果：
3--成3
1--成1
2--成2
2.3.2 当任务数>=（最大线程数+有界阻塞对列的时候）
2.3.2.1自定义的拒绝策略
RejectedExecutionHandler handler=new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("拒绝你");
}
};
2.3.2.2执行结果
3--成3
1--成1
2--成2
拒绝你
结论：首先会将一个任务给核心线程，然后开始将多余的线程放入有界阻塞对列中，当有界阻塞对列放满的时候，然后再根据最大线程数这个参数，进行分配线程，如果达到最大线程数，还有任务存在，则剩下的任务报错，或者配置了拒绝策略就执行拒绝策略
二：创建特定功能的线程池
多线程 类Executors 可以通过Executors类可以创建特定功能的线程池
Executors创建线程池的几个方法:
image.png
1.创建一个固定大小的线程池
特点：
（1）核心线程数和最大线程数相同
（2）阻塞对列是一个无界对列
//创建一个固定大小的线程池。 核心线程数用完之后，直接放入到无界对列中。如果线程很多。可以大到将无界对列撑爆炸
/**
* nThreads 核心线程数
* nThreads 最大线程数
* 0L, 存活时间
* TimeUnit.MILLISECONDS, 毫秒
* new LinkedBlockingQueue<Runnable>() 无界对列
*/
ExecutorService executorFixed = Executors.newFixedThreadPool(1);
executorFixed.submit(t1);
executorFixed.submit(t2);
executorFixed.submit(t3);
2.创建一个线程的线程池（特点和固定的相同）
## 创建只有一个线程的线程池
/**
*
* nThreads 1
* nThreads 1
* 0L, 存活时间
* TimeUnit.MILLISECONDS, 毫秒
* new LinkedBlockingQueue<Runnable>() 无界对列
*/
ExecutorService executorService = Executors.newSingleThreadExecutor();
3.创建一个可以根据实际情况调整线程个数的线程池
/**
* 0, 核心线程数0
* Integer.MAX_VALUE 最大线程数
* 60L,
* TimeUnit.SECONDS,
* new SynchronousQueue<Runnable>()
*/
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
cachedThreadPool.submit(t1);
cachedThreadPool.submit(t2);
cachedThreadPool.submit(t3);
cachedThreadPool.submit(t4);
3.1 SynchronousQueue队列
SynchronousQueue没有容量，是无缓冲等待队列，是一个不存储元素的阻塞队列，会直接将任务交给消费者，必须等队列中的添加元素被消费后才能继续添加新的元素。
参考：线程池中3种队列的区别：https://blog.csdn.net/qq_26881739/article/details/80983495
4.创建带有定时的线程池(有延迟功能)
/**
*
* corePoolSize 要保留在池中的线程数，即使他们是空闲的
* Integer.MAX_VALUE,
* 0,
* NANOSECONDS,
* new DelayedWorkQueue()
*
*/
ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(1);
scheduledExecutor.submit(t1);
scheduledExecutor.submit(t2);
scheduledExecutor.submit(t3);
scheduledExecutor.submit(t4);
for (int i = 0; i < 100; i++) {
//延迟5秒执行线程池
scheduledExecutor.schedule(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() +" time=" + (System.currentTimeMillis()));
}
}, 5, TimeUnit.SECONDS);
}
}
至此，4种创建线程池的方法记录完毕，有不足之处，欢迎大家指出。。谢谢。
image.png
