From 7e36eb78c63d2ed483bb8f717666f25c54f2e8b3 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 05 八月 2020 14:41:04 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/CrnThread.java | 12 ++++++++----
1 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/CrnThread.java b/src/main/java/com/zy/core/thread/CrnThread.java
index 733dc1f..8b0da7e 100644
--- a/src/main/java/com/zy/core/thread/CrnThread.java
+++ b/src/main/java/com/zy/core/thread/CrnThread.java
@@ -9,10 +9,11 @@
import lombok.extern.slf4j.Slf4j;
/**
+ * 鍫嗗灈鏈虹嚎绋�
* Created by vincent on 2020/8/4
*/
-@Slf4j
@Data
+@Slf4j
public class CrnThread implements Runnable, ThreadHandler {
private Slave slave;
@@ -27,9 +28,7 @@
while (true) {
try {
Task task = MessageQueue.poll(SlaveType.Crn, slave.getId());
- if (task == null) {
- System.out.println("鏃犱换鍔�");
- } else {
+ if (task != null) {
System.out.println("浠诲姟"+task.getId());
}
Thread.sleep(3000);
@@ -41,6 +40,11 @@
}
@Override
+ public boolean connect() {
+ return false;
+ }
+
+ @Override
public void close() {
}
}
--
Gitblit v1.9.1