使用dispatch_async在Swift中并发分析数组

我正在尝试使用 GCD 的后台线程同时分析照片。这是我写的代码：

dispatch_async(dispatch_get_global_queue(Int(QOS_CLASS_UTILITY.value), 0)) {
    for (var i = 0; i < 8; i++)
    {
        let color = self.photoAnalyzer.analyzeColors(imageStrips[i])
        colorList.append(color)
    }
}

为了澄清变量名称，以下是它们的描述：

photoAnalyzer是我编写的一个类的实例Analyzer它包含处理图像的所有方法。

analyzeColors是里面的一个方法Analyzer执行大部分分析并返回带有传入图像的主色的字符串的类

imageStrips是一个数组UIImage组成原始图像的部分

colorList是一个字符串数组，存储了返回值analyzeColor图像每个部分的方法。

上面的代码从for循环只访问一张图像imageList一次。我想做的是分析每个图像imageStrips同时，但我不知道如何去做。

任何建议将不胜感激。如果您想查看所有代码来进一步帮助我，我可以发布一个 GitHub 链接。

EDIT这是我更新的代码，用于同时处理 8 个处理器。

dispatch_apply(8, imageQueue) { numStrips -> Void in
    let color = self.photoAnalyzer.analyzeColors(imageStrips[numStrips])
    colorList.append(color)
}

但是，如果我尝试使用超过 8 个，代码实际上运行速度会比顺序运行慢。

有几种方法可以做到这一点，但在我们开始之前有一些观察结果：

• 为了尽量提高性能，如果您进行任何并发处理，请注意，无法保证它们的完成顺序。因此一个简单的colorList.append(color)如果它们出现的顺序很重要，则模式将不起作用。您可以预先填充colorList然后让每次迭代简单地做colorList[i] = color或者你可以使用字典。 （显然，如果顺序不重要，那么这并不重要。）

• 由于这些迭代将同时运行，因此您需要同步更新colorList。所以你的昂贵analyzeColors在后台队列上并发，但使用串行队列来更新colorList，以确保多个更新不会相互重叠。

• 在进行并发处理时，存在收益递减点。例如，将一个复杂的任务分解为 2-4 个并发循环可能会带来一些性能优势，但如果您开始过多地增加并发线程的数量，您会发现这些线程的开销开始对性能产生不利影响。因此，请使用不同程度的并发性进行基准测试，并且不要假设“更多线程”总是更好。

就如何实现这一点而言，有两种基本技术：

1. 如果你看到同时执行循环迭代 https://developer.apple.com/library/ios/documentation/General/Conceptual/ConcurrencyProgrammingGuide/OperationQueues/OperationQueues.html#//apple_ref/doc/uid/TP40008091-CH102-SW23 in the 并发编程指南：调度队列指南，他们谈论dispatch_apply，正是为此目的而设计的，运行for同时循环。

   colorList = [Int](count: 8, repeatedValue: 0)  // I don't know what type this `colorList` array is, so initialize this with whatever type makes sense for your app
   
   let queue = dispatch_get_global_queue(QOS_CLASS_UTILITY, 0)
   
   let qos_attr = dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, QOS_CLASS_UTILITY, 0)
   let syncQueue = dispatch_queue_create("com.domain.app.sync", qos_attr)
   
   dispatch_apply(8, queue) { iteration in
       let color = self.photoAnalyzer.analyzeColors(imageStrips[iteration])
       dispatch_sync(syncQueue) {
           colorList[iteration] = color
           return
       }
   }
   
   // you can use `colorList` here
   

   请注意，虽然这些迭代同时运行，但整个dispatch_apply循环相对于您启动它的队列同步运行。这意味着您不会希望从主线程调用上面的代码（我们永远不想阻塞主线程）。因此可能希望将整个事情分派到某个后台队列。

   顺便一提，dispatch_applyWWDC 2011 视频中对此进行了讨论街区和大中央调度的实践 https://developer.apple.com/videos/wwdc/2011/?id=308.

2. 另一种常见模式是创建一个调度组，使用该组将任务调度到并发队列，并指定一个dispatch_group_notify指定完成后您想要执行的操作。

   colorList = [Int](count: 8, repeatedValue: 0)  // I don't know what type this `colorList` array is, so initialize this with whatever type makes sense for your app
   
   let group = dispatch_group_create()
   let queue = dispatch_get_global_queue(QOS_CLASS_UTILITY, 0)
   
   let qos_attr = dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, QOS_CLASS_UTILITY, 0)
   let syncQueue = dispatch_queue_create("com.domain.app.sync", qos_attr)
   
   for i in 0 ..< 8 {
       dispatch_group_async(group, queue) {
           let color = self.photoAnalyzer.analyzeColors(imageStrips[i])
           dispatch_sync(syncQueue) {
               colorList[i] = color
               return
           }
       }
   }
   
   dispatch_group_notify(group, dispatch_get_main_queue()) {
       // use `colorList` here
   }
   
   // but not here (because the above code is running asynchronously)
   

   这种方法可以避免完全阻塞主线程，但您必须小心不要添加太多并发分派任务（因为工作线程是非常有限的资源）。

在这两个示例中，我创建了一个专用串行队列，用于将更新同步到colorList。这可能有点矫枉过正了。如果您没有阻塞主队列（无论如何都不应该这样做），您可以将此同步代码分派到主队列（这是一个串行队列）。但为此目的使用专用串行队列可能更精确。如果这是我要从多个线程不断交互的东西，我会使用读写器模式。但这对于这种情况来说可能已经足够了。