使用线程池时一定要注意的五个点

很多场景下应用程序必须能够处理一系列传入请求，简单的处理方式是通过一个线程顺序的处理这些请求，如下图：

单线程策略的优势和劣势都非常明显：

优势：设计和实现简单；劣势：这种方式会带来处理效率的问题，单线程的处理能力是有限，不能发挥多核处理器优势。

在这种场景下我们就需要考虑并发，一个简单的并发策略就是Thread-Per-Message模式，即为每个请求使用一个新的线程。

Thread-Per-Message策略的优势和劣势也非常明显：

优势：设计和实现比较简单，能够同时处理多个请求，提升响应效率；

劣势：主要在两个方面

1资源消耗 引入了在串行执行中所没有的开销，包括线程创建和调度，任务处理，资源分配和回收以及频繁上下文切换所需的时间和资源。2安全

有没有一种方式可以并发执行又可以克服Thread-Per-Message的问题？

采用线程池的策略，线程池通过控制并发执行的工作线程的最大数量来解决Thread-Per-Message带来的问题。可见下图，请求来临时先放入线程池的队列

线程池可以接受一个Runnable或Callable<T>任务，并将其存储在临时队列中，当有空闲线程时可以从队列中拿到一个任务并执行。

反例(使用 Thread-Per-Message 策略)

正例(使用 线程池 策略)

JAVA 中(JDK 15+)线程池的种类：

程序不能使用来自有界线程池的线程来执行依赖于线程池中其他任务的任务。

有两个场景：

要缓解上面两个场景产生的问题有两个简单的办法：

真正解决此类方法还是需要梳理线程池执行业务流程，不要在有界线程池中执行相互依赖的任务，防止出现竞争和死锁。

向线程池提交的任务需要支持中断。从而保证线程可以中断，线程池可以关闭。线程池支持 javautilconcurrentExecutorServiceshutdownNow() 方法，该方法尝试停止所有正在执行的任务，停止等待任务的处理，并返回等待执行的任务的列表。

但是 shutdownNow() 除了尽力尝试停止处理主动执行的任务之外不能保证一定能够停止。例如，典型的实现是通过Threadinterrupt()来停止，因此任何未能响应中断的任务可能永远不会终止，也就造成线程池无法真正的关闭。

反例：

正例：

线程池中的所有任务必须提供机制，如果它们异常终止，则需要通知应用程序

如果不这样做不会导致资源泄漏，但由于池中的线程仍然被会重复使用，使故障诊断非常困难或不可能。

在应用程序级别处理异常的最好方法是使用异常处理。异常处理可以执行诊断 *** 作，清理和关闭Java虚拟机，或者只是记录故障的详细信息。

也就是说在线程池里执行的任务也需要能够抛出异常并被捕获处理。

任务恢复或清除 *** 作可以通过重写 javautilconcurrentThreadPoolExecutor 类的 afterExecute() 钩子来执行。

当任务通过执行其 run() 方法中的所有语句并且成功结束任务，或者由于异常而导致任务停止时，将调用此钩子。

可以通过自定义 ThreadPoolExecutor 服务来重载 afterExecute()钩子。

还可以通过重载 terminated() 方法来释放线程池获取的资源，就像一个finally块。

反例：

任务意外终止时作为一个运行时异常，无法通知应用程序。此外，它缺乏恢复机制。因此，如果Task抛出一个NullPointerException ，异常将被忽略。

正例：

另外一种方式是使用 ExecutorServicesubmit() 方法（代替 execute() 方法）将任务提交到线程池并获取 Future 对象。

当通过 ExecutorServicesubmit() 提交任务时，抛出的异常并未到达未捕获的异常处理机制，因为抛出的异常被认为是返回状态的一部分，因此被包装在ExecutionException ，并由Futureget() 返回。

javalangThreadLocal 类提供线程内的本地变量。根据Java API

ThreadLocal对象需要关注那些对象被线程池中的多个线程执行的类。

线程池缓存技术允许线程重用以减少线程创建开销，或者当创建无限数量的线程时可以降低系统的可靠性。

当 ThreadLocal 对象在一个线程中被修改，随后变得可重用时，在重用的线程上执行的下一个任务将能看到该线程上执行过的上一个任务修改的ThreadLocal 对象的状态。

所以要在使用线程池时重新初始化的ThreadLocal对象实例。

反例：

DiaryPool类创建了一个线程池，它可以通过一个共享的无界的队列来重用固定数量的线程。

在任何时候，不超过numOfThreads个线程正在处理任务。如果在所有线程都处于活动状态时提交其他任务，则 它们在队列中等待，直到线程可用。

当线程循环时，线程的线程局部状态仍然存在。

下表显示了可能的执行顺序：

时间任务线程池提交方法日期1t11doSomething1()星期五2t22doSomething2()星期一3t31doSomething3()星期五

在这个执行顺序中，期望从doSomething2() 开始的两个任务（ t 2和t 3 doSomething2() 将当天视为星 期一。然而，因为池线程1被重用，所以t 3观察到星期五。

解决方案（try-finally条款）

符合规则的方案removeDay() 方法添加到Diary类，并在try‐finally 块中的实现doSomething1() 类的doSomething1() 方法的语句。finally 块通过删除当前线程中的值来恢复threadlocal类型的days对象的初始状态。

如果threadlocal变量再次被同一个线程读取，它将使用initialValue()方法重新初始化 ，除非任务已经明确设置了变量的值。这个解决方案将维护的责任转移到客户端（ DiaryPool ），但是当Diary类不能被修改时是一个好的选择。

解决方案（beforeExecute()）

使用一个自定义ThreadPoolExecutor 来扩展 ThreadPoolExecutor并覆盖beforeExecute() 方法。beforeExecute() 方法在Runnable 任务在指定线程中执行之前被调用。该方法在线程 “t” 执行任务 “r” 之前重新初始化 threadlocal 变量。

打开任务管理器， 查看---选择列----线程数 勾起来后，就可以查看到每个程序的线程数了。

或者

using SystemDiagnostics;

ProcessGetCurrentProcess()ThreadsCount;

可获取到线程的数量。

获取正在使用的线程数量：

int n = 0;

foreach (ProcessThread th in ProcessGetCurrentProcess()Threads)

{

if (thThreadState == ThreadStateRunning)

{

n++;

}

}

线程池的核心线程数量。初始是不创建线程的。当有任务提交到线程池时，判定如果已经创建的线程数量小于核心数量，且没有空闲线程时，则会新建一个线程去执行新提交的任务。如果已经达到核心线程数量， 则会加入到阻塞队列中。

线程池的最大容量。当线程池的阻塞队列放满了， 并且线程数量还未达到线程池的最大线程数量， 则会创建新的线程，直到达到最大值

当阻塞队列里面的任务被执行完了， 且有空闲线程时，指定大于核心线程池数量的部分空闲线程的存活时间， 毕竟线程也是需要消耗资源的，及时回收很有必要。当线程空闲的时间超过这个时间后，会回收掉一部分空闲线程，使其线程池中的线程数量不大于核心线程的数量

配套使用 这里需要指定时间的单位

阻塞队列，当没有空闲线程时，多余的任务缓存的地方。

线程工厂，用来创建线程时，设定线程的一些参数

当线程数量达到最大值时，且阻塞队列慢了， 后续在提交任务时，没有地方可以接受继续的提交的任务。这种情况下的一个拒绝策略。

getTask() 获取线程任务

队列take();

workQueueoffer(command) 唤醒等待线程

以上就是关于使用线程池时一定要注意的五个点全部的内容，包括:使用线程池时一定要注意的五个点、C#获取线程数量、线程池执行过程等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！