scheduledexecutorservice的启动和停止
时间: 2024-09-10 11:01:41 浏览: 44
java在服务启动的时候启动定时器
`ScheduledExecutorService` 是Java中的一个接口,它继承自 `ExecutorService` 接口,专门用于执行需要定期执行的任务,或者在将来某个时间执行一次或多次的任务。`ScheduledExecutorService` 提供了 `schedule`、`scheduleAtFixedRate` 和 `scheduleWithFixedDelay` 等方法来安排任务。
启动 `ScheduledExecutorService` 只需要创建它的实现类的实例即可,通常使用 `Executors` 类中的工厂方法来创建:
```java
// 创建一个固定大小的线程池,提供一个线程用于执行任务
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
```
启动一个周期性任务,可以使用如下代码:
```java
// 在指定的延迟后执行一次任务
scheduledExecutorService.schedule(() -> {
System.out.println("执行任务");
}, 5, TimeUnit.SECONDS);
// 每隔一定时间间隔执行一次任务
scheduledExecutorService.scheduleAtFixedRate(() -> {
System.out.println("周期性任务执行");
}, 0, 1, TimeUnit.MINUTES);
// 每隔一定时间间隔执行一次任务,但间隔的计算是任务结束时开始计算
scheduledExecutorService.scheduleWithFixedDelay(() -> {
System.out.println("周期性任务执行");
try {
Thread.sleep(10000); // 模拟任务执行需要一些时间
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}, 0, 1, TimeUnit.MINUTES);
```
停止 `ScheduledExecutorService` 通常通过调用 `shutdown()` 方法开始一个平滑的关闭过程。该方法会停止接受新任务,并尝试完成所有已提交的任务,但不会立即中断正在执行的任务。如果需要立即停止所有正在执行的任务,可以使用 `shutdownNow()` 方法。停止后,可以通过 `isTerminated()` 方法来检查是否所有任务都已经执行完毕。
```java
// 平滑关闭
scheduledExecutorService.shutdown();
// 尝试立即停止所有正在执行的任务
// scheduledExecutorService.shutdownNow();
// 等待直到所有任务都执行完毕
try {
if (!scheduledExecutorService.awaitTermination(60, TimeUnit.SECONDS)) {
// 如果在指定的时间内没有终止,可以尝试再次停止所有任务
scheduledExecutorService.shutdownNow();
}
} catch (InterruptedException e) {
// 如果等待过程中线程被中断,则再次尝试立即停止所有任务
scheduledExecutorService.shutdownNow();
Thread.currentThread().interrupt();
}
```
阅读全文