java实现周期性执行(定时任务)

Timer timer = new Timer();
      timer.schedule(new TimerTask() {
            @Override
            public void run() {
                log.e("time:");
 
            }
        }, 2000, 40);
//2000表示第一次执行任务延迟时间，40表示以后每隔多长时间执行一次run里面的任务

import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
 
/**
 * 设备在线延时检查检查
 */
@Slf4j
public class DelayedCheckDeviceSchedule {
 
  public static final Integer CONNECT_TIME_OUT = 10000;
 
//引用的业务层
  private ITblBaseService baseService = SpringContextHolder.getBean(ITblBaseService .class);
 
  private ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = null;
 
  /**
   * 需要延时检查的设备状态的设备id集合
   */
  public static Set<String> deviceSet = new HashSet<>();
 
  /**
   * 当前执行点
   */
  private AtomicInteger currentAtomicInteger = new AtomicInteger(1);
 
 
  /**
   * 初始化任务
   * @param delay 延迟几秒执行
   * @param checkCount 需要检测的次数
   * @param deviceId 设备Id
   * @param deviceType 设备类型
   * @return
   */
  public boolean init(long delay, int checkCount, String deviceId, String deviceType) {
    log.info("第一次初始化时间"+deviceId+"："+System.currentTimeMillis());
    if (deviceSet.add(deviceId) && deviceConnectModel!=null) {
      this.scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(4);
      this.scheduledThreadPoolExecutor.schedule(new Runnable() {
        @Override
        public void run() {
          executor(delay, checkCount, deviceId, deviceType);
        }
      }, delay, TimeUnit.SECONDS);
      return true;
    }
    return false;
  }
 
  /**
   * 执行体
   */
  private void executor(long delay, int checkCount, String deviceId, String deviceType) {
    log.info("第"+currentAtomicInteger.get()+"执行时间"+deviceId+"："+System.currentTimeMillis());
    if (deviceSet.contains(deviceId) && currentAtomicInteger.get() < (checkCount+1)) {
      //执行逻辑
          
       //当满足条件时，停止任务
        if(currentAtomicInteger.get()==checkCount){ 
          //需要处理的逻辑
 
          //停止任务
          this.scheduledThreadPoolExecutor.shutdownNow();
          deviceSet.remove(deviceId);
        }else {
          //下一次执行
          currentAtomicInteger.getAndIncrement();
          this.scheduledThreadPoolExecutor.schedule(new Runnable() {
            @Override
            public void run() {
              executor(delay, checkCount, deviceId, deviceType);
            }
          }, delay, TimeUnit.SECONDS);
     
       }
    } else {
      this.scheduledThreadPoolExecutor.shutdownNow();
      this.scheduledThreadPoolExecutor = null;
    }
  }
 
  /**
   * 停止检测任务
   * @param deviceId
   * @return
   */
  public static boolean stop(String deviceId) {
    return deviceSet.remove(deviceId);
  }
 
}

DelayedCheckDeviceSchedule delayedCheckDeviceSchedule = new DelayedCheckDeviceSchedule();
delayedCheckDeviceSchedule.init(10, 3, panModel.getDeviceId(), "pan");