Timer timer = new Timer();
? ? ? timer.schedule(new TimerTask() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? log.e("time:");
?
? ? ? ? ? ? }
? ? ? ? }, 2000, 40);
//2000表示第一次執(zhí)行任務(wù)延遲時(shí)間，40表示以后每隔多長(zhǎng)時(shí)間執(zhí)行一次run里面的任務(wù)

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;
?
/**
?* 設(shè)備在線延時(shí)檢查檢查
?*/
@Slf4j
public class DelayedCheckDeviceSchedule {
?
? public static final Integer CONNECT_TIME_OUT = 10000;
?
//引用的業(yè)務(wù)層
? private ITblBaseService baseService = SpringContextHolder.getBean(ITblBaseService .class);
?
? private ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = null;
?
? /**
? ?* 需要延時(shí)檢查的設(shè)備狀態(tài)的設(shè)備id集合
? ?*/
? public static Set<String> deviceSet = new HashSet<>();
?
? /**
? ?* 當(dāng)前執(zhí)行點(diǎn)
? ?*/
? private AtomicInteger currentAtomicInteger = new AtomicInteger(1);
?
?
? /**
? ?* 初始化任務(wù)
? ?* @param delay 延遲幾秒執(zhí)行
? ?* @param checkCount 需要檢測(cè)的次數(shù)
? ?* @param deviceId 設(shè)備Id
? ?* @param deviceType 設(shè)備類(lèi)型
? ?* @return
? ?*/
? public boolean init(long delay, int checkCount, String deviceId, String deviceType) {
? ? log.info("第一次初始化時(shí)間"+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;
? }
?
? /**
? ?* 執(zhí)行體
? ?*/
? private void executor(long delay, int checkCount, String deviceId, String deviceType) {
? ? log.info("第"+currentAtomicInteger.get()+"執(zhí)行時(shí)間"+deviceId+"："+System.currentTimeMillis());
? ? if (deviceSet.contains(deviceId) && currentAtomicInteger.get() < (checkCount+1)) {
? ? ? //執(zhí)行邏輯
? ? ? ? ??
? ? ? ?//當(dāng)滿(mǎn)足條件時(shí)，停止任務(wù)
? ? ? ? if(currentAtomicInteger.get()==checkCount){?
? ? ? ? ? //需要處理的邏輯
?
? ? ? ? ? //停止任務(wù)
? ? ? ? ? this.scheduledThreadPoolExecutor.shutdownNow();
? ? ? ? ? deviceSet.remove(deviceId);
? ? ? ? }else {
? ? ? ? ? //下一次執(zhí)行
? ? ? ? ? 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;
? ? }
? }
?
? /**
? ?* 停止檢測(cè)任務(wù)
? ?* @param deviceId
? ?* @return
? ?*/
? public static boolean stop(String deviceId) {
? ? return deviceSet.remove(deviceId);
? }
?
}

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