Java线程池ExecutorService学习和使用

示例1：使用ScheduledExecutorService进行定时任务调度

import java.util.concurrent.*;

public class ScheduledExecutorServiceExample {
    public static void main(String[] args) {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);

        Runnable task = () -> System.out.println("Executing Task at " + System.nanoTime());

        scheduledExecutorService.scheduleAtFixedRate(task, 0, 2, TimeUnit.SECONDS);

        try {
            Thread.sleep(10000);  // 让调度执行一段时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        scheduledExecutorService.shutdown();
    }
}
​

示例2：使用线程池执行大量任务并等待其完成

import java.util.concurrent.*;

public class BulkTaskExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(10);

        Callable<String> task = () -> {
            TimeUnit.SECONDS.sleep(1);
            return Thread.currentThread().getName();
        };

        List<Future<String>> futures = new ArrayList<>();
        for (int i = 0; i < 20; i++) {
            futures.add(executorService.submit(task));
        }

        futures.forEach(future -> {
            try {
                System.out.println(future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        });

        executorService.shutdown();
    }
}
​

思维导图

+------------------------------------------------------+
|          Java线程池ExecutorService学习和使用          |
+------------------------------------------------------+
           |
           +-----------------------------+
           | 一、概述                    |
           +-----------------------------+
           |
           +-----------------------------+
           | 二、基本概念                 |
           +-----------------------------+
           |
           +-----------------------------+
           | 三、常用方法                 |
           | 1. 提交任务                 |
           | 2. 关闭线程池               |
           | 3. 获取线程池状态           |
           | 4. 批量提交任务             |
           +-----------------------------+
           |
           +-----------------------------+
           | 四、线程池的创建             |
           | 1. 固定大小线程池           |
           | 2. 单线程线程池             |
           | 3. 可缓存线程池             |
           | 4. 定时线程池               |
           +-----------------------------+
           |
           +-----------------------------+
           | 五、使用示例                 |
           +-----------------------------+
           |
           +-----------------------------+
           | 六、线程池配置               |
           | 1. 核心线程数和最大线程数   |
           | 2. 自定义拒绝策略           |
           | 3. 钩子函数                 |
           +-----------------------------+
           |
           +-----------------------------+
           | 七、实战示例                 |
           | 示例1：定时任务调度          |
           | 示例2：执行大量任务并等待完成|
           +-----------------------------+
​

总结

通过学习和使用Java中的 ExecutorService，可以显著提升并发编程的效率和代码的可维护性。合理配置线程池参数，结合实际应用场景，可以实现高效、可靠的并发处理。希望本文提供的示例和思路能够帮助开发者深入理解并应用 ExecutorService，实现更高效的并发程序。