#

luxiaotao1123

2025-01-07 0a3cbfd5731c46c2a89cc6a7b4ff5096dc89a315

#

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

@@ -37,16 +37,13 @@
        this.consumerExecutor.execute(() -> {
            while (!Thread.currentThread().isInterrupted()) {
                try {

                    Thread.sleep(30);
                    List<UnlockPathTask> tasks = new ArrayList<>();
                    // if unlockTaskQueue was empty, then block
//                    tasks.add(unlockTaskQueue.take());
                    tasks.add(unlockTaskQueue.take());
                    unlockTaskQueue.drainTo(tasks);

                    if (tasks.isEmpty()) {
                        Thread.sleep(30);
                    } else {

                    if (!Cools.isEmpty(tasks)) {
                        long startTime = System.currentTimeMillis();

                        List<int[]> resetCodeIdxList = null;