diff --git a/src/main/java/com/tuoheng/steam/service/TaskService.java b/src/main/java/com/tuoheng/steam/service/TaskService.java index 0ad75d9..5b8ec56 100644 --- a/src/main/java/com/tuoheng/steam/service/TaskService.java +++ b/src/main/java/com/tuoheng/steam/service/TaskService.java @@ -1,5 +1,6 @@ package com.tuoheng.steam.service; +import com.alibaba.fastjson2.JSON; import com.tuoheng.steam.dos.StreamProcess; import com.tuoheng.steam.dos.StreamTask; import com.tuoheng.steam.service.innerService.ProcessService; @@ -35,7 +36,8 @@ public class TaskService implements ITaskService{ public void cleaTask() { for (ConcurrentHashMap.Entry entry : runningTasks.entrySet()) { StreamTask streamTask = entry.getValue(); - if(streamTask.getStartTime().getTime() < new Date().getTime() - 60 * 20 *60 ) { + if(streamTask.getStartTime().getTime() < new Date().getTime() - 30 * 60 * 1000 ) { + logger.info("清理废弃任务 {}", JSON.toJSONString(streamTask)); StreamTask s = stopTask(entry.getKey()); scheduler.schedule(() -> { File file = new File(targetPath +"/"+ s.getOutFileName());