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

Remove restriction of download thread pool size (was 100 before)

This commit is contained in:
0xb00bface 2021-01-16 15:52:07 +01:00
parent 19da3c43bf
commit 66d234e668
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
CHANGELOG.md
View File

@ -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 3.12.2
======================== ========================
* Fix: Some Cam4 URLs were broken * Fix: Some Cam4 URLs were broken

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

@ -71,7 +71,7 @@ public class NextGenLocalRecorder implements Recorder {
// thread pools for downloads and post-processing // thread pools for downloads and post-processing
private BlockingQueue<Runnable> downloadQueue = new SynchronousQueue<>(); private BlockingQueue<Runnable> 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<Recording> completionService = new ExecutorCompletionService<>(downloadPool); private ExecutorCompletionService<Recording> completionService = new ExecutorCompletionService<>(downloadPool);
private BlockingQueue<Runnable> ppQueue = new LinkedBlockingQueue<>(); private BlockingQueue<Runnable> ppQueue = new LinkedBlockingQueue<>();