davebluke
/
ctbrec
forked from j62/ctbrec
1
0
Fork 0
Code Pull Requests Activity

Replace CompletableFuture with a submit to segmentDownloadPool

This commit is contained in:
0xb00bface 2021-01-16 23:02:14 +01:00
parent fa7f1e5f57
commit 3fedfe4be7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java
View File

@ -158,7 +158,7 @@ public class NextGenLocalRecorder implements Recorder {
ScheduledFuture<Recording> rescheduledFuture = downloadPool.schedule(rec, delay, TimeUnit.MILLISECONDS); ScheduledFuture<Recording> rescheduledFuture = downloadPool.schedule(rec, delay, TimeUnit.MILLISECONDS);
downloadFutureQueue.add(rescheduledFuture); downloadFutureQueue.add(rescheduledFuture);
} else { } else {
CompletableFuture.runAsync(() -> { segmentDownloadPool.submit(() -> {
deleteIfEmpty(rec); deleteIfEmpty(rec);
removeRecordingProcess(rec); removeRecordingProcess(rec);
if (rec.getStatus() == State.WAITING) { if (rec.getStatus() == State.WAITING) {