Java定时线程池,每隔5秒执行一次任务,执行5次后关闭线程池完整代码
时间: 2024-09-10 14:19:06 浏览: 89
Java中的定时线程池可以通过`ScheduledExecutorService`来实现,这是一个可以安排在给定的延迟后运行命令,或者定期执行命令的线程池。下面是使用`ScheduledExecutorService`创建一个定时线程池,并设置每隔5秒执行一次任务,执行5次后关闭线程池的完整代码示例:
```java
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小的线程池
ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
// 创建一个任务,这里以打印字符串为例
Runnable task = () -> {
System.out.println("执行定时任务: " + System.currentTimeMillis());
};
// 使用schedule方法安排任务在初始延迟后执行,之后每隔5秒执行一次
int initialDelay = 0; // 初始延迟0秒
long period = 5; // 之后每5秒执行一次
int numIterations = 5; // 执行5次
// scheduleAtFixedRate方法允许你指定任务执行的起始时间、周期以及频率
executorService.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);
// 使用submit提交的任务能够得到一个Future对象,可以通过它来取消任务
// ScheduledFuture<?> future = executorService.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);
// 执行完指定次数后关闭线程池
executorService.schedule(() -> {
executorService.shutdown();
System.out.println("定时任务执行完毕,线程池已关闭。");
}, numIterations * period, TimeUnit.SECONDS);
}
}
```
请注意,执行完指定次数后关闭线程池的代码使用了`schedule`方法,它允许我们在指定的延迟后执行一个任务,这里设置为执行完5次定时任务后关闭线程池。
阅读全文