在Java多线程编程中，`ScheduledExecutorService` 是一个非常重要的工具类，它继承自 `ExecutorService` 接口，提供了定时执行任务和周期性执行任务的功能。相比于传统的 `Timer` 类，`ScheduledExecutorService` 更加灵活和强大，适用于复杂的并发场景。
一、ScheduledExecutorService 的基本概念
`ScheduledExecutorService` 提供了两个主要的方法来调度任务：
- `schedule(Runnable command, long delay, TimeUnit unit)`：在指定的延迟时间后执行一次任务。
- `scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)`：从初始延迟开始，以固定的间隔重复执行任务。
- `scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)`：从初始延迟开始，每次任务完成后等待指定的时间间隔再执行下一次任务。
二、ScheduledExecutorService 的使用示例
下面通过几个简单的例子来展示如何使用 `ScheduledExecutorService`。
1. 延迟执行任务
```java
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class DelayTaskExample {
public static void main(String[] args) {
// 创建一个单线程的 ScheduledExecutorService
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("任务执行于 " + System.currentTimeMillis());
// 在 5 秒后执行任务
scheduler.schedule(task, 5, TimeUnit.SECONDS);
// 关闭调度器
scheduler.shutdown();
}
}
```
在这个例子中，我们创建了一个 `ScheduledExecutorService`，并在 5 秒钟后执行了一个简单的打印任务。
2. 固定频率执行任务
```java
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class FixedRateTaskExample {
public static void main(String[] args) {
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("任务执行于 " + System.currentTimeMillis());
// 每隔 3 秒执行一次任务
scheduler.scheduleAtFixedRate(task, 0, 3, TimeUnit.SECONDS);
// 关闭调度器
scheduler.shutdown();
}
}
```
在这个例子中，我们使用 `scheduleAtFixedRate` 方法来每隔 3 秒钟执行一次任务。
3. 固定延迟执行任务
```java
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class FixedDelayTaskExample {
public static void main(String[] args) {
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("任务执行于 " + System.currentTimeMillis());
// 每次任务完成后等待 2 秒再执行下一次任务
scheduler.scheduleWithFixedDelay(task, 0, 2, TimeUnit.SECONDS);
// 关闭调度器
scheduler.shutdown();
}
}
```
在这个例子中，我们使用 `scheduleWithFixedDelay` 方法来确保每次任务完成后等待 2 秒钟再执行下一次任务。
三、ScheduledExecutorService 的关闭
在使用完 `ScheduledExecutorService` 后，一定要记得调用 `shutdown()` 方法来释放资源。如果需要立即停止所有正在执行的任务，可以使用 `shutdownNow()` 方法。
四、总结
`ScheduledExecutorService` 是 Java 中用于定时任务调度的强大工具。通过灵活地使用 `schedule`、`scheduleAtFixedRate` 和 `scheduleWithFixedDelay` 方法，我们可以轻松实现各种复杂的任务调度需求。相比传统的 `Timer` 类，`ScheduledExecutorService` 提供了更高的灵活性和更好的线程管理能力，是现代 Java 应用程序中不可或缺的一部分。
希望本文能帮助你更好地理解和使用 `ScheduledExecutorService`！
