线程池分类
-
FixedThreadPool：固定大小线程池，线程数量固定，不会自动扩容或缩容。
-
CachedThreadPool：缓存线程池，线程数量不固定，根据需要自动扩容或缩容。适用于执行大量短时间任务的场景。
-
SingleThreadPool：单线程线程池，只有一个线程在工作，保证任务按顺序执行。
-
ScheduledThreadPool：定时任务线程池，用于执行定时任务和周期性任务。
-
WorkStealingPool：工作窃取线程池，每个线程都有自己的工作队列，当某个线程完成自己的任务后，会从其他线程的队列中偷取任务来执行，提高任务执行效率。
-
ForkJoinPool：分治任务线程池，可以将一个大任务拆分成多个小任务并行执行，并将结果合并，适用于处理大规模的计算任务。
newFixedThreadPool
它创建一个具有固定数量线程的线程池。这意味着在任何给定的时间，线程池中最多只能同时执行固定数量的任务。
下面是一个示例代码：
ExecutorService executor = Executors.newFixedThreadPool(5);for (int i = 0; i < 10; i++) {Runnable worker = new MyRunnable(i);executor.execute(worker);
}executor.shutdown();
while (!executor.isTerminated()) {
}System.out.println("所有任务执行完毕");
在这个示例中，我们创建了一个固定数量为5的线程池，并提交了10个任务到线程池中执行。每个任务都是一个MyRunnable对象，它是一个实现了Runnable接口的自定义类。executor.execute(worker)将每个任务提交给线程池执行。
executor.shutdown()用于关闭线程池，不再接受新任务。然后使用executor.isTerminated()来检查线程池中的任务是否全部执行完毕，直到全部执行完毕后跳出循环。
最后，我们打印出"所有任务执行完毕"的信息。
使用newFixedThreadPool创建线程池的好处是可以限制同时执行的任务数量，避免线程过多造成的性能问题。当所有任务执行完毕后，线程池可以重用线程来执行新的任务，而不需要每次都创建新的线程。这样可以减少线程创建和销毁的开销，提升程序的性能。
newCachedThreadPool
newCachedThreadPool是java.util.concurrent.Executors类中提供的一个线程池创建方法。它的原理是根据需要创建线程来执行任务，如果线程池中有空闲线程，则复用空闲线程执行任务；如果线程池中没有空闲线程，则创建新的线程来执行任务。同时，如果线程空闲时间超过60秒，则会被回收，从而适应任务的变化。
下面是代码示例：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolExample {public static void main(String[] args) {// 创建一个线程池，使用newCachedThreadPool方法ExecutorService executorService = Executors.newCachedThreadPool();// 提交任务给线程池executorService.submit(new Task("Task 1"));executorService.submit(new Task("Task 2"));executorService.submit(new Task("Task 3"));// 关闭线程池executorService.shutdown();}static class Task implements Runnable {private String name;public Task(String name) {this.name = name;}@Overridepublic void run() {System.out.println("Task " + name + " is running in thread: " + Thread.currentThread().getName());}}
}
该示例中，首先创建了一个使用newCachedThreadPool方法创建的线程池对象executorService。然后，我们提交了三个任务给线程池去执行。每个任务都是一个Task对象，该对象实现了Runnable接口，重写了run方法，用来定义具体的任务逻辑。在run方法中，我们打印了当前任务的名称以及执行任务的线程名称。
最后，我们调用shutdown方法关闭线程池，等待所有任务执行完毕。
由于使用了newCachedThreadPool方法创建的线程池是一个无界线程池，所以可以执行任意数量的任务。如果线程池中有空闲线程，任务会被分配给空闲线程执行；如果没有空闲线程，会创建新的线程来执行任务。同时，如果线程空闲时间超过60秒，线程会被回收，从而适应任务的变化。
newSingleThreadExecutor
newSingleThreadExecutor是Java中ExecutorService接口的一个实现类，它创建一个只有一个线程的线程池。该线程池只会用一个线程来执行任务，确保任务按照它们被提交的顺序依次执行，即任务将会顺序执行而不会并发执行。
下面给出一个示例代码：
ExecutorService executor = Executors.newSingleThreadExecutor();executor.execute(new Runnable() {public void run() {try {// 模拟任务执行Thread.sleep(1000);System.out.println("Task executed");} catch (InterruptedException e) {e.printStackTrace();}}
});executor.shutdown();
解释：
-
首先通过
Executors.newSingleThreadExecutor()创建一个只有一个线程的线程池。 -
调用
executor.execute()方法提交一个任务（表示为一个Runnable对象）。这里的任务是模拟执行了一段耗时1秒的操作。 -
然后调用
executor.shutdown()方法来关闭线程池。注意，这里的关闭操作是异步的，即会等待所有任务执行完毕后关闭线程池。
由于newSingleThreadExecutor只有一个线程，所以无论提交多少个任务，它们都将按照提交的顺序一个一个地被顺序执行。在上面的示例中，只有一个任务，因此它将会被执行一次，并在执行完毕后输出"Task executed"。
任务提交
Executor.execute()方法用于提交一个Runnable任务给执行器执行。执行器会立即开始执行任务，并且无法取消或获取任务的结果。
ExecutorService.submit()方法用于提交一个Runnable或Callable任务给执行器执行，并且返回一个表示任务结果的Future对象。可以通过Future对象来获取任务的执行结果，也可以使用Future对象来取消任务的执行。
线程池调优
线程池调优是指对线程池的配置和参数进行调整，以达到更好的性能和资源利用效率。
-
根据实际需求配置线程池大小：线程池大小应该根据系统的负载情况来设定，太小会导致任务等待时间过长，太大则会增加系统负担。可以根据系统的并发请求量和处理能力来动态调整线程池的大小。
-
设置合理的阻塞队列大小：线程池的阻塞队列可以用于缓存等待执行的任务，但是过大的队列可能会占用过多的内存，导致系统资源浪费。应根据实际情况选择合适的队列大小，一般来说，有界队列比无界队列更可控，可以避免无限制的堆积。
-
考虑任务执行时间和响应时间：如果大部分任务执行时间较短，可以适当增加线程池的大小来提高并发处理能力。如果大部分任务执行时间较长，可以适当减少线程池的大小，以避免资源浪费。
-
使用合适的线程池类型：Java中常用的线程池类型有FixedThreadPool、CachedThreadPool和ScheduledThreadPool等，选择合适的线程池类型可以更好地适应任务的特性和需求。
-
监控和调整：通过监控线程池的运行状况，可以及时发现并解决问题，例如线程池的饱和状态、活动线程数、任务等待时间等。可以使用一些监控工具和框架来帮助收集和分析线程池的数据，从而做出有针对性的调整。
-
合理处理任务拒绝策略：当线程池满了并且队列也满了时，可以使用合适的任务拒绝策略来处理超出处理能力的任务。常用的策略有丢弃任务、调用者运行和抛出异常等，可以根据实际需求选择合适的策略。
线程池监控
-
线程池监控指标：可以通过调用ThreadPoolExecutor类的方法来获取线程池的各项指标，比如getPoolSize()可以获取线程池的当前线程数，getActiveCount()可以获取正在执行任务的线程数，getCompletedTaskCount()可以获取已经完成的任务数等。
-
线程池状态：可以通过调用ThreadPoolExecutor类的方法来获取线程池的当前状态，比如isShutdown()可以判断线程池是否已经被关闭，isTerminated()可以判断线程池是否已经完全终止。
-
监控任务执行情况：可以通过实现ThreadPoolExecutor类的子类，重写其beforeExecute()和afterExecute()方法来监控任务的执行情况。beforeExecute()方法会在每个任务执行之前调用，可以在该方法中记录任务开始执行的时间，afterExecute()方法会在每个任务执行之后调用，可以在该方法中记录任务执行结束的时间，并计算任务执行的时长。
-
监控线程池异常信息：可以通过实现ThreadPoolExecutor类的子类，重写其afterExecute()方法，在该方法中捕获任务执行过程中的异常信息，并进行处理。
-
使用管理工具：Java也提供了一些管理工具，如JConsole、VisualVM等，可以用来对线程池进行监控和管理。
总结
线程池有三种分类，分别是固定大小线程池、可缓存线程池和定时任务线程池。
-
固定大小线程池（FixedThreadPool）: 这种线程池的核心线程数量是固定的，不会随着任务的增加而增加。当有新任务到达时，如果当前线程池中的线程数量小于核心线程数量，则直接创建一个新线程来执行任务；如果当前线程数量已经达到核心线程数量，则将新任务放入任务队列中等待执行。当任务队列已满且线程池中的线程都处于繁忙状态时，新任务会由线程池的拒绝策略来处理。
-
可缓存线程池（CachedThreadPool）: 这种线程池的核心线程数量是0，最大线程数量是无限制的。当有新任务到达时，线程池会尝试复用已有的线程来执行任务，如果没有可用的线程，则创建一个新线程来执行任务。当线程池中的线程空闲时间超过一定时间（默认为60秒），则会被自动销毁。这种线程池适用于执行耗时较短的任务，任务量较大且随时可能增加的场景。
-
定时任务线程池（ScheduledThreadPool）: 这种线程池可以执行定时任务和周期性任务。它由一个核心线程池和一个任务队列组成。当有新任务到达时，如果当前线程池中的线程数量小于核心线程数量，则直接创建一个新线程来执行任务；如果当前线程数量已经达到核心线程数量，则将新任务放入任务队列中等待执行。当任务队列已满且线程池中的线程都处于繁忙状态时，新任务会由线程池的拒绝策略来处理。定时任务线程池适用于需要定时执行任务或周期性执行任务的场景。
