sunpeng
/
stream_srs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改录制时长

This commit is contained in:
孙小云 2025-04-24 16:42:53 +08:00
parent 613d6d3dc5
commit 03a23330bb
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/tuoheng/steam/service/TaskService.java
View File

@ -42,7 +42,7 @@ public class TaskService implements ITaskService{
public void cleaTask() { public void cleaTask() {
for (ConcurrentHashMap.Entry<String, StreamTask> entry : runningTasks.entrySet()) { for (ConcurrentHashMap.Entry<String, StreamTask> entry : runningTasks.entrySet()) {
StreamTask streamTask = entry.getValue(); 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)); logger.info("清理废弃任务 {}", JSON.toJSONString(streamTask));
try { try {
StreamTask s = stopTask(entry.getKey()); StreamTask s = stopTask(entry.getKey());