背景:

线程是一个开发经常使用的东西，但是实际工作中很少有新建一个线程去执行任务，线程的创建和销毁都会耗费资源，我们一般都会用线程池来完成线程的创建和销毁。

• 多说一句

JDK自带的线程池不建议大家去使用，每个都存在资源的浪费，甚至会引发OOM问题，大家都是开发，这些东西还是自己根据实际业务去创建自定义的好。

正文

• 自定义一个线程池首先我们需要知道它怎么去构建，怎么传参，参数都是什么含义，参数传多少合适，接下来一一解开疑惑。
• 我们首先看一下线程池的构造函数，分析一下里面的参数:

1. CorePoolSize(核心线程数):
   就是我们经常去处理的任务的线程数量,线程池如果没有任务处理时，它们是在空闲状态，不会被销毁，有任务时，它们会直接去处理任务，如果忙不过来就会把任务添加到阻塞队列。

2. MaximumPoolSize(最大线程数):
   上面说到核心线程来不及去处理任务，线程会放到队列中等待处理。当队列满了，没有办法继续缓存任务时，这个时候线程池会创建一个新线程去处理任务，注意:这里不是处理来的新任务，而是从队列头部拉一个出来，新任务放进去队列里面等待处理，大家都是有顺序的。
   当然这时候队列还是满的，如果任务过来还是会触发这个机制，去建新线程，这个参数就是控制可以创建的最大线程树，如果线程数量超过时，就会触发拒绝策略，下面会将。

3. keepAliveTime（最大存活时间）:
   刚才说了，如果核心线程数都忙着呢，队列也满了，我们就会创建新线程，可是如果线程都执行完任务总不能都去空闲不销毁吧。这时候肯定有一种机制去管理它们，如果空闲线程数大于核心线程数，它们多的线程最多活的时间根据这个参数来设置，到时间了，就会被销毁。

4. Unit（单位）:
   最大存活时间的单位。

5. workQueue（阻塞队列）:
   队列的作用你一定还记得，核心线程忙的时候，任务会放到队列中，JDK提供了4个队列供我们选择

   ArrayBlockingQueue: 基于数组的有边界的队列，按照先进先出排列，跟我们排队一个意思，不能插队。我们创建这个队列的时候，传一个参数就可以了，参数表示队列的容量大小。
   
   LinkedBlockingQuene: 基于链表的阻塞队列，也是采用先进先出，创建时如果构造函数不传队列容量大小时，默认大小为Integer.Max，也可以指定容量大小。
   
   
   SynchronousQueue: 不缓存任务的阻塞队列，任务来了以后不会缓存到队列中，直接创建一个新线程去处理任务。
   
   PriorityBlockingQueue: 是一个支持优先级的无界阻塞队列，直到系统资源耗尽。默认情况下元素采用自然顺序升序排列。也可以自定义类实现compareTo()方法来指定元素排序规则，或者初始化PriorityBlockingQueue时，指定构造参数Comparator来对元素进行排序。
   

6. ThreadFactory（线程工厂）:
   通过ThreadFactory的newThread方法，可以对创建的线程做一些操控，ThreadFactory是一个接口，我们需要实现它的newThread的方法，这时候我们就可以设置一些线程的参数，这个参数可不填，有默认的。

7. handler :拒绝策略:
   当队列满了时且线程数达到最大线程数时，这时候任务再来时，就会触发拒绝策略来应对接下来的任务，这时候肯定是资源不够用了，我们需要根据实际场景去选择正确的策略。JDK提供了4钟拒绝策略，我们来看一下每一个策略。
   AbortPolicy： 丢弃任务并抛出RejectedExecutionException异常。这是线程池默认的拒绝策略，在任务不能再提交的时候，抛出异常，及时反馈程序运行状态。如果是比较关键的业务，推荐使用此拒绝策略，这样子在系统不能承载更大的并发量的时候，能够及时的通过异常发现。
   DiscardPolicy： 丢弃任务，但是不抛出异常。如果线程队列已满，则后续提交的任务都会被丢弃，且是静默丢弃。
   DiscardOldestPolicy： 丢弃队列最前面的任务，新任务加到队列里面，如果有新任务过来，继续这个策略。
   CallerRunsPolicy： 如果队列满了，这个任务由调用线程去执行。

实战

public static void main(String[] args) {
	//阻塞队列
	ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue<>(200);
	//新建一个自定义线程池
	ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 50, 30, TimeUnit.SECONDS, arrayBlockingQueue);
	//循环输出数字
	for(int i =0;i<200;i++){
		int num = i;
		//submit执行方法,也可以用execute,submit具有返回值
		threadPoolExecutor.submit(new Runnable() {
			@Override
			public void run() {
				try {
					//让子弹飞一会儿
					Thread.sleep(1000);
					//输出线程名
					System.out.println(num +Thread.currentThread().getName());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
	}
	//线程池使用完一定要关闭
		threadPoolExecutor.shutdown();
	}

• 输出结果

1pool-1-thread-2
2pool-1-thread-3
3pool-1-thread-4
0pool-1-thread-1
4pool-1-thread-5
5pool-1-thread-2
7pool-1-thread-4

注意点

• 核心线程数多少合适?
  如果是计算性任务，不涉及I/O操作，使用CPU资源比较多，这时候核心线程数和CPU核数相同，
  如果是I/O比较多，比如批量下载文件，读写数据库、redis缓存，这些I/O操作用线程池就可以优化空间很大，我们把核心线程数设置为核数的double（双倍）。

• 线程池启动方法:
  示例中使用的submit方法，submit方法可以接收Runnable和Callable，Callable可以有返回值，让我们可以知道线程池的执行情况。也可以用execute执行方法，可以启动线程池但是没有返回值。

• 线程池关闭方法:
  线程池使用完，一定要关闭，这里有两个方法，shutdown()和shutdownNow()，前者是需要等待线程池执行完所有任务在关闭，后者正在执行的任务停止，没有执行的任务返回。