JAVA定时任务

java 中采用ScheduledExecutorService来进行定时任务调度。
ScheduledExecutorService是基于线程池设计的定时任务类，每个调度任务都会分配到线程池中的一个线程去执行，也就是说，任务是并发执行，互不影响。

一、定时任务简单应用

1、简单的列子

public class Schedule1 {
    public static void main(String[] args) {
        ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(10);
        Runnable runnable = () -> {
            String name = Thread.currentThread().getName();
            DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
            System.out.println(name + ":RUN1 正在执行任务！" + format.format(new Date()));
        };
        scheduledThreadPool.scheduleAtFixedRate(runnable, 0, 2, TimeUnit.SECONDS);
    }
}

2、ScheduledExecutorService

定时任务执行接口，有4中执行方法。

• schedule(Runnable command,long delay, TimeUnit unit);
  创建并执行在给定延迟后启用的ScheduledFuture。
• schedule(Callable<V> callable, long delay, TimeUnit unit);
  创建并执行在给定延迟后启用的单次操作。
• scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit); 固定频率
  首次是initialDelay+period；下次就间隔period执行；计时是按照上个开始时间计算，如果任务执行时间超过period，那下次就直接执行了。如果超过多个period，下次多个都会同时执行。
  重点：一次执行失败会导致，整个调度失败，务必扑捉住错误。
• scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit); 固定延迟
  在上一个结束后和下一个开始之间给定延迟。

ScheduledThreadPoolExecutor

作为ScheduledExecutorService的具体实现类。创建实例时候我们可以直接new，但我们一般采用Executors 去创建实例。

 ScheduledExecutorService scheduledThreadPool1=new ScheduledThreadPoolExecutor(10);

Executors

为方便管理线程，采用Executors 工厂方法去创建实例。

public class Executors {
    public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }
   public static ScheduledExecutorService newScheduledThreadPool(
            int corePoolSize, ThreadFactory threadFactory) {
        return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
    }
    public static ScheduledExecutorService newScheduledThreadPool(
            int corePoolSize, ThreadFactory threadFactory) {
        return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
    }
   public static ScheduledExecutorService newSingleThreadScheduledExecutor() {
        return new DelegatedScheduledExecutorService
            (new ScheduledThreadPoolExecutor(1));
    }
}

取消定时任务

import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);
        scheduler.setRemoveOnCancelPolicy(true);//cancel时会删除这个任务
        scheduler.initialize();
        ScheduledFuture<?> future=scheduler.scheduleAtFixedRate(runnable, 2000);
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        future.cancel(false);
        System.out.println("执行任务完毕");

二、源码结构

关联关系

image.png