From 3d9c03fa5047b822861d304977ad1a7abceeff63 Mon Sep 17 00:00:00 2001 From: CodingPF Date: Wed, 8 Nov 2023 07:53:01 +0100 Subject: [PATCH] chnage to configurable pool size --- .../mlib/tool/FileSizeDeterminer.java | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/src/main/java/de/mediathekview/mlib/tool/FileSizeDeterminer.java b/src/main/java/de/mediathekview/mlib/tool/FileSizeDeterminer.java index 28743906..7edaef37 100644 --- a/src/main/java/de/mediathekview/mlib/tool/FileSizeDeterminer.java +++ b/src/main/java/de/mediathekview/mlib/tool/FileSizeDeterminer.java @@ -1,5 +1,6 @@ package de.mediathekview.mlib.tool; +import okhttp3.ConnectionPool; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; @@ -8,6 +9,7 @@ import org.jetbrains.annotations.NotNull; import java.io.IOException; +import java.util.concurrent.TimeUnit; import static jakarta.ws.rs.core.HttpHeaders.CONTENT_LENGTH; import static jakarta.ws.rs.core.HttpHeaders.CONTENT_TYPE; @@ -19,17 +21,18 @@ public class FileSizeDeterminer { public FileSizeDeterminer() { - this(30L,30L); + this(30L, 30L, 10); } public FileSizeDeterminer( - final long connectTimeoutInSeconds, final long readTimeoutInSeconds) { - client = - new OkHttpClientBuilder() - .withConnectTimeout(connectTimeoutInSeconds) - .withReadTimeout(readTimeoutInSeconds) - .build(); + final long connectTimeoutInSeconds, final long readTimeoutInSeconds, final int threadPoolSize) { + OkHttpClient.Builder b = new OkHttpClient.Builder(); + b.readTimeout(readTimeoutInSeconds,TimeUnit.SECONDS); + b.connectTimeout(connectTimeoutInSeconds,TimeUnit.SECONDS); + b.connectionPool(new ConnectionPool(threadPoolSize, 5L, TimeUnit.MINUTES)); + client = b.build(); } + public RespoonseInfo getRequestInfo(final String url) { return getRequestInfo(url, RequestType.HEAD); }