diff --git a/backend/src/main/java/io/metersphere/api/jmeter/APIBackendListenerHandler.java b/backend/src/main/java/io/metersphere/api/jmeter/APIBackendListenerHandler.java index a91d375f12..4e34729c9c 100644 --- a/backend/src/main/java/io/metersphere/api/jmeter/APIBackendListenerHandler.java +++ b/backend/src/main/java/io/metersphere/api/jmeter/APIBackendListenerHandler.java @@ -82,8 +82,8 @@ public class APIBackendListenerHandler { testResult.setConsole(resultService.getJmeterLogger(testId, true)); testResultService.saveResult(testResult, this.runMode, this.debugReportId, this.testId); // 清除已经中断的过程数据 - if (!MessageCache.reportCache.containsKey(testId) && resultService.processCache.containsKey(testId)) { - resultService.processCache.remove(testId); + if (!MessageCache.reportCache.containsKey(testId) && resultService.getProcessCache().containsKey(testId)) { + resultService.getProcessCache().remove(testId); } } diff --git a/backend/src/main/java/io/metersphere/api/service/MsResultService.java b/backend/src/main/java/io/metersphere/api/service/MsResultService.java index 8d13d34495..407adc1c42 100644 --- a/backend/src/main/java/io/metersphere/api/service/MsResultService.java +++ b/backend/src/main/java/io/metersphere/api/service/MsResultService.java @@ -24,7 +24,11 @@ import java.util.stream.Collectors; public class MsResultService { // 零时存放实时结果 private Cache cache = Cache.newHardMemoryCache(0, 3600 * 2); - public ConcurrentHashMap> processCache = new ConcurrentHashMap<>(); + private ConcurrentHashMap> processCache = new ConcurrentHashMap<>(); + + public ConcurrentHashMap> getProcessCache() { + return processCache; + } private final static String THREAD_SPLIT = " ";