java线程池使用完整代码

import java.util.concurrent.*;

public class ThreadPoolExample {

    public static void main(String[] args) {
        // 创建一个固定大小的线程池，大小为5
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 创建Runnable任务
        Runnable task = () -> {
            String threadName = Thread.currentThread().getName();
            System.out.println("Hello from " + threadName);
        };

        // 提交10个任务给线程池执行
        for (int i = 0; i < 10; i++) {
            executor.submit(task);
        }

        // 关闭线程池，不再接受新任务，但会继续执行已提交的任务
        executor.shutdown();

        // 等待所有任务完成
        try {
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                executor.shutdownNow(); // 如果等待超时，则强制关闭线程池
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
        }
    }
}

解释说明：

1. 创建线程池：使用 Executors.newFixedThreadPool(5) 创建了一个固定大小为5的线程池。这意味着最多可以同时运行5个线程。
2. 定义任务：创建了一个简单的 Runnable 任务，该任务会在控制台打印当前线程的名字。
3. 提交任务：通过 executor.submit(task) 提交了10个相同的任务给线程池执行。由于线程池大小为5，所以最多同时有5个任务在运行，其他任务会排队等待。
4. 关闭线程池：调用 executor.shutdown() 表示不再接受新的任务，但会继续执行已经提交的任务。
5. 等待任务完成：使用 awaitTermination 方法等待所有任务完成，如果超过指定时间（60秒）仍未完成，则调用 shutdownNow 强制关闭线程池。

这个例子展示了如何使用Java中的线程池来管理和执行多个任务。