From 5a5e59cd91380e1bc2d4c5917b622b1f77fcc8f3 Mon Sep 17 00:00:00 2001
From: CodingPF <j-doo@gmx.de>
Date: Wed, 8 Nov 2023 07:54:19 +0100
Subject: [PATCH] change to configurable pool size

---
 .../base/utils/CheckUrlAvailability.java      | 27 ++++++++++++-------
 .../mserver/crawler/CrawlerManager.java       |  8 +++++-
 2 files changed, 24 insertions(+), 11 deletions(-)

diff --git a/src/main/java/de/mediathekview/mserver/base/utils/CheckUrlAvailability.java b/src/main/java/de/mediathekview/mserver/base/utils/CheckUrlAvailability.java
index 45dc0eadd..7a8df2725 100644
--- a/src/main/java/de/mediathekview/mserver/base/utils/CheckUrlAvailability.java
+++ b/src/main/java/de/mediathekview/mserver/base/utils/CheckUrlAvailability.java
@@ -1,6 +1,8 @@
 package de.mediathekview.mserver.base.utils;
 
 
+import java.util.concurrent.ForkJoinPool;
+
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
@@ -14,16 +16,19 @@
 
 public class CheckUrlAvailability {
   private static final Logger LOG = LogManager.getLogger(CheckUrlAvailability.class);
+  private final FileSizeDeterminer fsd;
+  private int numberOfThreads = 10;
   private Long minFileSize = 2048L;
   private int removedCounter = 0;
   private long timeoutInMS = 1*60*1000L;
   private boolean timeout = false;
   private long start = 0;
-  private FileSizeDeterminer fsd = new FileSizeDeterminer();
-
-  public CheckUrlAvailability(long minFileSize, long timeoutInSec) {
+  
+  public CheckUrlAvailability(final long minFileSize, final long timeoutInSec, final int numberOfThreads) {
     this.minFileSize = minFileSize;
     this.timeoutInMS = timeoutInSec*1000;
+    this.numberOfThreads = numberOfThreads;
+    fsd = new FileSizeDeterminer(30L, 30L, numberOfThreads);
   }
   
   public Filmlist getAvaiableFilmlist(final Filmlist importList) {
@@ -32,7 +37,14 @@ public Filmlist getAvaiableFilmlist(final Filmlist importList) {
     Filmlist filteredFilmlist = new Filmlist();
     filteredFilmlist.setCreationDate(importList.getCreationDate());
     filteredFilmlist.setListId(importList.getListId());
-    importList.getFilms().values().stream().parallel().filter(this::isAvailable).forEach(filteredFilmlist::add);
+    //
+    ForkJoinPool customThreadPool = new ForkJoinPool(numberOfThreads);
+    customThreadPool.submit(() -> importList.getFilms().values().parallelStream()
+            .filter(this::isAvailable)
+            .forEach(filteredFilmlist::add))
+            .join();
+    customThreadPool.shutdown();
+    //
     LOG.debug("checked {} urls and removed {} in {} sec and timeout was reached: {}", importList.getFilms().size(), removedCounter, ((System.currentTimeMillis()-start)/1000), timeout);
     return filteredFilmlist;
   }
@@ -49,7 +61,7 @@ private boolean isAvailable(Film pFilm) {
     if (pFilm.getThema().equalsIgnoreCase("Livestream")) {
       // do not remove livestreams
       return true;
-    } else if (ri.getCode() == 404) {
+    } else if (!(ri.getCode() >= 200 && ri.getCode() < 300)) {
       LOG.debug("Film response ({}): {} # {} # {} # {} ", ri.getCode(), normalUrl, pFilm.getSender(), pFilm.getThema(), pFilm.getTitel());
       removedCounter++;
       return false;
@@ -66,11 +78,6 @@ private boolean isAvailable(Film pFilm) {
       removedCounter++;
       return false;
     }
-    // just for debugging
-    if (ri.getCode() != 200) {
-      LOG.debug("Film not removed but status!=200 ({}): {} # {} # {} # {} ", ri.getCode(), normalUrl, pFilm.getSender(), pFilm.getThema(), pFilm.getTitel());
-    }
-    
     return true;
   }
   
diff --git a/src/main/java/de/mediathekview/mserver/crawler/CrawlerManager.java b/src/main/java/de/mediathekview/mserver/crawler/CrawlerManager.java
index 245a3bf16..6ab02771c 100644
--- a/src/main/java/de/mediathekview/mserver/crawler/CrawlerManager.java
+++ b/src/main/java/de/mediathekview/mserver/crawler/CrawlerManager.java
@@ -192,7 +192,13 @@ public void importFilmlist(final ImportFilmlistConfiguration importFilmlistConfi
       }
       //
       if (importFilmlistConfiguration.isCheckImportListUrl() && importedFilmlist.isPresent() ) {
-        importedFilmlist = Optional.of(new CheckUrlAvailability(config.getCheckImportListUrlMinSize() ,config.getCheckImportListUrlTimeoutInSec()).getAvaiableFilmlist(importedFilmlist.get()));
+        importedFilmlist = Optional.of(
+            new CheckUrlAvailability(
+                config.getCheckImportListUrlMinSize(),
+                config.getCheckImportListUrlTimeoutInSec(),
+                config.getMaximumCpuThreads())
+            .getAvaiableFilmlist(importedFilmlist.get())
+        );
       }
       //
       final Filmlist difflist = new Filmlist(UUID.randomUUID(), LocalDateTime.now());