Java Executor执行器如何实现定时任务

在Java中，你可以使用ScheduledExecutorService接口来实现定时任务。ScheduledExecutorService是ExecutorService的子接口，它提供了定时执行任务的功能。要使用ScheduledExecutorService，你需要先创建一个ScheduledThreadPoolExecutor实例，然后使用它的schedule、scheduleAtFixedRate或scheduleWithFixedDelay方法来安排任务。

以下是一个简单的示例，展示了如何使用ScheduledExecutorService实现定时任务：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledTaskExample {

    public static void main(String[] args) {
        // 创建一个ScheduledExecutorService实例，线程池大小为2
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);

        // 创建一个Runnable任务
        Runnable task = () -> System.out.println("执行定时任务: " + System.currentTimeMillis());

        // 使用scheduleAtFixedRate方法安排任务，延迟1秒后开始执行，每隔2秒执行一次
        scheduledExecutorService.scheduleAtFixedRate(task, 1, 2, TimeUnit.SECONDS);

        // 使用scheduleWithFixedDelay方法安排任务，延迟1秒后开始执行，每次执行完成后等待2秒再执行下一次
        scheduledExecutorService.scheduleWithFixedDelay(task, 1, 2, TimeUnit.SECONDS);

        // 注意：在实际应用中，你可能需要添加一些逻辑来关闭ScheduledExecutorService，例如在应用程序退出时。
    }
}

在这个示例中，我们创建了一个ScheduledExecutorService实例，并使用scheduleAtFixedRate和scheduleWithFixedDelay方法安排了两个定时任务。这两个方法的区别在于：

• scheduleAtFixedRate：任务按照固定的频率执行，不管任务的执行时间如何。如果任务的执行时间超过了指定的周期，那么下一个任务会在当前任务完成后立即开始执行。
• scheduleWithFixedDelay：任务在上一个任务完成后，等待指定的延迟时间再开始执行。

注意：在实际应用中，你可能需要添加一些逻辑来关闭ScheduledExecutorService，例如在应用程序退出时。你可以调用shutdown()或shutdownNow()方法来关闭ScheduledExecutorService。