Java ExecutorService如何实现任务调度

Java中的ExecutorService接口提供了一种将任务提交给线程池执行的方式，但它本身并不直接支持任务调度。如果你需要调度任务在未来的某个时间点执行，或者定期执行任务，你可以使用ScheduledExecutorService接口，它是ExecutorService的子接口。

以下是如何使用ScheduledExecutorService来实现任务调度的几个例子：

1. 延迟执行任务：使用schedule方法可以在给定的延迟后执行一次性任务。

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 = new Runnable() {
            public void run() {
                System.out.println("Task executed after delay");
            }
        };

        // 延迟5秒后执行任务
        scheduler.schedule(task, 5, TimeUnit.SECONDS);
    }
}

2. 定期执行任务：使用scheduleAtFixedRate或scheduleWithFixedDelay方法可以定期执行任务。

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

public class ScheduledRepeatedTaskExample {
    public static void main(String[] args) {
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        Runnable task = new Runnable() {
            public void run() {
                System.out.println("Task executed at fixed rate");
            }
        };

        // 每隔10秒执行一次任务
        scheduler.scheduleAtFixedRate(task, 0, 10, TimeUnit.SECONDS);
    }
}

3. 取消调度任务：如果你需要取消一个已经调度的任务，可以使用Future对象。

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

public class ScheduledTaskCancellationExample {
    public static void main(String[] args) {
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        Runnable task = new Runnable() {
            public void run() {
                System.out.println("Task executed");
            }
        };

        // 延迟5秒后执行任务，并返回一个Future对象
        Future<?> future = scheduler.schedule(task, 5, TimeUnit.SECONDS);

        // 在某个时刻取消任务
        future.cancel(true);
    }
}

请注意，当使用ScheduledExecutorService时，你应该在不再需要它时关闭它，以释放系统资源。这可以通过调用shutdown或shutdownNow方法来完成。

scheduler.shutdown(); // 拒绝新的任务提交，并等待已提交的任务完成
// 或者
scheduler.shutdownNow(); // 尝试停止所有正在执行的任务，并暂停处理等待队列中的任务

在实际应用中，你可能需要根据具体的业务需求来选择合适的调度策略和参数。