From ce511a3d55e5f349b1647172e562c1659bbc8172 Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期五, 09 一月 2026 15:27:27 +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