diff --git a/client/src/main/java/ctbrec/ui/sites/myfreecams/MyFreeCamsAbstractUpdateService.java b/client/src/main/java/ctbrec/ui/sites/myfreecams/MyFreeCamsAbstractUpdateService.java index 197931c2..ea1d0f98 100644 --- a/client/src/main/java/ctbrec/ui/sites/myfreecams/MyFreeCamsAbstractUpdateService.java +++ b/client/src/main/java/ctbrec/ui/sites/myfreecams/MyFreeCamsAbstractUpdateService.java @@ -15,14 +15,13 @@ public abstract class MyFreeCamsAbstractUpdateService extends PaginatedScheduled MyFreeCamsClient client = MyFreeCamsClient.getInstance(); protected List getModels() { - List models = client.getModels().stream() - .toList(); + List models = client.getModels().stream().toList(); for (Model model : models) { GlobalThreadPool.submit(() -> { try { client.getSessionState(model); - model.isOnline(true); + model.isOnline(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } catch (Exception e) { diff --git a/common/src/main/java/ctbrec/GlobalThreadPool.java b/common/src/main/java/ctbrec/GlobalThreadPool.java index 71e93701..67ad5c8b 100644 --- a/common/src/main/java/ctbrec/GlobalThreadPool.java +++ b/common/src/main/java/ctbrec/GlobalThreadPool.java @@ -1,19 +1,16 @@ package ctbrec; -import java.util.UUID; +import lombok.extern.slf4j.Slf4j; + import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; +@Slf4j public class GlobalThreadPool { - private static final ExecutorService threadPool = Executors.newCachedThreadPool(r -> { - Thread t = new Thread(r); - t.setDaemon(true); - t.setName("GlobalWorker-" + UUID.randomUUID().toString().substring(0, 8)); - return t; - }); + private static final ExecutorService threadPool = Executors.newWorkStealingPool(); private GlobalThreadPool() { }