diff --git a/src/main/java/asia/yulinling/workflow/config/SchedulingConfig.java b/src/main/java/asia/yulinling/workflow/config/SchedulingConfig.java new file mode 100644 index 0000000..59f116f --- /dev/null +++ b/src/main/java/asia/yulinling/workflow/config/SchedulingConfig.java @@ -0,0 +1,31 @@ +package asia.yulinling.workflow.config; + +import org.jetbrains.annotations.NotNull; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.scheduling.SchedulingTaskExecutor; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; + +/** + *
+ * 定时任务配置类 + *
+ * + * @author YLL + * @since 2025/6/20 + */ +@Configuration +@EnableScheduling +public class SchedulingConfig { + + @Bean + public SchedulingTaskExecutor schedulingTaskExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + executor.setCorePoolSize(5); + executor.setMaxPoolSize(10); + executor.setThreadNamePrefix("WorkflowTaskScheduler-"); + executor.initialize(); + return executor; + } +} diff --git a/src/main/java/asia/yulinling/workflow/task/ScheduledTask.java b/src/main/java/asia/yulinling/workflow/task/ScheduledTask.java new file mode 100644 index 0000000..be2b818 --- /dev/null +++ b/src/main/java/asia/yulinling/workflow/task/ScheduledTask.java @@ -0,0 +1,21 @@ +package asia.yulinling.workflow.task; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; +import org.springframework.scheduling.annotation.Scheduled; +/** + *+ * 定时任务 + *
+ * + * @author YLL + * @since 2025/6/20 + */ +@Component +@Slf4j +public class ScheduledTask { + @Scheduled(fixedRate = 1000) + public void runEvery1SSecond() { +// log.info("执行定时任务 1s"); + } +}