github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-01-05 23:50:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

Use Mutex than @Synchronized

Browse Source
This commit is contained in:
Him188 2021-11-18 02:57:08 +00:00
parent df92607841
commit 0f1227d401
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mirai-core/src/commonTest/kotlin/network/framework/TestNetworkHandler.kt
View File

@ -11,6 +11,8 @@ package net.mamoe.mirai.internal.network.framework
import io.netty.channel.Channel
import kotlinx.coroutines.CompletableDeferred
import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock
import net.mamoe.mirai.internal.QQAndroidBot
import net.mamoe.mirai.internal.network.handler.NetworkHandler
import net.mamoe.mirai.internal.network.handler.NetworkHandlerContext
@ -35,9 +37,9 @@ internal open class TestNetworkHandler(
val resumeDeferred = CompletableDeferred<Unit>()
val resumeCount = AtomicInteger(0)
val onResume get() = resumeDeferred.onJoin
private val mutex = Mutex()
@Synchronized
override suspend fun resumeConnection0() {
override suspend fun resumeConnection0(): Unit = mutex.withLock {
resumeCount.incrementAndGet()
resumeDeferred.complete(Unit)
when (this.correspondingState) {