From adabe88648cda638af2b6a256e96967c004a1734 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Mon, 15 Dec 2025 13:56:54 +0800
Subject: [PATCH] =?UTF-8?q?fix(video):=20=E8=B0=83=E6=95=B4=E8=A7=86?=
 =?UTF-8?q?=E9=A2=91=E5=A4=84=E7=90=86=E4=BB=BB=E5=8A=A1=E5=8F=82=E6=95=B0?=
 =?UTF-8?q?=E4=BB=A5=E4=BC=98=E5=8C=96=E6=80=A7=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将探测大小从 32M 减小到 16M 以减少内存占用
- 修改线程池关闭前的等待时间从 5 分钟缩短至 3 分钟
- 添加注释说明批量定时停止的目的
---
 src/main/java/com/ycwl/basic/task/VideoPieceGetter.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
index 993bad6a..0ede072b 100644
--- a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
+++ b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
@@ -84,7 +84,7 @@ public class VideoPieceGetter {
     @Autowired
     private MemberRelationRepository memberRelationRepository;
 
-    public static final String PROBE_SIZE = "32M";
+    public static final String PROBE_SIZE = "16M";
 
     @Data
     public static class Task {
@@ -141,6 +141,7 @@ public class VideoPieceGetter {
 //            taskStatusBiz.setFaceCutStatus(task.faceId, 0);
 //        }
         AtomicBoolean invoke = new AtomicBoolean(false);
+        // 为了批量定时停止
         final ThreadFactory threadFactory = new ThreadFactoryBuilder()
                 .setNamePrefix("VPG-" + task.faceId + "-t")
                 .build();
@@ -264,7 +265,7 @@ public class VideoPieceGetter {
             Thread.sleep(1000L);
             log.info("executor等待被结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount());
             executor.shutdown();
-            executor.awaitTermination(5, TimeUnit.MINUTES);
+            executor.awaitTermination(3, TimeUnit.MINUTES);
             log.info("executor已结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount());
             executor.close();
         } catch (InterruptedException e) {