Skip to content

Commit b58f752

Browse files
committed
🐛 [kmp/core]修复IpcPool.ipcSet并发修改问题
1 parent e59e462 commit b58f752

1 file changed

Lines changed: 2 additions & 6 deletions

File tree

  • next/kmp/core/src/commonMain/kotlin/org/dweb_browser/core/ipc

next/kmp/core/src/commonMain/kotlin/org/dweb_browser/core/ipc/IpcPool.kt

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,11 @@ import kotlinx.coroutines.launch
88
import kotlinx.coroutines.plus
99
import org.dweb_browser.core.help.types.MicroModuleManifest
1010
import org.dweb_browser.helper.Debugger
11+
import org.dweb_browser.helper.SafeHashSet
1112
import org.dweb_browser.helper.SuspendOnce1
1213
import org.dweb_browser.helper.UUID
1314
import org.dweb_browser.helper.globalDefaultScope
1415
import org.dweb_browser.helper.randomUUID
15-
import org.dweb_browser.pure.http.PureStream
1616

1717
val debugIpcPool = Debugger("ipcPool")
1818

@@ -37,12 +37,8 @@ open class IpcPool {
3737
/**
3838
* 所有的ipc对象实例集合
3939
*/
40-
private val ipcSet = mutableSetOf<Ipc>()
40+
private val ipcSet = SafeHashSet<Ipc>()
4141

42-
/**
43-
* 所有的委托进来的流的实例集合
44-
*/
45-
private val streamPool = mutableMapOf<String, PureStream>()
4642
suspend fun createIpc(
4743
endpoint: IpcEndpoint,
4844
pid: Int,

0 commit comments

Comments
 (0)