ScheduledExecutorService 是 Java 中并发包 java.util.concurrent 提供的一个接口，用于定时或周期性地执行任务。它是 ExecutorService 的一个子接口，专门用于支持定时任务的执行和调度。通过 ScheduledExecutorService，我们可以更加高效和灵活地处理有关时间调度的任务，这在很多后台服务或定期操作中非常有用。

以下是一些关于 ScheduledExecutorService 的关键点：

创建 ScheduledExecutorService

通常，你可以通过 Executors 工具类来创建一个 ScheduledExecutorService 实例：

import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(int corePoolSize);  

这里的 corePoolSize 参数指的是池中的线程数。

常用方法

1. schedule

   • schedule(Runnable command, long delay, TimeUnit unit): 在给定的延迟之后执行一次任务。
   • schedule(Callable<V> callable, long delay, TimeUnit unit): 同样在给定延迟后执行任务，但返回一个结果。

2. scheduleAtFixedRate

   • scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit): 在初始延迟之后首先执行任务，随后以固定的周期不断执行。即每次执行任务的开始时间间隔固定。

3. scheduleWithFixedDelay

   • scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit): 在初始延迟之后执行任务，并在每次执行的完成与下一次开始之间保持固定的延迟。

使用示例

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 task = () -> System.out.println("Task executed at: " + System.currentTimeMillis());  
        long initialDelay = 1;  
        long period = 3;  
        scheduler.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);  
        // Add shutdown hook to ensure the service is shutdown correctly  
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {  
            System.out.println("Shutting down executor...");  
            scheduler.shutdown();  
            try {  
                if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {  
                    System.out.println("Force shutdown...");  
                    scheduler.shutdownNow();  
                }  
            } catch (InterruptedException e) {  
                scheduler.shutdownNow();  
            }  
            System.out.println("Shutdown complete.");  
        }));  
    }  
}  

注意事项

• 线程资源管理: ScheduledExecutorService 使用的线程池管理着应用程序的线程资源。在不需要的时候，应该记得调用 shutdown() 方法来释放资源。
• 异常处理: 任务中抛出的未捕获异常将导致该任务取消执行。应该在任务中适当处理异常以避免非预期行为。
• 时间单位: 方法中使用的 TimeUnit 提供了更直观的时间间隔控制，使代码更具可读性。

通过 ScheduledExecutorService，Java 程序可以高效地定期执行任务，在需要定时或周期性操作的场景中非常实用。