Java Executor执行器如何实现任务调度

Java Executor框架本身并不直接提供任务调度的功能，它主要用于管理和控制线程的执行。然而，你可以结合使用ScheduledExecutorService接口和ExecutorService接口来实现任务调度。

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

1. 首先，创建一个实现了Runnable接口的任务类：

public class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("任务执行时间: " + LocalDateTime.now());
    }
}

2. 接下来，创建一个ScheduledExecutorService实例，并使用scheduleAtFixedRate或scheduleWithFixedDelay方法来调度任务：

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

public class TaskScheduler {
    public static void main(String[] args) {
        // 创建一个具有单个线程的ScheduledExecutorService
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);

        // 创建一个任务实例
        MyTask myTask = new MyTask();

        // 使用scheduleAtFixedRate方法调度任务
        // 参数：任务实例、初始延迟时间、任务执行间隔时间、时间单位
        scheduledExecutorService.scheduleAtFixedRate(myTask, 0, 5, TimeUnit.SECONDS);

        // 或者使用scheduleWithFixedDelay方法调度任务
        // 参数：任务实例、上一次任务执行完成后的延迟时间、任务执行间隔时间、时间单位
        // scheduledExecutorService.scheduleWithFixedDelay(myTask, 0, 5, TimeUnit.SECONDS);

        // 注意：在实际应用中，你可能需要使用shutdown方法来关闭ScheduledExecutorService，以避免程序无法正常退出
    }
}

在这个示例中，我们创建了一个具有单个线程的ScheduledExecutorService，并调度了一个MyTask实例。任务将每隔5秒执行一次。你可以根据需要选择使用scheduleAtFixedRate或scheduleWithFixedDelay方法。前者会在固定的时间间隔内执行任务，而后者会在上一次任务执行完成后等待固定的时间间隔再执行任务。

请注意，在实际应用中，你可能需要使用shutdown方法来关闭ScheduledExecutorService，以避免程序无法正常退出。