信号量的最大值？

Question

例如，有一个1000倍的循环。最大值是多少才能使它快速，有效，并且不会导致死锁？

let group = DispatchGroup()
let queue = DispatchQueue(label: "com.num.loop", attributes: .concurrent)
let semaphore = DispatchSemaphore(value: 4)
for i in 1...1000 {
    semaphore.wait()
    group.enter()
    queue.async(group: group, execute: {
        doWork(i)                                    
        group.leave()
        semaphore.signal()
    })            
}

group.notify(queue: DispatchQueue.main) {
    // go on...
}

Answer 1

以下几点观察:

>

您永远不希望超过每个QoS的最大GCD工作线程数。如果你超过这个值，你可能会在你的应用程序中遇到阻塞。我最后一次检查，这个限制是64个线程。

话虽如此，但设备上超过内核的数量通常没有什么好处。

通常，我们会让GCD使用concurrentperform计算出并发线程的最大数量，这是为设备自动优化的。它还消除了对任何信号量或组的需要，通常导致更自然的读取代码:

DispatchQueue.global().async {
    DispatchQueue.concurrentPerform(iterations: 1000) { i in
        doWork(i)                                    
    }

    DispatchQueue.main.async {
        // go on...
    }
}

concurrentPerform将并行运行1,000个迭代，但将并发线程的数量限制在适合您的设备的水平，从而消除了对信号量的需要。但是concurrentperform本身是同步的，在完成所有迭代之前不会继续，因此不需要分派组。因此，将整个concurrentperform分派到某个后台队列，完成后，只需执行“完成代码”（或者，在您的情况下，将该代码分派回主队列）。

虽然我在上面讨论了concurrentperform，但只有当doWork同步执行其任务（例如，某些计算操作）时，它才起作用。如果它发起的东西本身是异步的，那么我们必须回到这个信号量/组技术。（或者，更好的做法是使用异步operation子类和具有合理maxConcurrentOperationCount队列，或者将flatmap（maxPublishers:)与合理的计数限制相结合）。

关于合理的阈值，在这种情况下，没有神奇的数字。你只需要执行一些经验测试，在内核数量和应用程序中可能发生的其他事情之间找到合理的平衡。例如，对于网络请求，我们通常使用4或6作为最大计数，这不仅考虑到超过该计数的好处会减少，而且考虑到如果成千上万的用户碰巧同时提交过多的并发请求对服务器的影响。

在“使其快速”方面，“应该允许并发运行多少次迭代”的选择只是决策制定过程的一部分。更关键的问题很快就变成了确保doWork完成足够的工作，以证明并发模式引入的适度开销是合理的。

例如，如果处理一个1,000×1,000像素的图像，您可以执行1,000,000次迭代，每个迭代处理一个像素。但如果你这样做，你可能会发现它实际上比你的非并发翻译慢。相反，您可能有1,000次迭代，每个迭代处理1,000个像素。或者您可能有100次迭代，每次处理10,000个像素。这种被称为“跨步”的技术通常需要一点经验研究，以便在一个人将执行多少次迭代和每个迭代完成多少工作之间找到正确的平衡。（而且，顺便说一句，当多个线程争夺相邻的内存访问地址时，这种跨步模式通常还可以防止高速缓存晃动。）