#

luxiaotao1123

2020-08-11 c38c9d4ccc288c19a9a637ef022078016fcf38a0

 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();