ExecutorService如何实现任务调度

ExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种将任务提交给线程池执行的方式。虽然 ExecutorService 本身并不直接提供任务调度的功能，但是你可以通过组合使用 ScheduledExecutorService（它是 ExecutorService 的子接口）来实现任务的定时调度。

以下是使用 ScheduledExecutorService 实现任务调度的基本步骤：

1. 创建一个 ScheduledExecutorService 实例。通常，你可以使用 Executors 工厂方法来创建一个具有固定线程数的调度执行器：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(4);

这里创建了一个具有 4 个线程的调度执行器。 2. 定义要执行的任务。这个任务需要实现 Runnable 接口：

Runnable task = new Runnable() {
    @Override
    public void run() {
        // 在这里编写要执行的任务代码
        System.out.println("任务执行时间：" + LocalDateTime.now());
    }
};

3. 使用 schedule、scheduleAtFixedRate 或 scheduleWithFixedDelay 方法来安排任务的执行。

   • schedule(Runnable command, long delay, TimeUnit unit)：在给定的延迟后执行一次任务。
   • scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：在初始延迟后开始执行任务，并按照固定的频率重复执行。
   • scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：在初始延迟后开始执行任务，并在每次任务完成后等待固定的延迟再执行下一次任务。

例如，如果你想在 5 秒后执行一次任务，可以使用以下代码：

scheduler.schedule(task, 5, TimeUnit.SECONDS);

如果你想每隔 10 秒执行一次任务，可以使用以下代码：

scheduler.scheduleAtFixedRate(task, 0, 10, TimeUnit.SECONDS);

注意：在使用完 ScheduledExecutorService 后，记得调用 shutdown() 方法来关闭它，以释放资源。

scheduler.shutdown();

以上就是使用 ScheduledExecutorService 实现任务调度的基本步骤。你可以根据需要调整任务的执行频率和延迟时间。