From 0bdcd2680178e9e6e81c776bfc2d886ac8252825 Mon Sep 17 00:00:00 2001 From: "Goulven.Furet" Date: Thu, 7 Dec 2023 16:18:17 +0100 Subject: [PATCH] Legacy treadpools (no virtual thread) --- .../services/fetching/CsvDatasourceFetchingService.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvDatasourceFetchingService.java b/crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvDatasourceFetchingService.java index d37bd5b9f..5225a2d0c 100644 --- a/crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvDatasourceFetchingService.java +++ b/crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvDatasourceFetchingService.java @@ -112,8 +112,9 @@ public CsvDatasourceFetchingService(final DataFragmentCompletionService completi this.completionService = completionService; this.fetcherProperties = fetcherProperties; // The CSV executor can have at most the fetcher max indexation tasks threads - executor = Executors.newFixedThreadPool(fetcherProperties.getConcurrentFetcherTask(), Thread.ofVirtual().factory()); - +// TODO : see with @Nico + // executor = Executors.newFixedThreadPool(fetcherProperties.getConcurrentFetcherTask(), Thread.ofVirtual().factory()); + executor = Executors.newFixedThreadPool(fetcherProperties.getConcurrentFetcherTask()); }