这是交易。我试图在树上走。但是要同时进行。因此,每次我走到一个节点上时,我都需要同时走动它的所有节点,依此类推。
但。我不想等待整个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/