diff --git a/src/main/java/com/tuoheng/steam/service/TaskService.java b/src/main/java/com/tuoheng/steam/service/TaskService.java index a5ed5a0..69b303e 100644 --- a/src/main/java/com/tuoheng/steam/service/TaskService.java +++ b/src/main/java/com/tuoheng/steam/service/TaskService.java @@ -42,7 +42,7 @@ 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() - 30 * 60 * 1000 ) { + if(streamTask.getStartTime().getTime() < new Date().getTime() - 90 * 60 * 1000 ) { logger.info("清理废弃任务 {}", JSON.toJSONString(streamTask)); try { StreamTask s = stopTask(entry.getKey());