ios - 如何限制 gcd 队列缓冲区大小

Question

我正在尝试使用 CoreImage 和 Metal 处理一系列 UIImages 并显示它们。我的问题是如果我的 gcd block 很忙，我想删除传入的图像。如何实现这个 GCD 队列，如何定义队列的最大缓冲区大小？

Answer 1

没有针对此的原生机制，但您可以使用信号量通过算法实现您想要的。

在我深入探讨“一次处理 4 个，但如果我们很忙则丢弃任何一个”场景之前，让我首先考虑更简单的“处理所有，但在任何给定时间不超过 4 个”模式。 (我将在下面回答你的问题，但基于这个更简单的情况。)

例如，假设您有一些预先存在的对象数组，并且您希望同时处理它们，但在任何给定时间不超过四个(可能是为了最大限度地减少峰值内存使用):

DispatchQueue.global().async {
    let semaphore = DispatchSemaphore(value: 4)

    for object in objects {
        semaphore.wait()

        processQueue.async {
            self.process(object)
            semaphore.signal()
        }
    }
}

基本上，wait 函数将作为 the documentation说，“减少计数信号量。如果结果值小于零，该函数将等待信号发生再返回。”

所以，我们从计数 4 开始我们的信号量。因此，如果 objects 中有 10 个项目，前四个将立即开始，但第五个直到以下之一才会开始较早的那些完成并发送了一个信号(它将信号量计数器递增 1)，依此类推，实现了“并发运行，但在任何给定时间最多 4 个”行为。

---

那么，让我们回到你的问题。假设您希望一次处理不超过四张图像，如果当前已处理四张图像，则丢弃任何传入图像。您可以通过告诉 wait 根本不等待来实现这一点，即检查正确的 .now() 信号量计数器是否已经归零，即，类似于:

let semaphore = DispatchSemaphore(value: 4)
let processQueue = DispatchQueue(label: "com.domain.app.process", attributes: .concurrent)

func submit(_ image: UIImage) {
    if semaphore.wait(timeout: .now()) == .timedOut { return }

    processQueue.async {
        self.process(image)
        self.semaphore.signal()
    }
}

请注意，我们通常希望避免阻塞主线程(就像 wait 可以做到的)，但是因为我使用了 .now() 的超时，它永远不会阻塞，我们只是使用信号量以一种良好的、线程安全的方式跟踪我们的位置。

---

最后一种方法是考虑操作队列:

// create queue that will run no more than four at a time (no semaphores needed; lol)

let processQueue: OperationQueue = {
    let queue = OperationQueue()
    queue.maxConcurrentOperationCount = 4
    return queue
}()

func submit(_ image: UIImage) {
    // cancel all but the last three unstarted operations

    processQueue.operations
        .filter { $0.isReady && !$0.isFinished && !$0.isExecuting && !$0.isCancelled }
        .dropLast(3)
        .forEach { $0.cancel() }

    // now add new operation to the queue

    processQueue.addOperation(BlockOperation {
        self.process(image)
    })
}

行为略有不同(将最近的四张图像排在队列中，准备就绪)，但需要考虑。