ThreadPoolExecutor实现

ThreadPoolExecutor是Java中的一个线程池实现，可以帮助我们管理线程池中的线程，从而优化程序的性能。下面是一个简单的ThreadPoolExecutor的实现示例：

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

public class ThreadPoolExecutorDemo {

    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("Finished all threads");
    }
}

class WorkerThread implements Runnable {

    private String taskName;

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

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " executing " + taskName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

在这个示例中，我们使用了Executors工厂类创建了一个ThreadPoolExecutor，该线程池包含5个线程。我们使用一个for循环将10个任务提交到线程池中，并且在每个任务执行时都会输出线程名和任务名。最后，我们调用shutdown()方法关闭线程池，并且通过isTerminated()方法判断线程池中的所有线程是否都已经执行完毕。