q792602257/FrameTour-BE
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整一下切片逻辑

Browse Source
This commit is contained in:
Jerry Yan
2025-06-17 14:12:43 +08:00
parent fae62ab7c2
commit b0c8643e92
1 changed files with 12 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/ycwl/basic/task/VideoPieceGetter.java
View File

@ -181,14 +181,11 @@ public class VideoPieceGetter {
.map(Map.Entry::getKey).forEach(pairDeviceId -> { .map(Map.Entry::getKey).forEach(pairDeviceId -> {
log.info("找到同景区关联设备：{} -> {}", pairDeviceId, faceSample.getDeviceId()); log.info("找到同景区关联设备：{} -> {}", pairDeviceId, faceSample.getDeviceId());
if (pairDeviceId != null) { if (pairDeviceId != null) {
executor.execute(() -> {
doCut(pairDeviceId, faceSample.getId(), faceSample.getCreateAt(), task); doCut(pairDeviceId, faceSample.getId(), faceSample.getCreateAt(), task);
currentUnFinPlaceholder.remove(faceSample.getDeviceId().toString()); currentUnFinPlaceholder.remove(faceSample.getDeviceId().toString());
});
} }
}); });
} }
executor.execute(() -> {
doCut(faceSample.getDeviceId(), faceSample.getId(), faceSample.getCreateAt(), task); doCut(faceSample.getDeviceId(), faceSample.getId(), faceSample.getCreateAt(), task);
currentUnFinPlaceholder.remove(faceSample.getDeviceId().toString()); currentUnFinPlaceholder.remove(faceSample.getDeviceId().toString());
if (templatePlaceholder != null) { if (templatePlaceholder != null) {
@ -203,13 +200,13 @@ public class VideoPieceGetter {
}); });
}); });
}); });
});
try { try {
Thread.sleep(1000L); Thread.sleep(1000L);
log.info("executor等待被结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount()); log.info("executor等待被结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount());
executor.shutdown(); executor.shutdown();
executor.awaitTermination(5, TimeUnit.MINUTES); executor.awaitTermination(5, TimeUnit.MINUTES);
log.info("executor已结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount()); log.info("executor已结束！[A:{}/T:{}/F:{}]", executor.getActiveCount(), executor.getTaskCount(), executor.getCompletedTaskCount());
executor.close();
} catch (InterruptedException e) { } catch (InterruptedException e) {
return; return;
} finally { } finally {