java 使用ThreadPoolExecutor 封装一个工具类以及如何使用

好的，您的问题是如何使用 ThreadPoolExecutor 封装一个 Java 工具类，以便在项目中使用。

首先，让我们快速了解一下 ThreadPoolExecutor。ThreadPoolExecutor 是 Java 提供的一个线程池实现，可以用于管理多个线程的执行。当我们需要运行大量的且相对较短的任务时，使用线程池可以减少线程的创建和销毁操作，提高性能。ThreadPoolExecutor 可以设置核心线程数、最大线程数、任务队列、拒绝策略等参数，以便满足我们的需求。

下面是封装 ThreadPoolExecutor 的工具类示例代码：

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolUtils {

    private static ThreadPoolExecutor threadPoolExecutor;

    public static void initThreadPool() {
        int corePoolSize = 5; // 核心线程数
        int maximumPoolSize = 10; // 最大线程数
        long keepAliveTime = 60; // 非核心线程等待新任务的最长时间
        TimeUnit unit = TimeUnit.SECONDS;
        ArrayBlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100); // 任务队列，可根据实际情况调整大小
        threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    public static void executeTask(Runnable task) {
        if (threadPoolExecutor == null) {
            initThreadPool();
        }
        threadPoolExecutor.execute(task);
    }
}

上面的代码定义了一个 ThreadPoolUtils 类，其中 initThreadPool() 方法用于初始化线程池，executeTask(Runnable task) 方法用于向线程池中添加任务。在使用时，可通过调用 executeTask() 方法来执行任务。

使用示例：

public class Test {

    public static void main(String[] args) {
        Thread task1 = new Thread(() -> {
            System.out.println("Task 1 is running.");
        });
        Thread task2 = new Thread(() -> {
            System.out.println("Task 2 is running.");
        });
        ThreadPoolUtils.executeTask(task1);
        ThreadPoolUtils.executeTask(task2);
    }
}

在上面的示例中，我们创建了两个线程，然后通过 ThreadPoolUtils.executeTask() 方法将它们添加到线程池中。

希望这个例子能够解决您的问题。如果您有任何其他问题，请随时问我。