From 66d234e668d83bc7f360e2fff4fbcd18505ab655 Mon Sep 17 00:00:00 2001 From: 0xb00bface <0xboobface@gmail.com> Date: Sat, 16 Jan 2021 15:52:07 +0100 Subject: [PATCH] Remove restriction of download thread pool size (was 100 before) --- CHANGELOG.md | 5 +++++ .../src/main/java/ctbrec/recorder/NextGenLocalRecorder.java | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 6ff84c2f..2b46e195 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,8 @@ +3.12.3 +======================== +* Recording size now takes all associated files into account +* Removed restriction of download thread pool size (was 100 before) + 3.12.2 ======================== * Fix: Some Cam4 URLs were broken diff --git a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java index d595f437..ff0e04a9 100644 --- a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java +++ b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java @@ -71,7 +71,7 @@ public class NextGenLocalRecorder implements Recorder { // thread pools for downloads and post-processing private BlockingQueue downloadQueue = new SynchronousQueue<>(); - private ThreadPoolExecutor downloadPool = new ThreadPoolExecutor(2, 100, 5, TimeUnit.MINUTES, downloadQueue, createThreadFactory("Download")); + private ThreadPoolExecutor downloadPool = new ThreadPoolExecutor(2, Integer.MAX_VALUE, 5, TimeUnit.MINUTES, downloadQueue, createThreadFactory("Download")); private ExecutorCompletionService completionService = new ExecutorCompletionService<>(downloadPool); private BlockingQueue ppQueue = new LinkedBlockingQueue<>();