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