java线程池的工作原理

import java.util.concurrent.*;

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

        // 提交10个任务给线程池执行
        for (int i = 0; i < 10; i++) {
            int taskNumber = i + 1;
            executor.submit(() -> {
                System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                try {
                    // 模拟任务执行时间
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskNumber + " is completed");
            });
        }

        // 关闭线程池，不再接受新的任务
        executor.shutdown();

        // 等待所有任务完成
        try {
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
        }
    }
}

解释说明

1. 创建线程池：

   • 使用 Executors.newFixedThreadPool(4) 创建一个固定大小为4的线程池。这意味着最多同时有4个线程在执行任务。

2. 提交任务：

   • 使用 executor.submit() 方法向线程池提交任务。这里我们提交了10个任务，每个任务都会打印当前任务编号和正在运行的线程名称，然后模拟2秒的任务执行时间，最后打印任务完成信息。

3. 关闭线程池：

   • 使用 executor.shutdown() 方法关闭线程池，表示不再接受新的任务，但会继续执行已经提交的任务。

4. 等待任务完成：

   • 使用 executor.awaitTermination() 方法等待所有任务完成。如果在指定时间内（这里是60秒）任务没有完成，则调用 executor.shutdownNow() 强制关闭线程池。

通过这段代码，你可以看到线程池如何管理多个任务的并发执行，并且如何优雅地关闭线程池以确保资源释放。