Austin/gkd
1
0
Fork 0
mirror of https://github.com/gkd-kit/gkd.git synced 2024-11-16 11:42:22 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

perf: 使用线程池而非协程处理 IO 事件。

Browse Source 
在 pixel6 测试，协程启动耗时约 0.5-1ms，线程池约 0.02-0.1ms。
This commit is contained in:
weishu 2023-12-27 11:59:03 +08:00
parent 933fd91d08
commit 5e8e610efa
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/src/main/kotlin/li/songe/gkd/service/GkdAbService.kt
View File

@ -57,6 +57,7 @@ import li.songe.gkd.util.subsItemsFlow
import li.songe.gkd.util.updateStorage import li.songe.gkd.util.updateStorage
import li.songe.gkd.util.updateSubscription import li.songe.gkd.util.updateSubscription
import li.songe.selector.Selector import li.songe.selector.Selector
import java.util.concurrent.Executors
import kotlin.coroutines.resume import kotlin.coroutines.resume
import kotlin.coroutines.suspendCoroutine import kotlin.coroutines.suspendCoroutine
@ -124,7 +125,7 @@ class GkdAbService : CompositionAbService({
var lastTriggerShizukuTime = 0L var lastTriggerShizukuTime = 0L
var lastContentEventTime = 0L var lastContentEventTime = 0L
val queryThread = Dispatchers.IO.limitedParallelism(1) val queryThread = Dispatchers.IO.limitedParallelism(1)
val eventThread = Dispatchers.IO.limitedParallelism(1) val eventExecutor = Executors.newSingleThreadExecutor()
onDestroy { onDestroy {
queryThread.cancel() queryThread.cancel()
} }
@ -207,7 +208,7 @@ class GkdAbService : CompositionAbService({
val evActivityId = fixedEvent.className val evActivityId = fixedEvent.className
scope.launch(eventThread) { eventExecutor.execute launch@{
val eventNode = event.source ?: return@launch val eventNode = event.source ?: return@launch
val oldAppId = topActivityFlow.value.appId val oldAppId = topActivityFlow.value.appId
val rightAppId = if (oldAppId == evAppId) { val rightAppId = if (oldAppId == evAppId) {