ScheduledExecutorService 如何实现定时任务

ScheduledExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种在给定的延迟后运行命令，或者定期执行命令的方法。这个接口是 ExecutorService 的子接口，它增加了调度功能。

要使用 ScheduledExecutorService 实现定时任务，你可以按照以下步骤操作：

1. 创建一个实现了 Runnable 或 Callable 接口的任务类。
2. 创建一个 ScheduledExecutorService 实例，通常通过 Executors 工厂方法创建。
3. 使用 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 scheduler = Executors.newScheduledThreadPool(1);

        // 创建一个 Runnable 任务
        Runnable task = new Runnable() {
            public void run() {
                System.out.println("执行定时任务: " + System.currentTimeMillis());
            }
        };

        // 延迟 5 秒后开始执行任务，然后每 10 秒执行一次
        scheduler.scheduleAtFixedRate(task, 5, 10, TimeUnit.SECONDS);

        // 注意：在实际应用中，你可能需要一种机制来关闭 ScheduledExecutorService，例如使用 shutdown() 或 shutdownNow() 方法。
        // 下面的代码是为了演示，它会等待 60 秒后关闭调度器
        try {
            Thread.sleep(60000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        scheduler.shutdown();
    }
}

在这个例子中，我们创建了一个 ScheduledExecutorService，它包含一个线程池。然后我们定义了一个简单的任务，该任务打印当前的时间戳。接着，我们使用 scheduleAtFixedRate 方法来安排任务的执行，它会在初始延迟 5 秒后开始执行任务，然后每隔 10 秒执行一次。

请注意，当使用 ScheduledExecutorService 时，你应该考虑如何优雅地关闭它，以避免资源泄露。在上面的例子中，我们在主线程中让程序睡眠了 60 秒，然后调用了 shutdown 方法来关闭调度器。在实际应用中，你可能需要根据应用的生命周期来决定何时关闭调度器。