关于java:Java线程池

1、留神异样的捕捉

线程池在应用时，在应用 ThreadPoolExecutor 时，例如
ThreadPoolExecutor.execute(new Runnable());
如果不捕获异样，那么容易造成异样的失落，例如线程池如果队列已满，并且达到了最大线程数，那么线程会拒绝执行工作，这个时候如果不去捕获 execute()的异样，则容易造成工作未实现，也没有任何异样，所以执行时能够抉择捕捉到异样。

try {ThreadPoolExecutor.execute(new Runnable());
}catch (Exception e){log.warn("executor exception:",e);
    // 弥补执行
    doCompensationWork();}

2、线程池创立形式的抉择：

当须要创立线程池时，Java 能够抉择两种创立形式

2.1 通过 Executors 创立线程池：

然而通过 Executors 创立线程池是存在危险, 起因在于：（摘自阿里编码规约）
线程池不容许应用 Executors 去创立，而是通过 ThreadPoolExecutor 的形式，这样的解决形式让写的同学更加明确线程池的运行规定，躲避资源耗尽的危险。

2.2 应用 new ThreadPoolExecutor 创立线程池创立办法：

其实 Executors 底层也是应用 ThreadPoolExecutor 进行创立的，应用 ThreadPoolExecutor 创立须要本人指定外围线程数、最大线程数、线程的闲暇时长以及阻塞队列。这样能够依照理论应用场景设定须要的外围线程以及队列大小，避免出现内存占用过多或者线程过多造成的 OOM 危险，所以优先应用 ThreadPoolExecutor 创立线程池。

3 Executors 各个办法的弊病的起因

3.1 newFixedThreadPool 和 newSingleThreadExecutor:

次要问题是沉积的申请解决队列可能会消耗十分大的内存，甚至 OOM。
查看其源码能够看到 newFixedThreadPool、newSingleThreadExecutor 都是应用 LinkedBlockingQueue 作为线程池的队列，这样外围线程都占满后，工作会存储到队列，这样就可能导致队列存储了多个工作，造成内存透露甚至 OOM 的危险。

3.2 newCachedThreadPool 和 newScheduledThreadPool:

次要问题是线程数最大数是 Integer.MAX_VALUE，可能会创立数量十分多的线程，甚至 OOM。

4、ThreadPoolExecutor 参数解析：

1、corePoolSize & maximumPoolSize 外围线程数（corePoolSize）和最大线程数（maximumPoolSize）

当一个新工作被提交到池中，如果以后运行线程小于外围线程数（corePoolSize），即便以后有闲暇线程，也会新建一个线程来解决新提交的工作；如果以后运行线程数大于外围线程数（corePoolSize）并小于最大线程数（maximumPoolSize），只有当期待队列已满的状况下才会新建线程，即大于外围线程时，优先放在队列，队列已满才会去创立新的线程，直至达到最大线程，这时再来工作，则执行设定的回绝策略；

2、keepAliveTime & unitkeepAliveTime

为超过 corePoolSize 线程数量的线程最大闲暇工夫，unit 为工夫单位。非核心线程的最大闲暇工夫；

3、期待队列任何阻塞队列（BlockingQueue）

都能够用来转移或保留提交的工作，线程池大小和阻塞队列互相束缚线程池：如果运行线程数小于 corePoolSize，提交新工作时就会新建一个线程来运行；如果运行线程数大于或等 corePoolSize，新提交的工作就会入列期待；如果队列已满，并且运行线程数小于 maximumPoolSize，也将会新建一个线程来运行；如果线程数大于 maximumPoolSize，新提交的工作将会依据回绝策略来解决。

4、三种通用的入队策略

间接传递：通过 SynchronousQueue 间接把工作传递给线程。如果以后没可用线程，尝试入队操作会失败，而后再创立一个新的线程。当解决可能具备外部依赖性的申请时，该策略会防止申请被锁定。间接传递通常须要无界的最大线程数（maximumPoolSize），防止回绝新提交的工作。当工作继续达到的平均速度超过可解决的速度时，可能导致线程的有限增长。

无界队列：应用无界队列（如 LinkedBlockingQueue）作为期待队列，当所有的外围线程都在解决工作时，新提交的工作都会进入队列期待。因而，不会有大于 corePoolSize 的线程会被创立（maximumPoolSize 也将失去作用）。这种策略适宜每个工作都齐全独立于其余工作的状况；例如网站服务器。这种类型的期待队列能够使霎时暴发的高频申请变得平滑。当工作继续达到的平均速度超过可处理速度时，可能导致期待队列有限增长。

有界队列：当应用无限的最大线程数时，有界队列（如 ArrayBlockingQueue）能够避免资源耗尽，然而难以调整和管制。队列大小和线程池大小能够相互作用：应用大的队列和小的线程数能够缩小 CPU 使用率、系统资源和上下文切换的开销，然而会导致吞吐量变低，如果工作频繁地阻塞（例如被 I / O 限度），零碎就能为更多的线程调度执行工夫。应用小的队列通常须要更多的线程数，这样能够最大化 CPU 使用率，但可能会须要更大的调度开销，从而升高吞吐量。

5、回绝策略

当线程池曾经敞开或达到饱和（最大线程和队列都已满）状态时，新提交的工作将会被回绝。ThreadPoolExecutor 定义了四种回绝策略：

AbortPolicy：默认策略，在须要回绝工作时抛出 RejectedExecutionException；

CallerRunsPolicy：间接在 execute 办法的调用线程中运行被回绝的工作，如果线程池曾经敞开，工作将被抛弃；

DiscardPolicy：间接抛弃工作；DiscardOldestPolicy：抛弃队列中等待时间最长的工作，并执行以后提交的工作，如果线程池曾经敞开，工作将被抛弃。

咱们也能够自定义回绝策略，只须要实现 RejectedExecutionHandler；须要留神的是，回绝策略的运行须要指定线程池和队列的容量。