ThreadPoolExecutor创建线程

要使用ThreadPoolExecutor创建线程池，可以按照以下步骤进行操作：

1. 导入必要的类：

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

2. 创建ThreadPoolExecutor实例：

ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);

其中，poolSize是线程池的大小，即同时可以执行的任务数量。

3. 向线程池提交任务：

executor.submit(new Runnable() {
    public void run() {
        // 任务的具体逻辑
    }
});

可以通过submit方法提交一个Runnable或者Callable类型的任务。

4. 关闭线程池：

executor.shutdown();

调用shutdown方法会等待所有已提交的任务执行完成后再关闭线程池。

完整的示例代码如下：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        int poolSize = 5;
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);

        for (int i = 0; i < 10; i++) {
            executor.submit(new Runnable() {
                public void run() {
                    System.out.println("Task executed by thread: " + Thread.currentThread().getName());
                }
            });
        }

        executor.shutdown();
    }
}

在上面的示例中，我们创建了一个大小为5的线程池，然后提交了10个任务给线程池执行。每个任务会打印当前执行任务的线程名字。最后，我们调用shutdown方法关闭线程池。

使用ThreadPoolExecutor可以更好地管理线程池的行为，例如设置线程池的大小、设置任务的拒绝策略等。