import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
import java.util.concurrent.Executors;
@Component
@EnableScheduling
public class Task implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        //設置線程池
        scheduledTaskRegistrar.setScheduler(Executors.newScheduledThreadPool(20));
        //taskConfig中配置定時任務的相關信息
        TaskConfig taskConfig = dutyConfigs.get(taskType);
        //異步任務
        Runnable runnable = () -> createByConfig(taskConfig);
        Trigger trigger = triggerContext -> {
            CronTrigger cronTrigger = new CronTrigger(taskConfig.getCron());
            return cronTrigger.nextExecutionTime(triggerContext);
        };
        scheduledTaskRegistrar.addTriggerTask(runnable, trigger);
    }
}