#算法耗时优化

Junjie

2026-04-13 89433d782a834ae4ab1835a0b70fa16340bbbd49

#算法耗时优化

 src/main/java/com/zy/common/utils/NavigateUtils.java

@@ -2141,7 +2141,7 @@
        Map<Integer, StationTaskTraceVo> traceMap = new LinkedHashMap<>();
        if (stationTaskTraceRegistry != null) {
            try {
                List<StationTaskTraceVo> traceList = stationTaskTraceRegistry.listLatestTraces();
                List<StationTaskTraceVo> traceList = stationTaskTraceRegistry.listPlanningActiveTraceSnapshots();
                if (traceList != null) {
                    for (StationTaskTraceVo traceVo : traceList) {
                        if (!isPlanningActiveTrace(traceVo)) {

 src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java

@@ -205,6 +205,31 @@
        return result;
    }

    public List<StationTaskTraceVo> listPlanningActiveTraceSnapshots() {
        ensureCacheLoaded();
        cleanupExpired();
        List<StationTaskTraceVo> result = new ArrayList<>();
        for (TraceTaskState state : taskStateMap.values()) {
            if (state == null) {
                continue;
            }
            StationTaskTraceVo traceVo = state.toPlanningVo();
            if (traceVo == null) {
                continue;
            }
            result.add(traceVo);
        }
        result.sort(new Comparator<StationTaskTraceVo>() {
            @Override
            public int compare(StationTaskTraceVo a, StationTaskTraceVo b) {
                long av = a.getUpdatedAt() == null ? 0L : a.getUpdatedAt();
                long bv = b.getUpdatedAt() == null ? 0L : b.getUpdatedAt();
                return Long.compare(bv, av);
            }
        });
        return result;
    }

    private void cleanupExpired() {
        long now = System.currentTimeMillis();
        for (Map.Entry<Integer, TraceTaskState> entry : taskStateMap.entrySet()) {
@@ -703,6 +728,24 @@
            return vo;
        }

        private synchronized StationTaskTraceVo toPlanningVo() {
            if (isTerminalStatus(this.status)) {
                return null;
            }
            StationTaskTraceVo vo = new StationTaskTraceVo();
            vo.setTaskNo(taskNo);
            vo.setThreadImpl(threadImpl);
            vo.setStatus(status);
            vo.setTraceVersion(traceVersion);
            vo.setStartStationId(startStationId);
            vo.setCurrentStationId(currentStationId);
            vo.setFinalTargetStationId(finalTargetStationId);
            vo.setPendingStationIds(copyIntegerList(pendingStationIds));
            vo.setLatestIssuedSegmentPath(copyIntegerList(latestIssuedSegmentPath));
            vo.setUpdatedAt(updatedAt);
            return vo;
        }

        private synchronized TraceSnapshot toSnapshot() {
            TraceSnapshot snapshot = new TraceSnapshot();
            snapshot.setTaskNo(taskNo);