ScheduledThreadPoolExecutor 设置定时任务
时间: 2024-08-27 14:01:40 浏览: 43
ScheduledThreadPoolExecutor是Java并发包中用于定期执行任务的一个工具,它基于ThreadPoolExecutor,添加了调度功能。通过ScheduledThreadPoolExecutor,你可以安排任务在未来某个时间点执行,或者按照一定的时间间隔周期性地运行。
设置定时任务通常包括以下步骤:
1. **创建executor**: 首先,你需要创建一个ScheduledThreadPoolExecutor实例,比如:
```java
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
```
这里的数字1表示线程池大小,可以根据需求调整。
2. **提交任务**: 使用`schedule()`方法来指定任务何时开始执行,例如立即执行一次的命令:
```java
Runnable task = () -> System.out.println("Task will run once.");
executor.schedule(task, 0, TimeUnit.MILLISECONDS); // 0毫秒后执行
```
如果你想让任务每隔一段时间执行,可以使用`scheduleAtFixedRate()`或`scheduleWithFixedDelay()`方法,前者会在每个固定时间间隔执行,后者则是第一次延迟执行然后按照给定的间隔重复:
```java
executor.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);
executor.scheduleWithFixedDelay(task, initialDelay, delay, TimeUnit.SECONDS);
```
这里,initialDelay是首次执行的延迟,period/delay是执行间隔。
3. **取消任务**: 如果需要在任何时候取消任务,可以使用`cancel()`方法配合`Future`接口:
```java
Future<?> future = executor.submit(task);
future.cancel(true); // 取消任务,true表示立即中断任务
```
4. **关闭线程池**: 当所有任务完成后,记得关闭线程池以释放资源:
```java
executor.shutdown(); // 或 shutdownNow() 来立即停止所有任务
```
阅读全文