From b726dc97538b7d4ba71fd06c14161017dd67c2b7 Mon Sep 17 00:00:00 2001
From: xubinbin <1323875150@qq.com>
Date: 星期三, 10 五月 2023 15:38:22 +0800
Subject: [PATCH] "@schedule"是Spring框架提供的一种定时任务执行机制，默认情况下它是单线程执行，项目中多次使用fixedRate按指定频率执行任务(不管前面任务是否已经完成)，在同时执行多个定时任务时可能会出现阻塞和性能问题，为了解决这种单线程瓶颈问题，将定时任务的执行机制改为支持多线程
---
src/main/java/com/genersoft/iot/vmp/conf/ScheduleConfig.java | 30 ++++++++++++++++++++++++++++++
1 files changed, 30 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/conf/ScheduleConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/ScheduleConfig.java
new file mode 100644
index 0000000..432fafb
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/conf/ScheduleConfig.java
@@ -0,0 +1,30 @@
+package com.genersoft.iot.vmp.conf;
+
+import org.apache.commons.lang3.concurrent.BasicThreadFactory;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+/**
+ * "@Scheduled"鏄疭pring妗嗘灦鎻愪緵鐨勪竴绉嶅畾鏃朵换鍔℃墽琛屾満鍒讹紝榛樿鎯呭喌涓嬪畠鏄崟绾跨▼鐨勶紝鍦ㄥ悓鏃舵墽琛屽涓畾鏃朵换鍔℃椂鍙兘浼氬嚭鐜伴樆濉炲拰鎬ц兘闂銆�
+ * 涓轰簡瑙ｅ喅杩欑鍗曠嚎绋嬬摱棰堥棶棰橈紝鍙互灏嗗畾鏃朵换鍔＄殑鎵ц鏈哄埗鏀逛负鏀寔澶氱嚎绋�
+ */
+@Configuration
+public class ScheduleConfig implements SchedulingConfigurer {
+
+ public static final int cpuNum = Runtime.getRuntime().availableProcessors();
+
+ private static final int corePoolSize = cpuNum;
+
+ private static final String threadNamePrefix = "scheduled-task-pool-%d";
+
+ @Override
+ public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+ taskRegistrar.setScheduler(new ScheduledThreadPoolExecutor(corePoolSize,
+ new BasicThreadFactory.Builder().namingPattern(threadNamePrefix).daemon(true).build(),
+ new ThreadPoolExecutor.CallerRunsPolicy()));
+ }
+}
--
Gitblit v1.8.0