自定义工具类

package com.sxfoundation.task;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskRejectedException;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.TaskUtils;
import org.springframework.stereotype.Component;import java.util.concurrent.*;/*** @author valor.* @date 2019-07-25 16:30*/
@Component
public class JobManager {@Autowiredprivate ThreadPoolTaskScheduler taskScheduler;private static volatile JobManager jobManager;private JobManager() { }public static JobManager getInstance() {if (null == jobManager) {synchronized (JobManager.class) {if (null == jobManager) {jobManager = new JobManager();}}}return jobManager;}/*** 添加任务*/public void addJob(long startTime, Runnable task) {        
//        ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);ScheduledExecutorService executor = this.taskScheduler.getScheduledExecutor();try {Runnable runnable = TaskUtils.decorateTaskWithErrorHandler(task, TaskUtils.LOG_AND_PROPAGATE_ERROR_HANDLER, false);ScheduledFuture<?> future = executor.schedule(runnable, startTime, TimeUnit.MILLISECONDS);} catch (RejectedExecutionException ex) {throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, ex);}}}

使用

private final JobManager jobManager;jobManager.addJob(EXPIRY_TIME, () -> {closeOrder(orderDon.getId(), user.getId());
});