GCD 最佳实践指南
guduxiasky
9年前
<p>Grand Central Dispatch大中枢派发:joy: 或俗称 GCD 是一件极其强大的武器。他为你提供了很多底层工具，比如队列和信号量，你可以组合这些工具来达成自己想要的多线程效果。不幸的是，这些基于 C 的 API 晦涩难懂，并且想要将低级工具组合起来实现高抽象层级 API 的效果（译者注：类似于 NSOperation ）也不是一件容易的事。这篇文章，我来教大家如何利用 GCD 提供的工具来达成高抽象层级的行为。 <a href="/misc/goto?guid=4959671874710873821" rel="nofollow,noindex">英文原文</a></p> <h2>工作在后台</h2> <p>这或许是 GCD 提供的最简单的工具了，他能让你在后台线程处理一些工作，然后返回主线程继续，就如同 UIKit 的操作只能在主线程中进行。</p> <p>在本指南中，我将使用 doSomeExpensiveWork() 函数来表示一些长期运行的任务，并最终返回一个结果。</p> <p>根据这一思路，我们的套路一般是：</p> <pre> <code class="language-objectivec">let defaultPriority = DISPATCH_QUEUE_PRIORITY_DEFAULT let backgroundQueue = dispatch_get_global_queue(defaultPriority, 0) dispatch_async(backgroundQueue, { let result = doSomeExpensiveWork() dispatch_async(dispatch_get_main_queue(), { //use `result` somehow }) }) </code></pre> <p>在实际项目中，除了 DISPATCH_QUEUE_PRIORITY_DEFAULT ，我们几乎不使用其他的优先级选项。 dispatch_get_global_queue() 将返回一个队列，支持数百个线程的执行。如果你总是需要在一个后台队列上执行开销庞大的操作，那么可以使用 dispatch_queue_create 创建自己的队列， dispatch_queue_create 带两个参数，第一个是需要指定的队列名，第二个说明是串行队列还是并发队列。</p> <p>注意每次调用使用的是 dispatch_async 而不是 dispatch_sync 。 dispatch_async 将在 block 执行前立即返回，而 dispatch_sync 则会等到 block 执行完毕后才返回。内部的调用可以使用 dispatch_sync （因为不在乎什么时候返回），但是外部的调用必须是 dispatch_async （否则主线程会被阻塞）。</p> <h2>创建单例</h2> <p>dispatch_once 这个 API 可以用来创建单例。不过这种方式在 Swift 已不再重要，Swift 有更简单的方法来创建单例。我这里就只贴 OC 的实现：</p> <pre> <code class="language-objectivec">+ (instancetype) sharedInstance { static dispatch_once_t onceToken; static id sharedInstance; dispatch_once(&onceToken, ^{ sharedInstance = [[self alloc] init]; }); return sharedInstance; } </code></pre> <h2>将 completion block 扁平化</h2> <p>至此我们的 GCD 之旅开始变得有趣起来。我们可以使用信号量来阻塞一个线程任意时长，直到一个信号从另一个线程发出。信号量和 GCD 的其他部分一样也是线程安全的，而且能够从任意位置被触发。</p> <p>信号量适用于当你有一个异步 API 需要同步执行的情形，但你不能修改它</p> <pre> <code class="language-objectivec">// on a background queue dispatch_semaphore_t semaphore = dispatch_semaphore_create(0) doSomeExpensiveWorkAsynchronously(completionBlock: { dispatch_semaphore_signal(semaphore) }) dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER) //the expensive asynchronous work is now done </code></pre> <p>调用 dispatch_semaphore_wait 将会阻塞线程直到 dispatch_semaphore_signal 被调用。这就意味着 signal 必须从不同的线程被调用，因为当前线程是被完全阻塞的。更进一步，你从来都不该在主线程中调用 wait ，而是只从后台线程中调用。</p> <p>你可以在调用 dispatch_semaphore_wait 时设置一个超时时间，但是我总是趋向使用 DISPATCH_TIME_FOREVER</p> <p>为什么在已经有 completion block 的情况下，还想要摊平代码？因为方便呀，我能想到的一种场景是执行一组异步程序，但他们必须串行执行（即只有前一个任务执行完成，才会继续执行下一个任务）。现在把上述想法简单地抽象成一个 AsyncSerialWorker 示例：</p> <pre> <code class="language-objectivec">typealias DoneBlock = () -> () typealias WorkBlock = (DoneBlock) -> () class AsyncSerialWorker { private let serialQueue = dispatch_queue_create("com.khanlou.serial.queue", DISPATCH_QUEUE_SERIAL) func enqueueWork(work: WorkBlock) { dispatch_async(serialQueue) { let semaphore = dispatch_semaphore_create(0) work({ dispatch_semaphore_signal(semaphore) }) dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER) } } } </code></pre> <p>上面这个简短的类创建了一个串行队列，允许你将 work 的入队列操作放进 block 中。在 WorkBlock 需要一个 DoneBlock 作为参数，而 DoneBlock 会在当前工作结束时被执行，我们通过将 DoneBlock 设置为 {dispatch_semaphore_signal(semaphore)} 来调整信号量，从而让串行队列继续执行下去。</p> <p>dispatch_semaphore_create(0) 当两个线程需要协调处理某个事件时，我们在这里传入 0；内部其实是维护了一个计数器，我们下面会说到</p> <h2>限制并发的数量</h2> <p>在上面的例子中，信号量被用来当做是一个简单的标志，但它也可以当成一个有限资源的计数器。如果你想针对某些特定的资源限制连接数，你可以这样做：</p> <pre> <code class="language-objectivec">class LimitedWorker { private let concurrentQueue = dispatch_queue_create("com.khanlou.concurrent.queue", DISPATCH_QUEUE_CONCURRENT) private let semaphore: dispatch_semaphore_t init(limit: Int) { semaphore = dispatch_semaphore_create(limit) } func enqueueWork(work: () -> ()) { dispatch_async(concurrentQueue) { dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER) work() dispatch_semaphore_signal(semaphore) } } } </code></pre> <p>这个例子来自于苹果官方的 <a href="/misc/goto?guid=4959671874795285252" rel="nofollow,noindex">多线程编程指南</a> ，官方给出的解释如下：</p> <p>在创建信号量的时候，可以限定资源的可用数。这个可用数（long 类型）会随信号量初始化时作为参数传入。每次等待信号量时， dispatch_semaphore_wait 都会消耗一次这个可用数，如果结果为负，函数会告诉内核阻断你的线程。另一方面， dispatch_semaphore_signal 函数每次执行都会将该可用计数 + 1 ，以此来表明已经释放了资源。如果此刻有因为等待可用资源而被阻隔的任务，系统会从等待的队列中解锁一个任务来执行。</p> <p>这个效果类似于 NSOperationQueue 的 maxConcurrentOperationCount 。如果你使用原生的 GCD 队列而不是 NSOperationQueue ，你就能使用信号量来限制并发任务的数量。</p> <p>值得注意是：每次调用 enqueueWork 都会将 work 提交到一个 并发队列 ，而该 并发队列 收到任务就会丢出去执行，直到触碰到信号量数量耗尽的天花板（work 入队列的速度太快， dispatch_semaphore_wait 已经消耗完了所有的数量，而之前的 work 还未执行完毕， dispatch_semaphore_signal 不能增加信号量的可用数量）</p> <h2>等待许多并发任务去完成</h2> <p>如果你有许多 blocks 任务要去执行，你需要在他们全部完成时得到通知，你可以使用 group。 dispatch_group_async 允许你在队列中添加任务（这些任务应该是同步执行的），而且你会追踪有多少被添加的任务。注意：同一个 dispatch group 能够添加不同队列上的任务，并且能保持对所有组内任务的追踪。当所有被追踪的任务完成时，一个传递给 dispatch_group_notify 的 block 会被触发执行，有点类似于 completion block</p> <pre> <code class="language-objectivec">dispatch_group_t group = dispatch_group_create() for item in someArray { dispatch_group_async(group, backgroundQueue, { performExpensiveWork(item: item) }) } dispatch_group_notify(group, dispatch_get_main_queue(), { // all the work is complete } </code></pre> <p>对于摊平一个拥有 completion block 的函数来说，下面是一个绝佳的示例。分发组（The dispatch group）认为整个 block 将在返回时完成，所以 block 会一直等到任务完成时才会返回</p> <p>还有更多手动使用 dispatch groups 的姿势，尤其有很多异步执行的大开销任务：</p> <pre> <code class="language-objectivec">// must be on a background thread dispatch_group_t group = dispatch_group_create() for item in someArray { dispatch_group_enter(group) performExpensiveAsyncWork(item: item, completionBlock: { dispatch_group_leave(group) }) } dispatch_group_wait(group, DISPATCH_TIME_FOREVER) // all the work is complete </code></pre> <p>这段代码更加复杂一些，但是我们逐行去看还是可以理解的。如同信号量，groups 同样保持着一个线程安全的、可以操控的内部计数器。你可以使用这个计数器来确保在 completion block 执行前，多个大开销任务都已执行完毕。使用 enter 来增加计数器，使用 leave 来减少计数器。 dispatch_group_async 已为你处理了这些细节，所以尽情地享受即可。</p> <p>代码片段的最后一行是 wait 调用：他会阻断当前线程并且等待计数器达到 0 才会继续执行。注意尽管你使用了 enter/leave API，但你还是能够通过 dispatch_group_notify 将 block 提交到队列中。反过来也是成立的：如果你用了 dispatch_group_async API，也是能够使用 dispatch_group_wait 的。</p> <p>dispatch_group_wait 和 dispatch_semaphore_wait 一样都接收一个超时参数。再次重申，我更喜欢 DISPATCH_TIME_FOREVER ，同样的不要在主线程中调用 dispatch_group_wait 。</p> <p>上面两段代码最大的不同在于使用 notify 可以完全从主线程上被调用，而使用 wait 的只能在后台线程上使用（至少是 wait 部分，因为他会完全阻塞当前线程）</p> <h2>隔离队列</h2> <p>Swift 中的字典（和数组）都是值类型，当他们被修改时，他们的引用会被一个新的副本所替代。但是，因为更新 Swift 对象的实例变量操作并不是原子性的，所以这些操作也不是线程安全的。如果两个线程同一时间更新一个字典（比如都添加一个值），而且这两个操作都尝试写同一块内存，这就会导致内存崩坏，我们可以使用隔离队列来达成线程安全的目的。</p> <p>先来构建一个 <strong>标识映射</strong> <a href="/misc/goto?guid=4959671874881962613" rel="nofollow,noindex">Identity Map</a> ，一个标识映射是一个字典，代表着从 ID 到 model 对象的映射</p> <p>Identity Map（标识映射）模式是通过将所有已加载对象放在一个映射中确保所有对象只被加载一次，并且在引用这些对象时使用该映射来查找对象。在处理数据并发访问时，要有一种策略让多个用户共同影响同一个业务实体，这个固然很重要。同样重要的是，单个用户在一个长运行事务或复杂事务中始终使用业务实体的一致版本。Identity Map模式提供的功能；为事务中使用所有的业务对象均保存一个版本，如果一个实体被请求两次，返回同一个实体。</p> <pre> <code class="language-objectivec">class IdentityMap<T: Identifiable> { var dictionary = Dictionary<String, T>() func object(forID ID: String) -> T? { return dictionary[ID] as T? } func addObject(object: T) { dictionary[object.ID] = object } } </code></pre> <p>这个对象基本就是一个字典封装器，如果有多个线程在同一时刻调用函数 addObject ，内存将会崩坏，因为线程会操作相同的引用。这也是操作系统中的经典的 <a href="/misc/goto?guid=4959671874972351202" rel="nofollow,noindex">读者-写者问题</a> ，简而言之，我们可以在同一时刻有多个读者，但同一时刻只能有一个线程可以写入。</p> <p>幸运的是 GCD 针对在该场景下同样拥有强力武器，有如下四种 APIs 供我们选用：</p> <ul> <li>dispatch_sync</li> <li>dispatch_async</li> <li>dispatch_barrier_sync</li> <li>dispatch_barrier_async</li> </ul> <p>我们的想法是读操作可以支持同步和异步，而写操作也能支持异步写入，并且必须确保是写入的是同一个引用。GCD 的 barrier 集合 APIs 提供了解决方案：他们将会一直等到队列中的任务清空，才会继续执行 block。使用 barrier APIs 可以用来限制我们对字典对象的写入，并且确保我们不会在同一时刻进行多个写操作，以及正在写操作时同时进行读操作。</p> <pre> <code class="language-objectivec">class IdentityMap<T: Identifiable> { var dictionary = Dictionary<String, T>() let accessQueue = dispatch_queue_create("com.khanlou.isolation.queue", DISPATCH_QUEUE_CONCURRENT) func object(withID ID: String) -> T? { var result: T? = nil dispatch_sync(accessQueue, { result = dictionary[ID] as T? }) return result } func addObject(object: T) { dispatch_barrier_async(accessQueue, { dictionary[object.ID] = object }) } } </code></pre> <p>dispatch_sync 将会分发 block 到我们的隔离队列上然后等待其执行完毕。通过这种方式，我们就实现了同步读操作（如果我们搞成异步读取，getter 方法就需要一个 completion block）。因为 accessQueue 是并发队列，这些同步读取操作可以并发执行，也就是允许同时读。</p> <p>dispatch_barrier_async 将分发 block 到隔离队列上， async 异步部分意味着会立即返回，并不会等待 block 执行完毕。这对性能是有好处的，但是在一个写操作后立即执行一个读操作会导致读到一个半成品的数据（因为可能写操作还未完成就开始读了）。</p> <p>dispatch_barrier_async 中的 barrier 部分意味着：只要 barrier block 进入队列，并不会立即执行，而是会等待该队列其他 block 执行完毕后再执行。所以在这点上就保证了我们的 barrier block 每次都只有它自己在执行。而所有在他之后提交的 block 也会一直等待这个 barrier block 执行完再执行。</p> <p>传入 dispatch_barrier_async() 函数的 <strong>queue</strong> ，必须是用 dispatch_queue_create 创建的并发 <strong>queue</strong> 。如果是串行 <strong>queue</strong> 或者是 <strong>global concurrent queues</strong> ，这个函数就会变成 dispatch_async() 了</p> <h2>完结</h2> <p>GCD 是一个具备底层特性的框架，通过他们，我们可以构建高层级的抽象行为。如果还有一些我没提到的高层级的行为可以用 GCD 来构建，欢迎来交流。</p> <p>来自： <a href="/misc/goto?guid=4959671875052996734" rel="nofollow">http://chengway.in/gcd-zui-jia-shi-jian-zhi-nan/</a></p>