refactor: 测试结束时清理待执行队列

eac7a050 · CaptainB · 2075eba1 · eac7a050
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

src/main/java/io/metersphere/streaming/commons/utils/ReportTasks.java ...a/io/metersphere/streaming/commons/utils/ReportTasks.java +3 -1

未找到文件。
--- a/src/main/java/io/metersphere/streaming/commons/utils/ReportTasks.java
+++ b/src/main/java/io/metersphere/streaming/commons/utils/ReportTasks.java
@@ -20,7 +20,9 @@ public class ReportTasks {
    public static void clearTasks(String reportId) {
        for (Future<?> task : getTasks(reportId)) {
            try {
-                task.cancel(true);
+                if (!task.isDone()) {
+                    task.cancel(true);
+                }
            } catch (Exception e) {
                LogUtil.error("取消任务失败: ", e);
            }