07 Java JUC 中的 Executor 框架 周期性任务调度

2023年6月3日 350次阅读 来源: JUC

ScheduledExecutorService基于ExecutorService，是一个完整的线程池调度。另外在提供线程池的基础上增加了四个调度任务的API。

  • schedule(Runnable command,long delay, TimeUnit unit)：在指定的延迟时间一次性启动任务（Runnable），没有返回值。
  • schedule(Callable<V> callable, long delay, TimeUnit unit)：在指定的延迟时间一次性启动任务（Callable），携带一个结果。
  • scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit)：建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；也就是将在 initialDelay 后开始执行，然后在initialDelay+period 后执行，接着在 initialDelay + 2 * period 后执行，依此类推。如果任务的任何一个执行遇到异常，则后续执行都会被取消。否则，只能通过执行程序的取消或终止方法来终止该任务。如果此任务的任何一个执行要花费比其周期更长的时间，则将推迟后续执行，但不会同时执行。
  • scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit)：创建并执行一个在给定初始延迟后首次启用的定期操作，随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。如果任务的任一执行遇到异常，就会取消后续执行。否则，只能通过执行程序的取消或终止方法来终止该任务。
public class ScheduledThreadUsage {
    public static void main(String[] args) {
        ScheduledThreadPoolExecutor executor = (ScheduledThreadPoolExecutor) Executors.newScheduledThreadPool(1);
//        executor.schedule(new Task("延迟5秒，执行一次 "), 5, TimeUnit.SECONDS);
//        executor.scheduleAtFixedRate(new Task("延迟5秒，每10秒执行一次 "), 5,10, TimeUnit.SECONDS);
        executor.scheduleWithFixedDelay(new Task("延迟5秒，每隔10秒执行一次 "), 5,10, TimeUnit.SECONDS);
        try {
            TimeUnit.MINUTES.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        executor.shutdown();
        try {
            executor.awaitTermination(1, TimeUnit.DAYS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.printf("Main: Ends at: %s\n", new Date());
    }
}
    原文作者：JUC
    原文地址: https://blog.csdn.net/yanliang1/article/details/46715291
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞