#

vincentlu

15 小时以前 1bdaf9be340892e1654caea9ed4082b6c61beb3b

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/PathQueueConsumer.java

@@ -37,7 +37,7 @@
        this.consumerExecutor.execute(() -> {
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    Thread.sleep(30);
                    Thread.sleep(10);
                    List<UnlockPathTask> tasks = new ArrayList<>();
                    // if unlockTaskQueue was empty, then block
                    tasks.add(unlockTaskQueue.take());
@@ -51,7 +51,7 @@
                            resetCodeIdxList = this.getResetCodeList(lev, tasks.get(0));
                        } else if (tasks.size() > 1) {
//                            log.info("consumer task count:{}", tasks.size());
                            resetCodeIdxList = this.getResetCodeList(lev,tasks);
                            resetCodeIdxList = this.getResetCodeList(lev, tasks);
                        }

                        if (!Cools.isEmpty(resetCodeIdxList)) {