处理多个完成处理程序

Question

我正试图协调每个数组元素的多个完成处理程序。

代码本质上是这样的：

var results = [String:Int]()

func requestData(for identifiers: [String])
{
    identifiers.forEach
    {   identifier in

        service.request(identifier, completion: { (result) in
            result[identifier] = result
        })
    }

    // Execute after all the completion handlers finish
    print(result)
}

因此，数组中的每个元素都通过具有完成处理程序的服务发送，并且所有结果都存储在数组中。一旦所有这些处理程序完成，我希望执行一些代码。

我尝试使用DispatchQueue来实现这一点。

var results = [String:Int]()

func requestData(for identifiers: [String])
{
    let queue = DispatchQueue.init(label: "queue")

    identifiers.forEach
    {   identifier in

        service.request(identifier, completion: { (result) in
            queue.sync
            {
                result[identifier] = result
            }
        })
    }

    // Execute after all the completion handlers finish
    queue.sync
    {
        print(result)
    }
}

但是打印调用仍然首先执行，使用一个空的Dictionary

- XmasRights

Answer 1

如果我正确理解你想要做的事情，你可能需要使用一个 DispatchGroup。

这里是一个示例：

let group = DispatchGroup()

var letters = ["a", "b", "c"]

for letter in letters {
    group.enter()
    Server.doSomething(completion: { [weak self] (result) in
        print("Letter is: \(letter)")
        group.leave()
    })
}

group.notify(queue: .main) {
    print("- done")
}

这将打印出类似于以下内容：

b
c
a
// ^ in some order
- done

- Doug Mead

---

我希望我能够多次点赞。难以置信寻找这个非常有用的内置功能竟然如此困难！ - biomiker

Answer 2

首先，请注意您的service.request(...)是以异步模式处理的。另一个问题是您希望在该循环中完成所有服务请求。

我的建议是创建具有完成处理程序的函数，并在每个循环完成时添加计数器。您的函数将类似于以下内容。

var results = [String:Int]()

func requestData(for identifiers: [String], callback:@escaping (Bool) -> Void)
{
    var counter = 0
    var maxItem = identifiers.count

    identifiers.forEach
    {   identifier in

        service.request(identifier, completion: { (result) in
            result[identifier] = result
            counter += 1
            if counter == maxItem {
                callback(true) // update completion handler to say all loops request are done
            }
            // if not, continue the other request
        })
    }
}

下面是你代码的另一部分如何调用该函数并等待回调：

requestData(for identifiers:yourArrays) { (complete) in

    if complete {
        print(results)
    }
}

不要忘记处理错误。

- xmhafiz