From cfb5a68740880c52c9acada94f25a06614f2407a Mon Sep 17 00:00:00 2001
From: qlsxk <qlsxk@qq.com>
Date: 星期六, 11 十月 2025 10:07:16 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/ServerBootstrap.java | 20 +++++++++++---------
1 files changed, 11 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index 08bdeb2..3aaf637 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -82,17 +82,19 @@
}
private void initFakeThread(){
- ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFake, enableFakeDeviceThread);
- new Thread(thread).start();
- SlaveConnection.put(SlaveType.FakeThread, 1, thread);
+ if (enableFake) {
+ ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFake, enableFakeDeviceThread);
+ new Thread(thread).start();
+ SlaveConnection.put(SlaveType.FakeThread, 1, thread);
- ThreadHandler thread2 = new FakeZyForkLiftThread(redisUtil);
- new Thread(thread2).start();
- SlaveConnection.put(SlaveType.FakeThread, 2, thread2);
+ ThreadHandler thread2 = new FakeZyForkLiftThread(redisUtil);
+ new Thread(thread2).start();
+ SlaveConnection.put(SlaveType.FakeThread, 2, thread2);
- ThreadHandler thread3 = new FakeNyLiftThread(redisUtil);
- new Thread(thread3).start();
- SlaveConnection.put(SlaveType.FakeThread, 3, thread3);
+ ThreadHandler thread3 = new FakeNyLiftThread(redisUtil);
+ new Thread(thread3).start();
+ SlaveConnection.put(SlaveType.FakeThread, 3, thread3);
+ }
}
--
Gitblit v1.9.1