From aedd800a2601e430a83315a0a56e76d732dc98a4 Mon Sep 17 00:00:00 2001 From: FongMi Date: Sat, 29 Jul 2023 17:41:07 +0800 Subject: [PATCH] Update SiteViewModel.java --- .../java/com/fongmi/android/tv/model/SiteViewModel.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/app/src/main/java/com/fongmi/android/tv/model/SiteViewModel.java b/app/src/main/java/com/fongmi/android/tv/model/SiteViewModel.java index 935d5effb..3128050da 100644 --- a/app/src/main/java/com/fongmi/android/tv/model/SiteViewModel.java +++ b/app/src/main/java/com/fongmi/android/tv/model/SiteViewModel.java @@ -26,7 +26,6 @@ import com.github.catvod.utils.Util; import java.util.ArrayList; import java.util.Arrays; -import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.concurrent.Callable; @@ -219,9 +218,8 @@ public class SiteViewModel extends ViewModel { List magnets = new ArrayList<>(); List items = new ArrayList<>(); for (Vod.Flag.Episode episode : flag.getEpisodes()) if (Sniffer.isThunder(episode.getUrl())) magnets.add(Magnet.get(episode.getUrl())); - ExecutorService executor = Executors.newCachedThreadPool(); - for (Future> future : executor.invokeAll(magnets, 15, TimeUnit.SECONDS)) items.addAll(future.get()); - if (items.size() > 0) Collections.sort(items, (o1, o2) -> o1.getName().compareTo(o2.getName())); + ExecutorService executor = Executors.newFixedThreadPool(Constant.THREAD_POOL * 2); + for (Future> future : executor.invokeAll(magnets, 30, TimeUnit.SECONDS)) items.addAll(future.get()); if (items.size() > 0) flag.setEpisodes(items); executor.shutdownNow(); }