iOS 多网络请求的线程安全
wqxiea
7年前
<p style="text-align:center"><img src="https://simg.open-open.com/show/7134af75feb037690ecbe3f5df83fec1.jpg"></p> <p>iOS 网络编程有一种常见的场景是：我们需要并行处理二个请求并且在都成功后才能进行下一步处理。下面是部分常见的处理方式，但是在使用过程中也很容易出错：</p> <ul> <li>DispatchGroup：通过 GCD 机制将多个请求放到一个组内，然后通过 <strong>DispatchGroup.wait()</strong> 和 <strong>DispatchGroup.notify()</strong> 进行成功后的处理。</li> <li>OperationQueue：为每一个请求实例化一个 <strong>Operation</strong> 对象，然后将这些对象添加到 <strong>OperationQueue</strong> ，并且根据它们之间的依赖关系决定执行顺序。</li> <li>同步 DispatchQueue：通过同步队列和 <strong>NSLock</strong> 机制避免数据竞争，实现异步多线程中同步安全访问。</li> <li>第三方类库：Futures/Promises 以及响应式编程提供了更高层级的并发抽象。</li> </ul> <p>在多年的实践过程中，我意识到上面这些方法这些方法都存在一定的缺陷。另外，要想完全正确的使用这些类库还是有些困难。</p> <h2>并发编程中的挑战</h2> <p>使用并发的思维思考问题很困难：大多数时候，我们会按照读故事的方式来阅读代码：从第一行到最后一行。如果代码的逻辑不是线性的话，可能会给我们造成一定的理解难度。在单线程环境下，调试和跟踪多个类和框架的程序执行已经是非常头疼的一件事了，多线程环境下这种情况简直不敢想象。</p> <p>数据竞争问题：在多线程并发环境下，数据读取操作是线程安全的而写操作则是非线程安全。如果发生了多个线程同时对某个内存进行写操作的话，则会发生数据竞争导致潜在数据错误。</p> <p>理解多线程环境下的动态行为本身就不是一件容易的事，找出导致数据竞争的线程就更为麻烦。虽然我们可以通过互斥锁机制解决数据竞争问题，但是对于可能修改的代码来说互斥锁机制的维护会是一件非常困难的事。</p> <p>难以测试：并发环境下很多问题并不会在开发过程中显现出来。虽然 Xcode 和 LLVM 提供了 <a href="/misc/goto?guid=4959755023311525770" rel="nofollow,noindex">Thread Sanitizer</a> 这类工具用于检查这些问题，但是这些问题的调试和跟踪依然存在很大的难度。因为并发环境下除了代码本身的影响外，应用也会受到系统的影响。</p> <h2>处理并发情形的简单方法</h2> <p>考虑到并发编程的复杂性，我们应该如何解决并行的多个请求？</p> <p>最简单的方式就是避免编写并行代码而是讲多个请求线性的串联在一起：</p> <pre> <code class="language-objectivec">let session = URLSession.shared session.dataTask(with: request1) { data, response, error in // check for errors // parse the response data session.dataTask(with: request2) { data, response error in // check for errors // parse the response data // if everything succeeded... callbackQueue.async { completionHandler(result1, result2) } }.resume() }.resume()</code></pre> <p>为了保持代码的简洁，这里忽略了很多的细节处理，例如：错误处理以及请求取消操作。但是这样将并无关联的请求线性排序其实暗藏着一些问题。例如，如果服务端支持 HTTP/2 协议的话，我们就没发利用 HTTP/2 协议中通过同一个链接处理多个请求的特性，而且线性处理也意味着我们没有好好利用处理器的性能。</p> <h2>关于 URLSession 的错误认知</h2> <p>为了避免可能的数据竞争和线程安全问题，我将上面的代码改写为了嵌套请求。也就是说如果将其改为并发请求的话：请求将不能进行嵌套，两个请求可能会对同一块内存进行写操作而数据竞争非常难以重现和调试。</p> <p>解决改问题的一个可行办法是通过锁机制：在一段时间内只允许一个线程对共享内存进行写操作。锁机制的执行过程也非常简单：请求锁、执行代码、释放锁。当然要想完全正确使用锁机制还是有一些技巧的。</p> <p>但是根据 URLSession 的 <a href="/misc/goto?guid=4959755023399586217" rel="nofollow,noindex">文档</a> 描述，这里有一个并发请求的更简单解决方案。</p> <pre> <code class="language-objectivec">init(configuration: URLSessionConfiguration, delegate: URLSessionDelegate?, delegateQueue queue: OperationQueue?)</code></pre> <p>[…]</p> <p>queue : An operation queue for scheduling the delegate calls and completion handlers. The queue should be a serial queue, in order to ensure the correct ordering of callbacks. If nil, the session creates a serial operation queue for performing all delegate method calls and completion handler calls.</p> <p>这意味所有 URLSession 的实例对象包括 <em>URLSession.shared</em> 单例的回调并不会并发执行，除非你明确的传人了一个并发队列给参数 <em>queue</em> 。</p> <h2>URLSession 拓展并发支持</h2> <p>基于上面对 URLSession 的新认知，下面我们对其进行拓展让它支持线程安全的并发请求（完成代码 <a href="/misc/goto?guid=4959755023486878147" rel="nofollow,noindex">地址</a> ）。</p> <pre> <code class="language-objectivec">enum URLResult { case response(Data, URLResponse) case error(Error, Data?, URLResponse?) } extension URLSession { @discardableResult func get(_ url: URL, completionHandler: @escaping (URLResult) -> Void) -> URLSessionDataTask } // Example let zen = URL(string: "https://api.github.com/zen")! session.get(zen) { result in // process the result }</code></pre> <p>首先，我们使用了一个简单的 <em>URLResult</em> 枚举来模拟我们可以在 <em>URLSessionDataTask</em> 回调中获得的不同结果。该枚举类型有利于我们简化多个并发请求结果的处理。这里为了文章的简洁并没有贴出 <em>URLSession.get(_:completionHandler:)</em> 方法的完整实现，该方法就是使用 GET 方法请求对应的 URL 并自动执行 <em>resume()</em> 最后将执行结果封装成 <em>URLResult</em> 对象。</p> <pre> <code class="language-objectivec">@discardableResult func get(_ left: URL, _ right: URL, completionHandler: @escaping (URLResult, URLResult) -> Void) -> (URLSessionDataTask, URLSessionDataTask) { }</code></pre> <p>该段 API 代码接受两个 URL 参数并返回两个 <em>URLSessionDataTask</em> 实例。下面代码是函数实现的第一段：</p> <pre> <code class="language-objectivec">precondition(delegateQueue.maxConcurrentOperationCount == 1, "URLSession's delegateQueue must be configured with a maxConcurrentOperationCount of 1.")</code></pre> <p>因为在实例化 URLSession 对象时依旧可以传入并发的 <em>OperationQueue</em> 对象，所以这里我们需要使用上面这段代码将这种情况排除掉。</p> <pre> <code class="language-objectivec">var results: (left: URLResult?, right: URLResult?) = (nil, nil) func continuation() { guard case let (left?, right?) = results else { return } completionHandler(left, right) }</code></pre> <p>将这段代码继续添加到实现中，其中定义了一个表示返回结果的元组变量 <em>results</em> 。另外，我们还在函数内部定义了另一个工具函数用于检查是否两个请求都已经完成结果处理。</p> <pre> <code class="language-objectivec">let left = get(left) { result in results.left = result continuation() } let right = get(right) { result in results.right = result continuation() } return (left, right)</code></pre> <p>最后将这段代码追加到实现中，其中我们分别对两个 URL 进行了请求并在请求都完成后一次返回了结果。值得注意的是这里我们通过两次执行 <em>continuation()</em> 来判断请求是否全部完成：</p> <ol> <li>第一次执行 <em>continuation()</em> 时因为其中一个请求并未完成结果为 <em>nil</em> 所以回调函数并不会执行。</li> <li>第二次执行的时候两个请求全部完成，执行回调处理。</li> </ol> <p>接下来我们可以通过简单的请求来测试下这段代码：</p> <pre> <code class="language-objectivec">extension URLResult { var string: String? { guard case let .response(data, _) = self, let string = String(data: data, encoding: .utf8) else { return nil } return string } } URLSession.shared.get(zen, zen) { left, right in guard case let (quote1?, quote2?) = (left.string, right.string) else { return } print(quote1, quote2, separator: "\n") // Approachable is better than simple. // Practicality beats purity. }</code></pre> <h2>并行悖论</h2> <p>我发现解决并行问题最简单最优雅的方法就是尽可能的少使用并发编程，而且我们的处理器非常适合执行那些线性代码。但是如果将大的代码块或任务拆分为多个并行执行的小代码块和任务将会让代码变得更加易读和易维护。</p> <p> </p> <p>来自：https://segmentfault.com/a/1190000011591022</p> <p></p> <p> </p>