ios - Tidwall/安全互斥锁死锁

问题描述

我正在使用https://github.com/tidwall/Safe，一个 Swift 并发库，我想我发现了一个线程错误。（我认为我使用的是 IOS 12.3.1、iPhone Xs。Swift 4；Xcode 10.2 。）该库现在是只读的，所以我正在尝试自己调试它。不过，这个错误真的很微妙，或者它是由我什至没有想到的东西引起的，因为我做的事情与给定的库几乎相同，它工作正常，但库本身死锁了。

这是不应该死锁的测试代码：

private func testCompetingDeadlock() {
    NSLog("start")
    let c = Chan<Int32>()
    let b = Chan<Int32>()
    let COUNT = 1000
    let wg = WaitGroup()
    wg.add(1)
    dispatch {
        NSLog("receiver starting")
        for i in 0..<(2*COUNT) {
            Thread.sleep(forTimeInterval: 0.01)
            let v = <-c
            b <- v!
        }
        wg.done()
    }
    sleep(1)
    wg.add(1)
    dispatch {
        NSLog("sender 1 starting")
        for i in 0..<COUNT {
            c <- 1
            <-b
            NSLog("1 : \(i)")
        }
        NSLog("1 done")
        wg.done()
    }
    wg.add(1)
    dispatch {
        NSLog("sender 2 starting")
        for i in 0..<COUNT {
            c <- 2
            <-b
            NSLog("2 : \(i)")
        }
        NSLog("2 done")
        wg.done()
    }
    wg.wait()
    NSLog("Both done")
}

请注意send， aka的底层实现<-是

internal func send(_ msg: T) {
    NSLog("locking (\(Thread.current)) - \(Unmanaged.passUnretained(cond.mutex).toOpaque())")
    cond.mutex.lock()
    NSLog("locked (\(Thread.current)) - \(Unmanaged.passUnretained(cond.mutex).toOpaque())")
    threadCount += 1
    defer {
        threadCount -= 1
        NSLog("unlocking (\(Thread.current)) - \(Unmanaged.passUnretained(cond.mutex).toOpaque())")
        cond.mutex.unlock()
        NSLog("unlocked (\(Thread.current)) - \(Unmanaged.passUnretained(cond.mutex).toOpaque())")
    }
    if threadCount > 1 {
        NSLog("threadCount is \(threadCount)")
    }

    if closed {
        #if os(Linux)
        assertionFailure("Send on closed channel")
        #else
        NSException.raise(NSExceptionName(rawValue: "Exception"), format: "send on closed channel", arguments: getVaList([]))
        #endif
    }
    msgs.append(msg)
    broadcast()
    while msgs.count > cap {
        cond.wait()
    }
}

（我添加了日志记录，并且threadCount。一旦发生死锁，threadCount就是 2。我在课堂上尝试了相同的“锁定后 inc，解锁前 dec”，死锁期间Mutex我得到3？我不知道怎么做，我没有进一步调查它，尽管它可能是一个重要的线索。）

如果testCompetingDeadlock运行，死锁通常会立即发生，两个发送线程卡在该cond.wait()行上send，都在同一个互斥锁的锁定区域内。我不知道怎么做。我尝试Mutex以与我认为使用它相同的方式测试它本身，send如下所示：

private func testSafeMutex() {
    let mutex = Mutex()

    dispatch {
        NSLog("1 locking")
        mutex.lock()
        NSLog("1 locked")
        defer {
            NSLog("1 unlocking")
            mutex.unlock()
            NSLog("1 unlocked")
        }

        sleep(1)
    }

    dispatch {
        NSLog("2 locking")
        mutex.lock()
        NSLog("2 locked")
        defer {
            NSLog("2 unlocking")
            mutex.unlock()
            NSLog("2 unlocked")
        }

        sleep(1)
    }
}

但是，工作正常 - 没有死锁。

除了添加越来越细粒度的日志记录之外，我真的不确定该怎么做，并尝试合并两个测试用例直到找到关键差异（这很困难，因为很难在版本之间保持代码功能） . 有人可以帮我调试这个库吗？是否可能存在一些特定于 iOS 的内存模型问题等？

标签： iosswiftconcurrencyopen-source

ios - Tidwall/安全互斥锁死锁

问题描述

解决方案

推荐阅读