Java 线程池实现：示例和代码解释

以下是一个简单的 Java 线程池实现：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5); //创建线程池，大小为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 tasks');
    }
}

class WorkerThread implements Runnable {
    private String task;

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

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + ' start ' + task);

        try {
            Thread.sleep(1000); //模拟任务执行需要的时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println(Thread.currentThread().getName() + ' end ' + task);
    }
}

在这个例子中，我们使用了Executors类提供的newFixedThreadPool方法来创建一个固定大小的线程池。然后，我们创建了10个任务，每个任务都是一个WorkerThread对象，并将它们提交给线程池执行。每个WorkerThread对象实现了Runnable接口，它的run方法中包含了具体的任务逻辑。在run方法中，我们使用Thread.sleep方法来模拟任务执行需要的时间。

最后，我们调用了线程池的shutdown方法来关闭线程池，然后使用isTerminated方法等待所有任务执行完毕。一旦所有任务执行完毕，我们输出了一条消息表示所有任务都已完成。