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);
         }