Java ThreadPoolExecutor用法介绍

Java ThreadPoolExecutor是Java中一个关键的并发工具，它是ExecutorService接口的一种实现，主要用来管理线程的运行，包括线程的创建、销毁以及任务的分配等。它使用线程池技术进行管理，有效地解决了频繁创建和销毁线程的资源浪费问题，提高了系统的执行效率。

一、ThreadPoolExecutor概述

ThreadPoolExecutor是继承于AbstractExecutorService的类，是线程池的核心类，也是JUC最核心的类之一。它解决了两个从资源限制中引发的问题：由于每个任务创建一条线程所带来的开销，以及由于太多线程而引发的资源消耗。

public class ThreadPoolExecutor extends AbstractExecutorService

ThreadPoolExecutor的构造方法允许我们详细设置线程池中的各个参数，例如核心线程数、最大线程数，空闲线程的保留时间，以及任务队列等。

public ThreadPoolExecutor(int corePoolSize,
                           int maximumPoolSize,
                           long keepAliveTime,
                           TimeUnit unit,
                           BlockingQueue workQueue);

二、ThreadPoolExecutor的使用

ThreadPoolExecutor提供了execute和submit两种方式来执行任务，execute方法用于提交一个Runnable任务，返回值为空，因此无法知道任务执行结果。submit方法可以提交一个Callable任务，返回一个Future对象，可以通过这个返回值获取任务的执行结果。

// 创建一个固定大小的线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 200, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(5));
// 提交Runnable任务
executor.execute(new Runnable() {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " is running");
    }
});

当我们创建了ThreadPoolExecutor后，可以通过它的execute方法或者submit方法来提交任务。

// 创建Runnable任务
Runnable task = new Runnable() {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " is running");
    }
};

// 提交任务
executor.submit(task);

三、ThreadPoolExecutor的参数详解

ThreadPoolExecutor在初始化时，需要设置核心线程数、最大线程数，任务队列等参数，这些参数对于ThreadPoolExecutor的运行起着关键的作用。

// 创建一个固定大小的线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(
        5, // 核心线程数
        10, // 最大线程数
        200, // 空闲线程保留时间
        TimeUnit.MILLISECONDS, // 空闲线程保留时间的单位
        new ArrayBlockingQueue<>(5) // 任务队列
        );

核心线程数corePoolSize是最小的线程数，也是默认的线程数。如果线程池中的线程数小于这个数，那么即使有空闲的线程，也会创建新的线程来执行任务。最大线程数maximumPoolSize是线程池能创建的最大线程数。

任务队列workQueue是用来储存待执行任务的队列。只有当线程数大于核心线程数时，才会将任务放入任务队列。而当任务队列满了之后，如果线程数还没到达最大线程数，那么就会创建新的线程来执行任务。