From ede979dbf9a7872b0709ff2bdbac2e11167a3b71 Mon Sep 17 00:00:00 2001
From: lin <648540858@qq.com>
Date: Mon, 30 Mar 2026 17:00:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E9=85=8D=E7=BD=AE=E7=B1=BB=E5=B9=B6=E8=AE=B0=E5=BD=95?=
 =?UTF-8?q?=E5=BF=83=E8=B7=B3=E6=9B=B4=E6=96=B0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/conf/SchedulingConfig.java        | 20 +++++++++++++++++++
 .../cmd/KeepaliveNotifyMessageHandler.java    |  1 +
 2 files changed, 21 insertions(+)
 create mode 100644 src/main/java/com/genersoft/iot/vmp/conf/SchedulingConfig.java

diff --git a/src/main/java/com/genersoft/iot/vmp/conf/SchedulingConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/SchedulingConfig.java
new file mode 100644
index 000000000..6896ca63a
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/conf/SchedulingConfig.java
@@ -0,0 +1,20 @@
+package com.genersoft.iot.vmp.conf;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.TaskScheduler;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+@Configuration
+public class SchedulingConfig {
+
+    @Bean
+    public TaskScheduler taskScheduler() {
+        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
+        scheduler.setPoolSize(5);
+        scheduler.setThreadNamePrefix("scheduled-");
+        scheduler.setVirtualThreads(true);  // 必须在 initialize() 之前
+        scheduler.initialize();
+        return scheduler;
+    }
+}
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/KeepaliveNotifyMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/KeepaliveNotifyMessageHandler.java
index 97e7a4ccf..a801dc08c 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/KeepaliveNotifyMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/KeepaliveNotifyMessageHandler.java
@@ -94,6 +94,7 @@ public class KeepaliveNotifyMessageHandler extends SIPRequestProcessorParent imp
     }
     @Scheduled(fixedDelay = 10, timeUnit = TimeUnit.SECONDS)
     public void executeUpdateDeviceList() {
+        log.info("[定时任务] 更新心跳记录，待处理设备数量: {}", taskQueue.size());
         try {
             if (!taskQueue.isEmpty()) {
                 redisCatchStorage.updateDeviceKeepaliveTimeStamp(taskQueue.stream().toList());