From 3e6ea6acc9205d7d0ba3e925b703994e8bc868ea Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 03 九月 2020 12:50:26 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/LedThread.java | 37 +++++++++++++++++++++++++++++++++----
1 files changed, 33 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index a8c02ad..511816f 100644
--- a/src/main/java/com/zy/core/thread/LedThread.java
+++ b/src/main/java/com/zy/core/thread/LedThread.java
@@ -2,6 +2,10 @@
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 com.zy.core.model.command.LedCommand;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import onbon.bx05.Bx5GEnv;
@@ -14,6 +18,9 @@
import onbon.bx05.utils.DisplayStyleFactory;
import java.awt.*;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
/**
* Created by vincent on 2020/9/1
@@ -24,6 +31,7 @@
private Slave slave;
private Bx5GScreenClient screen;
+ private Set<Integer> workNos = new HashSet<>();
public LedThread(Slave slave) {
this.slave = slave;
@@ -37,15 +45,24 @@
}
@Override
- @SuppressWarnings("InfiniteLoopStatement")
+ @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
public void run() {
connect();
while (true) {
try {
+ Task task = MessageQueue.poll(SlaveType.Led, slave.getId());
+ if (task != null) {
+ switch (task.getStep()) {
+ // 鍐欐暟鎹�
+ case 1:
+ write((List<LedCommand>)task.getData());
+ break;
+ default:
+ break;
+ }
+ }
-
-
- Thread.sleep(500);
+ Thread.sleep(3000);
} catch (Exception e) {
e.printStackTrace();
}
@@ -74,6 +91,18 @@
}
+ private void write(List<LedCommand> list) {
+
+ for (LedCommand command : list) {
+
+ }
+
+
+
+
+ }
+
+
public static void main(String[] args) throws Exception {
--
Gitblit v1.9.1