From abe39c5eb999d5f26be5d5e4b87d082c344e1427 Mon Sep 17 00:00:00 2001 From: fengyuecanzhu <1021300691@qq.com> Date: Thu, 13 May 2021 18:44:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/src/main/java/xyz/fycz/myreader/application/App.java | 4 ++++ .../main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java | 3 +++ .../xyz/fycz/myreader/ui/presenter/BookcasePresenter.java | 3 ++- 3 files changed, 9 insertions(+), 1 deletion(-) diff --git a/app/src/main/java/xyz/fycz/myreader/application/App.java b/app/src/main/java/xyz/fycz/myreader/application/App.java index 3010287..71d713b 100644 --- a/app/src/main/java/xyz/fycz/myreader/application/App.java +++ b/app/src/main/java/xyz/fycz/myreader/application/App.java @@ -513,4 +513,8 @@ public class App extends Application { public static boolean isDebug() { return debug; } + + public ExecutorService getmFixedThreadPool() { + return mFixedThreadPool; + } } diff --git a/app/src/main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java b/app/src/main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java index c90b950..2389693 100644 --- a/app/src/main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java +++ b/app/src/main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java @@ -47,6 +47,8 @@ import java.util.List; import java.util.Locale; import io.reactivex.Observable; +import io.reactivex.internal.schedulers.ExecutorScheduler; +import io.reactivex.schedulers.Schedulers; import xyz.fycz.myreader.ActivityManage; import xyz.fycz.myreader.R; import xyz.fycz.myreader.application.App; @@ -1587,6 +1589,7 @@ public class ReadActivity extends BaseActivity implements ColorPickerDialogListe chapter.setId(mBook.getId()); } CommonApi.getChapterContent(chapter.getUrl(), mReadCrawler) + .subscribeOn(Schedulers.from(App.getApplication().getmFixedThreadPool())) .subscribe(new MyObserver() { @Override public void onNext(@NotNull String s) { diff --git a/app/src/main/java/xyz/fycz/myreader/ui/presenter/BookcasePresenter.java b/app/src/main/java/xyz/fycz/myreader/ui/presenter/BookcasePresenter.java index f71a8cd..f258ac4 100644 --- a/app/src/main/java/xyz/fycz/myreader/ui/presenter/BookcasePresenter.java +++ b/app/src/main/java/xyz/fycz/myreader/ui/presenter/BookcasePresenter.java @@ -29,6 +29,7 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import io.reactivex.Observable; +import io.reactivex.schedulers.Schedulers; import xyz.fycz.myreader.R; import xyz.fycz.myreader.application.App; import xyz.fycz.myreader.application.SysManager; @@ -788,7 +789,7 @@ public class BookcasePresenter implements BasePresenter { mChapterService.saveOrUpdateChapter(chapter, s); successCathe++; curCacheChapterNum++; - })).subscribe(new MyObserver() { + })).subscribeOn(Schedulers.from(App.getApplication().getmFixedThreadPool())).subscribe(new MyObserver() { @Override public void onNext(@NotNull Object o) {