Java线程池ThreadPoolExecutor使用，附上代码

Java线程池ThreadPoolExecutor是Java提供的一个用于管理和复用线程的工具类。它可以帮助我们更有效地管理线程资源，提高程序的性能和可维护性。

下面是一个简单的使用ThreadPoolExecutor的示例代码：

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

public class ThreadPoolExample {
    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);
        try {
            // 模拟任务执行时间
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + " 完成任务：" + taskName);
    }
}

上述代码中，首先通过`Executors.newFixedThreadPool(5)`创建了一个包含5个线程的线程池。然后使用`executor.execute(worker)`提交任务给线程池执行，其中`worker`是实现了`Runnable`接口的任务对象。任务会被线程池中的线程异步执行。

最后，通过`executor.shutdown()`关闭线程池，并使用`executor.isTerminated()`等待所有任务完成。完成后输出"所有任务已完成"。