用灵魂搞定线程池，多线程也不怕

后端

2023-09-02 20:04:23

ThreadPoolExecutor介绍

ThreadPoolExecutor 是 Java 中用于管理线程池的类，它提供了丰富的功能和配置选项，可以满足各种各样的并发编程需求。ThreadPoolExecutor 的构造函数需要传入以下参数：

corePoolSize: 线程池的核心线程数，即当任务数小于核心线程数时，线程池会创建新的线程来执行任务。
maximumPoolSize: 线程池的最大线程数，即当任务数大于核心线程数时，线程池会创建新的线程来执行任务，直到达到最大线程数。
keepAliveTime: 线程池中空闲线程的存活时间，超过这个时间后，空闲线程将被销毁。
unit: 存活时间的单位，可以是 TimeUnit.SECONDS、TimeUnit.MILLISECONDS 等。
workQueue: 任务队列，用于存储等待执行的任务。

为什么要使用线程池

使用线程池主要有以下几个好处：

提高并发性: 线程池可以帮助我们更轻松地创建和管理线程，从而提高程序的并发性。
提高性能: 线程池可以复用线程，避免了频繁创建和销毁线程的开销，从而提高了程序的性能。
提高稳定性: 线程池可以帮助我们控制线程的创建和销毁，防止程序因创建过多线程而导致系统崩溃。

ThreadPoolExecutor的细节

ThreadPoolExecutor 提供了一些细节，可以帮助我们更好地理解和使用线程池：

线程池状态: 线程池有三种状态：运行状态、关闭状态和终止状态。
任务队列: 任务队列用于存储等待执行的任务，它可以是无界队列，也可以是有界队列。
拒绝策略: 当任务队列已满时，ThreadPoolExecutor 会根据拒绝策略来处理新提交的任务。常用的拒绝策略有：AbortPolicy、CallerRunsPolicy、DiscardOldestPolicy 等。
线程池监控: ThreadPoolExecutor 提供了一些方法，可以帮助我们监控线程池的状态，例如 getPoolSize()、getActiveCount()、getCompletedTaskCount() 等。

如何使用ThreadPoolExecutor

要使用 ThreadPoolExecutor，我们需要首先创建一个 ThreadPoolExecutor 对象，然后将任务提交给线程池。以下是一个使用 ThreadPoolExecutor 的示例：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExecutorExample {

    public static void main(String[] args) {
        // 创建一个线程池
        ExecutorService threadPool = Executors.newFixedThreadPool(5);

        // 向线程池提交任务
        for (int i = 0; i < 10; i++) {
            threadPool.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println("任务" + i + "正在执行...");
                }
            });
        }

        // 关闭线程池
        threadPool.shutdown();
    }
}