代码调整。

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/DatasetCleanServiceImpl.java

@@ -35,7 +35,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.io.*;
 import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Future;
 import java.util.stream.Collectors;
 
@@ -62,8 +61,6 @@ public class DatasetCleanServiceImpl extends BaseService<DatasetClean, Long> imp
     @Autowired
     private DatasetVersionService datasetVersionService;
 
-    private final ConcurrentHashMap<Long, Future<?>> futures = new ConcurrentHashMap<>();
-
     /**
      * 返回当前Service的主表Mapper对象。
      *
@@ -177,10 +174,6 @@ public class DatasetCleanServiceImpl extends BaseService<DatasetClean, Long> imp
      */
     @Override
     public void stopCleanTask(Long cleanId) {
-        Future<?> future = futures.remove(cleanId);
-        if (future != null && !future.isDone()) {
-            future.cancel(true);
-        }
         DatasetClean filter = this.datasetCleanMapper.selectById(cleanId);
         if(null != filter){
             updateCleanStatus(cleanId,DatasetConstant.PAUSE_FINISHED);

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/DatasetDataServiceImpl.java

@@ -41,11 +41,6 @@ public class DatasetDataServiceImpl implements DatasetDataService {
     @Autowired
     private DatasetCleanService datasetCleanService;
 
-    /**
-     * 线程集合
-     */
-    private final ConcurrentHashMap<Long, Future<?>> futures = new ConcurrentHashMap<>();
-
     /**
      * 保存新增对象。
      *
@@ -103,8 +98,7 @@ public class DatasetDataServiceImpl implements DatasetDataService {
         param.setPageSize(DatasetConstant.MAX_PAGE_SIZE);
         List<DatasetData> dataList = this.list(datasetId, param);
         if(CollUtil.isNotEmpty(dataList)) {
-            Future<Long> future = datasetCleanService.executeCleanTaskAsync(dataList, cleanId, datasetId);
-            futures.put(cleanId, future);
+            datasetCleanService.executeCleanTaskAsync(dataList, cleanId, datasetId);
         }
     }