谈一谈你对线程池的理解？

### 对线程池的理解 #### 线程池的基本概念 线程池是一种多线程处理机制，它通过提前创建一定数量的线程，并将任务分配给这些线程来执行，从而实现任务的并发处理。线程池管理着一组工作线程，当有新任务提交时，会将任务分配给空闲的线程执行。如果所有线程都在忙，新的任务会被放入队列中等待。 #### 线程池的好处 合理利用线程池能够带来以下三个主要好处： 1. **降低资源消耗**： - 通过重复利用已创建的线程，减少了频繁创建和销毁线程带来的系统资源消耗。线程的创建和销毁是一个昂贵的操作，尤其是在高并发环境下。 2. **提高响应速度**： - 当任务到达时，不需要等待线程创建就能立即执行任务，从而提高了系统的响应速度。线程池中的线程可以立即处理提交的任务，减少了任务的等待时间。 3. **提高线程的可管理性**： - 线程是稀缺资源，如果不加限制地创建线程，可能会耗尽系统资源，导致系统不稳定。线程池可以对线程的数量进行有效的控制和管理，避免了资源的过度消耗。通过线程池，可以对线程进行统一的分配、调优和监控。 #### 线程池的使用 在 Java 中，可以通过 `Executors` 工具类来创建线程池。常用的线程池类型包括： - **`newSingleThreadExecutor`**：创建一个单线程的线程池，保证所有任务按提交顺序执行。 - **`newFixedThreadPool`**：创建一个固定大小的线程池，线程池中线程数量固定，适用于负载较为稳定的应用。 - **`newCachedThreadPool`**：创建一个可缓存的线程池，线程池大小根据需要动态调整，适用于大量短期任务。 - **`newScheduledThreadPool`**：创建一个支持定时及周期性任务执行的线程池，适用于需要定时执行任务的应用。 #### 线程池的启动策略 1. **初始化线程池**：创建线程池时，可以指定线程池的大小，任务队列的类型等。 2. **提交任务**：通过 `execute()` 或 `submit()` 方法向线程池提交任务。`execute()` 方法用于提交不需要返回结果的任务，而 `submit()` 方法用于提交需要返回结果的任务。 3. **任务执行**：线程池中的线程会从任务队列中取出任务并执行。当线程执行完任务后，会返回线程池中等待下一个任务。 4. **关闭线程池**：当不再需要处理新的任务时，可以调用 `shutdown()` 方法关闭线程池，线程池会在执行完所有已提交的任务后终止。如果需要立即终止所有任务，可以调用 `shutdownNow()` 方法。 #### 示例代码 ```java import java.util.concurrent.*; public class ThreadPoolExample { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(10); for (int i = 0; i < 10; i++) { executor.execute(new Task()); } executor.shutdown(); } } class Task implements Runnable { @Override public void run() { System.out.println(Thread.currentThread().getName() + " is executing a task."); } } ``` ### 总结 通过合理使用线程池，可以显著提升系统的性能和稳定性： 1. **降低资源消耗**：减少了频繁创建和销毁线程的开销。 2. **提高响应速度**：任务可以立即执行，不需要等待线程的创建。 3. **提高可管理性**：有效控制线程数量，防止资源耗尽，提供统一的分配、调优和监控能力。 理解线程池的工作原理和优势，有助于在开发并发应用时，选择合适的线程池策略，提高系统的效率和可靠性。

### 首先线程池有什么作用？ - 1.提高响应速度，如果线程池有空闲线程的话，可以直接复用这个线程执行任务，而不用去创建。 - 2.减少资源占用，每次都创建线程都需要申请资源，而使用线程池可以复用已创建的线程。 - 3.可以控制并发数，可以通过设置线程池的最大线程数量来控制最大并发数，如果每次都是创建新线程，来了大量的请求，可能会因为创建的线程过多，造成内存溢出。 - 4.更加方便来管理线程资源。 ### 线程池有哪些参数？ ```java ThreadPoolExecutor executor = new ThreadPoolExecutor( 10, // corePoolSize 10, // maximumPoolSize 0L, // keepAliveTime TimeUnit.MILLISECONDS, // timeUnit new LinkedBlockingQueue<>(10), // 阻塞队列 Executors.defaultThreadFactory(), // 默认线程工厂 new ThreadPoolExecutor.AbortPolicy() // 拒绝策略 ); ``` **1.corePoolSize 核心线程数** 该线程池中核心线程数最大值，添加任务时，即便有空闲线程，只要当前线程池线程数<corePoolSize,都是会新建线程来执行这个任务。并且核心线程空闲时间超过keepAliveTime也是不会被回收的。（ 从阻塞队列取任务时，如果阻塞队列为空: 核心线程的会一直卡在workQueue.take方法，这个take方法每种等待队列的实现各不相同，以LinkedBlockingQueue为例， 在这个方法里会调用notEmpty队列(这是Condition实例)的await()方法一直阻塞并挂起，不会占用CPU资源。 非核心线程会调用workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS)方法取任务 ，这个poll方法每种等待队列的实现各不相同，以LinkedBlockingQueue为例， 在这个方法里面会调用notEmpty队列(这是Condition实例)的awaitNanos()方法进行超时等待，如果超过keepAliveTime时间后还没有新的任务，就会返回null,Worker对象的run()方法循环体的判断为null,任务结束，然后线程被系统回收） **2.maximumPoolSize 最大线程数** 该线程池中线程总数最大值 ，一般是用于当线程池中的线程都在执行任务，并且等待队列满了时，如果当前线程数<maximumPoolSize,可以创建一个新线程来执行任务。maximumPoolSize一般也可以用来现在最大线程并发执行量。 **3.workQueue 等待队列** 等待队列，一般是抽象类BlockingQueue的子类。  **4.keepAliveTime：非核心线程闲置超时时长。** 非核心线程如果处于闲置状态超过该值，就会被销毁。如果设置allowCoreThreadTimeOut(true)，则会也作用于核心线程。 **5.RejectedExecutionHandler 拒绝处理策略** 拒绝处理策略，核心线程已经满了，等待队列也满了，并且线程数量大于最大线程数时，就会采用拒绝处理策略进行处理，四种拒绝处理的策略为 ： - ThreadPoolExecutor.AbortPolicy：默认拒绝处理策略，丢弃任务并抛出RejectedExecutionException异常。 - ThreadPoolExecutor.DiscardPolicy：丢弃新来的任务，但是不抛出异常。 - ThreadPoolExecutor.DiscardOldestPolicy：丢弃等待队列头部（最旧的）的任务，然后重新尝试执行程序，将任务添加到队列中（如果再次失败，重复此过程）。 - ThreadPoolExecutor.CallerRunsPolicy：由调用线程处理该任务。 **6.ThreadFactory创建线程的工厂** ThreadFactory是一个接口，只有一个newThread()方法。(默认情况下ThreadPoolExecutor用的ThreadFactory默认都是Executors.defaultThreadFactory())。一般来说，你通过ThreadPoolExecutor来创建线程池，对于线程池中的线程你是无法直接接触到的，例如你为了更加方便得定位线程池的Bug，希望对线程池中线程设置跟业务相关的名称，那么就需要建一个类，实现ThreadFactory接口，编写newThread()方法的实现。 ```java public interface ThreadFactory { Thread newThread(Runnable r); } ```