gitea/legado
gitea/legado
1
1
Fork 0
mirror of https://github.com/gedoor/legado.git synced 2024-07-06 23:47:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
Horis 2024-02-21 09:33:47 +08:00
parent 0106c5e628
commit 7ecff06671
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/main/java/io/legado/app/ui/main/MainViewModel.kt
View File

@ -38,6 +38,7 @@ import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.isActive
import kotlinx.coroutines.launch
import java.util.LinkedList
import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.Executors
import kotlin.math.min
@ -46,7 +47,7 @@ class MainViewModel(application: Application) : BaseViewModel(application) {
private var poolSize = min(threadCount, AppConst.MAX_THREAD)
private var upTocPool = Executors.newFixedThreadPool(poolSize).asCoroutineDispatcher()
private val waitUpTocBooks = LinkedList<String>()
private val onUpTocBooks = hashSetOf<String>()
private val onUpTocBooks = ConcurrentHashMap.newKeySet<String>()
val onUpBooksLiveData = MutableLiveData<Int>()
private var upTocJob: Job? = null
private var cacheBookJob: Job? = null
@ -110,10 +111,9 @@ class MainViewModel(application: Application) : BaseViewModel(application) {
while (true) {
emit(waitUpTocBooks.poll() ?: break)
}
}.onEach {
}.onEachParallel(threadCount) {
onUpTocBooks.add(it)
postEvent(EventBus.UP_BOOKSHELF, it)
}.onEachParallel(threadCount) {
updateToc(it)
}.onEach {
onUpTocBooks.remove(it)