ScheduledExecutorService详细解

### ScheduledExecutorService 的详细用法和功能 #### 1. **ScheduledExecutorService 基本概念** `ScheduledExecutorService` 是 `java.util.concurrent` 包中的一个重要接口，它是 `ExecutorService` 接口的子接口，提供了定时任务调度的能力。相比于传统的 `Timer` 或者手动管理线程的方式，`ScheduledExecutorService` 提供了更灵活的任务调度机制[^2]。 #### 2. **创建 ScheduledExecutorService 实例** 可以通过 `Executors` 工具类提供的静态方法来创建 `ScheduledExecutorService` 的实例。常用的创建方式如下： ```java import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; // 创建一个单线程的 ScheduledExecutorService ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(); // 如果需要更多线程可以使用以下方法 // ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(int corePoolSize); ``` 这里展示了如何通过 `newSingleThreadScheduledExecutor()` 方法创建一个单线程池的调度器，也可以通过 `newScheduledThreadPool(int corePoolSize)` 来指定线程数量[^1]。 #### 3. **主要方法及其功能** ##### (1) **schedule(Runnable command, long delay, TimeUnit unit)** 用于安排一次性任务，在指定延迟后执行一次。 ```java scheduler.schedule(() -> { System.out.println("Task executed after delay"); }, 5, TimeUnit.SECONDS); ``` 这段代码会在 5 秒钟之后打印消息到控制台[^2]。 ##### (2) **scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)** 按照固定频率重复执行任务，第一次执行会有初始延迟。 ```java scheduler.scheduleAtFixedRate(() -> { System.out.println("Executing at fixed rate: " + System.currentTimeMillis()); }, 1, 2, TimeUnit.SECONDS); ``` 这个例子表示在 1 秒后开始执行任务，并每隔 2 秒再次执行[^2]。 ##### (3) **scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)** 按固定的延时间隔重复执行任务，即每次任务完成后等待一定时间再启动下一次。 ```java scheduler.scheduleWithFixedDelay(() -> { try { Thread.sleep(1000); // Simulate work taking time } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Executing with fixed delay: " + System.currentTimeMillis()); }, 1, 2, TimeUnit.SECONDS); ``` 在这个示例中，任务将在完成后的两秒重新触发新任务。 ##### (4) **shutdown() 和 shutdownNow()** 当不再需要继续提交新的任务时，应该调用 `shutdown()` 方法平滑关闭服务；如果希望立即停止所有正在运行的任务，则可调用 `shutdownNow()`。 ```java scheduler.shutdown(); // 平滑关闭 // 或者强制中断未完成的任务 List<Runnable> remainingTasks = scheduler.shutdownNow(); ``` #### 4. **优势对比其他方案** 相比传统 `Timer` 类型，`ScheduledExecutorService` 更加健壮可靠，能够更好地应对异常情况下的恢复策略，同时也支持更加复杂的多线程场景配置[^3]。 --- ###