pull/306/head
gedoor 5 years ago
parent 6ba2844ba3
commit 9fb0592ac4
  1. 7
      app/src/main/java/io/legado/app/ui/config/OtherConfigFragment.kt
  2. 3
      app/src/main/java/io/legado/app/ui/main/MainActivity.kt
  3. 8
      app/src/main/java/io/legado/app/ui/main/MainViewModel.kt

@ -95,9 +95,10 @@ class OtherConfigFragment : BasePreferenceFragment(),
override fun onSharedPreferenceChanged(sharedPreferences: SharedPreferences?, key: String?) { override fun onSharedPreferenceChanged(sharedPreferences: SharedPreferences?, key: String?) {
when (key) { when (key) {
PreferKey.threadCount -> upPreferenceSummary( PreferKey.threadCount -> {
key, AppConfig.threadCount.toString() upPreferenceSummary(key, AppConfig.threadCount.toString())
) postEvent(PreferKey.threadCount, "")
}
PreferKey.webPort -> { PreferKey.webPort -> {
upPreferenceSummary(key, webPort.toString()) upPreferenceSummary(key, webPort.toString())
if (WebService.isRun) { if (WebService.isRun) {

@ -157,6 +157,9 @@ class MainActivity : VMBaseActivity<MainViewModel>(R.layout.activity_main),
view_pager_main.setCurrentItem(3, false) view_pager_main.setCurrentItem(3, false)
} }
} }
observeEvent<String>(PreferKey.threadCount) {
viewModel.upPool()
}
} }
private inner class TabFragmentPageAdapter internal constructor(fm: FragmentManager) : private inner class TabFragmentPageAdapter internal constructor(fm: FragmentManager) :

@ -21,7 +21,8 @@ import kotlinx.coroutines.delay
import java.util.concurrent.Executors import java.util.concurrent.Executors
class MainViewModel(application: Application) : BaseViewModel(application) { class MainViewModel(application: Application) : BaseViewModel(application) {
var upTocPool = Executors.newFixedThreadPool(AppConfig.threadCount).asCoroutineDispatcher() private var upTocPool =
Executors.newFixedThreadPool(AppConfig.threadCount).asCoroutineDispatcher()
val updateList = hashSetOf<String>() val updateList = hashSetOf<String>()
override fun onCleared() { override fun onCleared() {
@ -29,6 +30,11 @@ class MainViewModel(application: Application) : BaseViewModel(application) {
upTocPool.close() upTocPool.close()
} }
fun upPool() {
upTocPool.close()
upTocPool = Executors.newFixedThreadPool(AppConfig.threadCount).asCoroutineDispatcher()
}
fun upChapterList() { fun upChapterList() {
execute { execute {
upChapterList(App.db.bookDao().hasUpdateBooks) upChapterList(App.db.bookDao().hasUpdateBooks)

Loading…
Cancel
Save