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) {