From 96b9ffebfac24b2d3e999f7aa22c21556ad99430 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 06 八月 2020 17:45:39 +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