这是交易。我试图在树上走。但是要同时进行。因此,每次我走到一个节点上时,我都需要同时走动它的所有节点,依此类推。
但。我不想等待整个DispatchGroup完成以获得结果,因为这就像Big O中最坏的情况一样。
相反,我想取消所有其他DispatchWorkItems,并在后续的项目中将它们留给他们。试图通过计算结束的任务来做到这一点。显然我在做错事或误解了如何使用它。
下面的代码仅用于示例目的和测试想法。
考虑现实情况,您可以在DispatchWorkItem中递归调用树的当前节点的另一个handle函数。

func handle(completion: @escaping (Int) -> Void) {
    var result: Int = 0


    var count = 7
    let group = DispatchGroup()
    let queue = DispatchQueue(label: "q", attributes: .concurrent)

    var items = [DispatchWorkItem]()

    let item1 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...1000 { continue }
        count -= 1
        group.leave()
        print("left 1")
    }
    let item2 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...2000 { continue }
        count -= 1
        group.leave()
        print("left 2")
    }
    let item3 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...6000 { continue }
        count -= 1
        group.leave()
        print("left 3")
    }
    let item4 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...3000 { continue }
        result = 42

        items.forEach { $0.cancel() }

        for _ in 0..<count {
            group.leave()
        }

        print("ok; left 4")
    }
    let item5 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...50000 { continue }
        count -= 1

        group.leave()
        print("left 5")
    }
    let item6 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...6000 { continue }
        count -= 1
        group.leave()
        print("left 6")
    }
    let item7 = DispatchWorkItem(flags: .inheritQoS) {
        for _ in 0...8000 { continue }
        count -= 1
        group.leave()
        print("left 7")
    }

    items.append(item1)
    items.append(item2)
    items.append(item3)
    items.append(item4)
    items.append(item5)
    items.append(item6)
    items.append(item7)

    for item in items {
        group.enter()
        queue.async(execute: item)
    }

    group.notify(queue: queue) {
        return
    }
}

test() {
    handle { result in
        print(result)
    }

}

最佳答案

您不能一次从多个线程读取和写入计数变量。您需要对互斥锁进行计数。您遇到不稳定的情况,试图从多个线程访问和/或更改计数。另外,您应该设计为根本不需要计数。

关于ios - Swift 3 DispatchGroup单成功DispatchWorkItem,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/45807520/

10-13 04:00