[leanback] update dev

app/build.gradle

@@ -17,7 +17,7 @@ android {
         leanback {
             dimension "mode"
             versionCode 69
-            versionName "20230309"
+            versionName "20230309#2"
         }
         mobile {
             dimension "mode"

app/src/leanback/java/com/fongmi/android/tv/ui/activity/CollectActivity.java

@@ -123,9 +123,7 @@ public class CollectActivity extends BaseActivity {
     private void search() {
         mAdapter.add(Collect.all());
         mPageAdapter.notifyDataSetChanged();
-        int core = Runtime.getRuntime().availableProcessors();
-        int corePoolSize = Math.max(Constant.THREAD_POOL, core);
-        mExecutor = new PauseThreadPoolExecutor(corePoolSize, corePoolSize, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
+        mExecutor = new PauseThreadPoolExecutor(Constant.THREAD_POOL, 0, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
         mBinding.result.setText(getString(R.string.collect_result, getKeyword()));
         for (Site site : mSites) mExecutor.execute(() -> search(site));
     }

app/src/leanback/java/com/fongmi/android/tv/ui/activity/DetailActivity.java

@@ -854,7 +854,7 @@ public class DetailActivity extends BaseActivity implements CustomKeyDownVod.Lis
 
     private void startSearch(String keyword) {
         mSearchAdapter.clear();
-        mExecutor = Executors.newFixedThreadPool(Constant.THREAD_POOL * 2);
+        mExecutor = Executors.newFixedThreadPool(Constant.THREAD_POOL);
         for (Site site : ApiConfig.get().getSites()) {
             if (site.getKey().equals(getKey())) continue;
             if (isAutoMode() && !site.isChangeable()) continue;

app/src/main/java/com/fongmi/android/tv/Constant.java

@@ -22,5 +22,5 @@ public class Constant {
     //代理超時時間
     public static final int TIMEOUT_GITHUB = 5 * 1000;
     //搜尋線程數量
-    public static final int THREAD_POOL = 5;
+    public static final int THREAD_POOL = 7;
 }

app/src/main/java/com/fongmi/android/tv/utils/PauseThreadPoolExecutor.java

@@ -12,8 +12,8 @@ public class PauseThreadPoolExecutor extends ThreadPoolExecutor {
     private final Condition condition;
     private boolean isPaused;
 
-    public PauseThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
-        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
+    public PauseThreadPoolExecutor(int corePoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
+        super(corePoolSize, corePoolSize, keepAliveTime, unit, workQueue);
         pauseLock = new ReentrantLock();
         condition = pauseLock.newCondition();
     }