java自定义ThreadPoolExecutor线程池

在Java中，我们可以通过自定义ThreadPoolExecutor类来创建自己的线程池。ThreadPoolExecutor类是ExecutorService接口的一个实现，它提供了一个灵活的线程池管理机制。

要自定义ThreadPoolExecutor线程池，我们需要使用ThreadPoolExecutor类的构造函数来创建一个实例，并设置一些参数来配置线程池的行为。下面是一个示例代码：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class CustomThreadPoolExecutor {
    public static void main(String[] args) {
        // 创建一个阻塞队列，用于存放待执行的任务
        BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(10);
        
        // 创建自定义的线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            5, // 核心线程数
            10, // 最大线程数
            1, // 空闲线程存活时间
            TimeUnit.MINUTES, // 时间单位
            queue // 阻塞队列
        );

        // 添加任务到线程池中
        for (int i = 0; i < 20; i++) {
            executor.execute(() -> {
                System.out.println("执行任务");
            });
        }

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

在上面的示例代码中，我们使用了一个LinkedBlockingQueue作为阻塞队列来存放待执行的任务。然后，我们创建了一个ThreadPoolExecutor实例，并设置了核心线程数为5，最大线程数为10，空闲线程存活时间为1分钟。接下来，我们通过execute方法向线程池提交了20个任务。

最后，记得要调用executor.shutdown()方法来关闭线程池，以确保所有任务执行完毕并释放资源。

通过自定义ThreadPoolExecutor类，我们可以根据实际需求来设置线程池的参数，并且可以根据需要灵活地处理提交的任务。