From ee7249d63b6ddf23b90c93320c429ac246420a9b Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Mon, 3 Mar 2025 18:08:31 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=BB=E5=8A=A8=E5=BB=BAthread?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/ycwl/basic/task/VideoPieceGetter.java | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
index 44afaeb..17a93af 100644
--- a/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
+++ b/src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
@@ -123,10 +123,8 @@ public class VideoPieceGetter {
                 })
                 .collect(Collectors.groupingBy(FaceSampleEntity::getDeviceId))
                 .values();
-        collection
-                .stream()
-                .parallel()
-                .forEach(faceSampleList -> {
+        collection.forEach(faceSampleList -> {
+                new Thread(() -> {
                     faceSampleList.parallelStream().forEach(faceSample -> {
                         DeviceEntity device = deviceRepository.getDevice(faceSample.getDeviceId());
                         DeviceConfigEntity config = deviceRepository.getDeviceConfig(faceSample.getDeviceId());
@@ -254,7 +252,8 @@ public class VideoPieceGetter {
                             }
                         }
                     });
-                });
+                }).start();
+        });
         if (task.faceId != null) {
             taskStatusBiz.setFaceCutStatus(task.faceId, 1);
         }