package com.cloudroam.task; import lombok.extern.slf4j.Slf4j; import javax.annotation.PostConstruct; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; /** * @author taojie * * 1.根据数据库配置的邮箱地址来发送邮件 * 2.根据数据库任务配置时间来发送邮件 */ //@Component @Slf4j public class PmsTaskExecutors { private final static ScheduledExecutorService scheduler= Executors.newScheduledThreadPool(5); @PostConstruct public void init() { scheduler.scheduleAtFixedRate(() -> { try { } catch (Exception e) { e.printStackTrace(); } }, 0, 1, TimeUnit.MINUTES); // 每隔一分钟检查一次数据库 } }