From 8c53606ba281d8b13890564f7e4684c4a20dadb1 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 06 八月 2020 10:49:43 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/BarcodeThread.java | 10 +++-------
1 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/BarcodeThread.java b/src/main/java/com/zy/core/thread/BarcodeThread.java
index 6c4a7eb..a2122c0 100644
--- a/src/main/java/com/zy/core/thread/BarcodeThread.java
+++ b/src/main/java/com/zy/core/thread/BarcodeThread.java
@@ -2,9 +2,6 @@
import com.zy.core.Slave;
import com.zy.core.ThreadHandler;
-import com.zy.core.cache.MessageQueue;
-import com.zy.core.enums.SlaveType;
-import com.zy.core.model.Task;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
@@ -17,6 +14,7 @@
public class BarcodeThread implements Runnable, ThreadHandler {
private Slave slave;
+ private String barcode;
public BarcodeThread(Slave slave) {
this.slave = slave;
@@ -28,10 +26,8 @@
public void run() {
while (true) {
try {
- Task task = MessageQueue.poll(SlaveType.Barcode, slave.getId());
- if (task != null) {
- System.out.println("浠诲姟"+task.getId());
- }
+// Task task = MessageQueue.poll(SlaveType.Barcode, slave.getId());
+ barcode = "10001136";
Thread.sleep(3000);
} catch (Exception e) {
e.printStackTrace();
--
Gitblit v1.9.1