#

luxiaotao1123

2020-09-03 3e6ea6acc9205d7d0ba3e925b703994e8bc868ea

 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 {