ppn/olcng
3
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcng.git synced 2026-07-03 14:05:17 +02:00
Code Issues Packages Projects Releases 3 Wiki Activity

perf(RealPingWorkerService): increase thread pool size and add exception handling

Browse Source
This commit is contained in:
zarazaex69
2026-04-04 19:02:49 +03:00
parent efe1fa8f9f
commit 1f73b90525
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
V2rayNG/app/src/main/java/com/v2ray/ang/service/RealPingWorkerService.kt
+3 -1
View File
@@ -27,7 +27,7 @@ class RealPingWorkerService(
) {
private val job = SupervisorJob()
private val cpu = Runtime.getRuntime().availableProcessors().coerceAtLeast(1)
private val dispatcher = Executors.newFixedThreadPool(cpu * 4).asCoroutineDispatcher()
private val dispatcher = Executors.newFixedThreadPool(cpu * 16).asCoroutineDispatcher()
private val scope = CoroutineScope(job + dispatcher + CoroutineName("RealPingBatchWorker"))
private val runningCount = AtomicInteger(0)
@@ -41,6 +41,8 @@ class RealPingWorkerService(
try {
val result = startRealPing(guid)
MessageUtil.sendMsg2UI(context, AppConfig.MSG_MEASURE_CONFIG_SUCCESS, Pair(guid, result))
} catch (e: Exception) {
MessageUtil.sendMsg2UI(context, AppConfig.MSG_MEASURE_CONFIG_SUCCESS, Pair(guid, -1L))
} finally {
val count = totalCount.decrementAndGet()
val left = runningCount.decrementAndGet()