scheduleAtFixedRate
是 Java 中 ScheduledExecutorService
接口的一个方法,用于以固定的频率执行任务。这个方法的执行策略是基于时间的,而不是基于任务完成的时间。下面是这个方法的一些关键点:
- 初始延迟:
scheduleAtFixedRate
方法允许你设置一个初始延迟(initialDelay
),这意味着在第一次执行任务之前,会等待指定的延迟时间。 - 执行间隔:你还需要指定任务的执行间隔(
period
),这是每次连续执行之间的时间间隔。 - 任务调度:这个方法会按照固定的时间间隔来调度任务,而不管任务的执行时间。这意味着,如果任务的执行时间超过了指定的执行间隔,那么下一次任务的执行将会在当前任务执行完成后立即开始。
- 并发执行:
scheduleAtFixedRate
方法不会等待任务完成就开始计算下一次任务的执行时间。这可能导致任务的并发执行,如果任务的执行时间超过了指定的执行间隔。 - 任务取消:如果任务因为某种原因被取消(例如,调用了
Future.cancel()
方法),那么scheduleAtFixedRate
将不再继续执行该任务。 - 异常处理:如果任务在执行过程中抛出异常,
scheduleAtFixedRate
将会忽略这个异常,并继续执行下一次任务。
下面是一个简单的示例,展示了如何使用 scheduleAtFixedRate
方法:
import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class ScheduleAtFixedRateExample { public static void main(String[] args) { ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); Runnable task = () -> { System.out.println("Task executed at: " + System.currentTimeMillis()); try { Thread.sleep(2000); // 模拟长时间运行的任务 } catch (InterruptedException e) { e.printStackTrace(); } }; executor.scheduleAtFixedRate(task, 0, 1, TimeUnit.SECONDS); } }
在这个示例中,我们创建了一个 ScheduledExecutorService
实例,并提交了一个任务,该任务每隔 1 秒执行一次。任务的执行时间为 2 秒,这将导致任务的并发执行。