From 0c5a58771fcf86ad0b562829fbfa440da9392703 Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期三, 17 十二月 2025 09:08:16 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/ServerBootstrap.java | 46 ++++++++++++----------------------------------
1 files changed, 12 insertions(+), 34 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index dcf52e6..549e663 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -17,7 +17,6 @@
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
-import javax.annotation.PreDestroy;
import java.util.List;
/**
@@ -92,7 +91,10 @@
throw new CoolException("鏈煡鐨勭嚎绋嬪疄鐜�");
}
- new Thread(thread).start();
+ Thread t = new Thread(thread);
+ t.setName("CrnThread-" + deviceConfig.getDeviceNo());
+ t.setDaemon(true);
+ t.start();
SlaveConnection.put(SlaveType.Crn, deviceConfig.getDeviceNo(), thread);
}
@@ -107,7 +109,10 @@
throw new CoolException("鏈煡鐨勭嚎绋嬪疄鐜�");
}
- new Thread(thread).start();
+ Thread t = new Thread(thread);
+ t.setName("DevpThread-" + deviceConfig.getDeviceNo());
+ t.setDaemon(true);
+ t.start();
SlaveConnection.put(SlaveType.Devp, deviceConfig.getDeviceNo(), thread);
}
@@ -122,40 +127,13 @@
throw new CoolException("鏈煡鐨勭嚎绋嬪疄鐜�");
}
- new Thread(thread).start();
+ Thread t = new Thread(thread);
+ t.setName("RgvThread-" + deviceConfig.getDeviceNo());
+ t.setDaemon(true);
+ t.start();
SlaveConnection.put(SlaveType.Rgv, deviceConfig.getDeviceNo(), thread);
}
}
-
-
- @PreDestroy
- public void destroy() {
- try {
- List<DeviceConfig> crnList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
- .eq("device_type", String.valueOf(SlaveType.Crn)));
- for (DeviceConfig deviceConfig : crnList) {
- SlaveConnection.remove(SlaveType.Crn, deviceConfig.getDeviceNo());
- }
- } catch (Exception ignore) {}
- try {
- List<DeviceConfig> devpList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
- .eq("device_type", String.valueOf(SlaveType.Devp)));
- for (DeviceConfig deviceConfig : devpList) {
- SlaveConnection.remove(SlaveType.Devp, deviceConfig.getDeviceNo());
- }
- } catch (Exception ignore) {}
- try {
- List<DeviceConfig> rgvList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
- .eq("device_type", String.valueOf(SlaveType.Rgv)));
- for (DeviceConfig deviceConfig : rgvList) {
- SlaveConnection.remove(SlaveType.Rgv, deviceConfig.getDeviceNo());
- }
- } catch (Exception ignore) {}
- try {
- mainProcess.shutDown();
- } catch (Exception ignore) {}
- }
-
}
--
Gitblit v1.9.1