diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-04-01 09:37:44 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-04-01 09:37:44 +0200 |
commit | ae6984c4b0a3983fb4ca1616fdf7407ce2c39da0 (patch) | |
tree | b6f17dca78dd857051def14ed56f5045aa9df5ee /filedistribution/src | |
parent | ede7a4ac09e169813087b05d8b98818332b6578c (diff) |
Use minimum 8 threads
Diffstat (limited to 'filedistribution/src')
-rw-r--r-- | filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java index 66b86866c3e..8a0212211e1 100644 --- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java +++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java @@ -37,7 +37,8 @@ public class FileReferenceDownloader { private final static Duration rpcTimeout = Duration.ofSeconds(10); private final ExecutorService downloadExecutor = - Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), new DaemonThreadFactory("filereference downloader")); + Executors.newFixedThreadPool(Math.max(8, Runtime.getRuntime().availableProcessors()), + new DaemonThreadFactory("filereference downloader")); private final ConnectionPool connectionPool; private final Map<FileReference, FileReferenceDownload> downloads = new LinkedHashMap<>(); private final Map<FileReference, Double> downloadStatus = new HashMap<>(); // between 0 and 1 |