Swift：与 DispatchGroup 的死锁

Question

我在 CoreData 并发方面遇到了一些问题。 当目标线程被DispatchGroup 阻塞时，我无法执行context.perform。

这是一个显示问题的简单示例：

func upload(objects: [NSManagedObject]) {
    let group = DispatchGroup()
    for object in objects {
        group.enter()
        upload(object) {
            group.leave()
        }
    }
    group.wait()    // current thread is blocked here

    someAdditionalWorkToDoInSameThread()
}

func upload(object: NSManagedObject, completion: ()->()) {
    let context = object.managedObjectContext
    performAlamofireRequest(object) {
        context.perform {
            // can't reach here because the thread is blocked
            update(object)
            completion()
        }
    }
}

请帮助我正确地重新实现它。谢谢。

Answer 1

在调度组上使用notify 而不是等待，应该可以解决您的问题。

调用wait() 会阻塞当前线程以完成之前提交的工作。
notify(queue:execute:) 将通知队列您作为参数传递的组任务已完成。

func upload(objects: [NSManagedObject], completion: ()->()) {
    let group = DispatchGroup()
    for object in objects {
        group.enter()
        upload(object) {
            group.leave()
        }
    }
    group.notify(queue: DispatchQueue.main) {
         completion()
    }
}