From e6d32c9a052311642c1a838c752e9ecce5c7a51b Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Mon, 12 Sep 2022 21:18:40 +0800
Subject: [PATCH] fix: worker heartbeat use wrong thread pool

---
 .../server/remote/server/self/ServerInfoServiceImpl.java       | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java
index 5159da83..94bb12ca 100644
--- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java
+++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java
@@ -2,9 +2,11 @@ package tech.powerjob.server.remote.server.self;
 
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.boot.info.BuildProperties;
+import org.springframework.scheduling.annotation.Async;
 import tech.powerjob.common.exception.PowerJobException;
 import tech.powerjob.common.utils.CommonUtils;
 import tech.powerjob.common.utils.NetUtils;
+import tech.powerjob.server.common.constants.PJThreadPool;
 import tech.powerjob.server.common.module.ServerInfo;
 import tech.powerjob.server.extension.LockService;
 import tech.powerjob.server.persistence.remote.model.ServerInfoDO;
@@ -86,6 +88,7 @@ public class ServerInfoServiceImpl implements ServerInfoService {
         log.info("[ServerInfoService] ip:{}, id:{}, cost:{}", ip, serverInfo.getId(), sw);
     }
 
+    @Async(PJThreadPool.TIMING_POOL)
     @Scheduled(fixedRate = 15000, initialDelay = 15000)
     public void heartbeat() {
         serverInfoRepository.updateGmtModifiedByIp(serverInfo.getIp(), new Date());