Java 创建线程池

在 Java 中，可以使用 `ThreadPoolExecutor` 类来创建线程池。以下是创建线程池的示例代码：

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

public class Main {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，最多同时执行 5 个线程
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 提交任务给线程池
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread("Task " + i);
            executor.execute(worker);
        }

        // 关闭线程池
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 等待所有任务完成
        }

        System.out.println("所有任务已经完成");
    }
}

class WorkerThread implements Runnable {
    private String taskName;

    public WorkerThread(String taskName) {
        this.taskName = taskName;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " 开始执行 " + taskName);
        // 执行任务的逻辑
        System.out.println(Thread.currentThread().getName() + " 完成任务 " + taskName);
    }
}

上述代码中，通过 `Executors.newFixedThreadPool(5)` 创建了一个固定大小为 5 的线程池。然后使用 `executor.execute(worker)` 提交任务给线程池。最后，在所有任务完成后，调用 `executor.shutdown()` 关闭线程池。