#

luxiaotao1123

2025-01-08 42e63efa6589342e0f9cff4389b986cf1c713c0b

#

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

@@ -492,8 +492,8 @@
        DynamicNode[][] dynamicMatrix = getDynamicMatrix(lev);
        String[][] codeMatrix = this.getCodeMatrix(lev);

        // concurrent
        ConcurrentLinkedQueue<SortCodeDto> codeList = new ConcurrentLinkedQueue<>();

        IntStream.range(0, codeMatrix.length).parallel().forEach(i -> {
            for (int j = 0; j < codeMatrix[i].length; j++) {
                DynamicNode dynamicNode = dynamicMatrix[i][j];
@@ -503,13 +503,8 @@
            }
        });

        return codeList.stream()
                .sorted(Comparator.comparingInt(SortCodeDto::getSerial))
                .map(SortCodeDto::getCode)
                .collect(Collectors.toList());

        // synchronize
//        List<SortCodeDto> codeList = new ArrayList<>();

//        for (int i = 0; i < codeMatrix.length; i++) {
//            for (int j = 0; j < codeMatrix[i].length; j++) {
//                DynamicNode dynamicNode = dynamicMatrix[i][j];
@@ -518,8 +513,11 @@
//                }
//            }
//        }
//        codeList.sort(Comparator.comparingInt(SortCodeDto::getSerial));
//        return codeList.stream().map(SortCodeDto::getCode).collect(Collectors.toList());

        return codeList.stream()
                .sorted(Comparator.comparingInt(SortCodeDto::getSerial))
                .map(SortCodeDto::getCode)
                .collect(Collectors.toList());
    }

    public void modifyDynamicMatrix(Integer lev, List<int[]> codeIdxList, String vehicle) {