ios - 我们如何在swift中使用协议(protocol)实现并发线程？

Question

<分区>

Answer 1

之前我建议使用目标队列，但更好的是，创建一个主并发队列，然后为命名队列创建串行队列，然后通过该主并发队列调度所有内容。与目标队列方法不同，这将遵循分配给命名队列的任务和分配给未命名队列的任务的调度。

通过该实现，这是一个示例(Instruments“兴趣点”配置文件)，其中我为名为“fred”和“ginger”的队列添加了任务，还有一个被添加到未命名的队列中，然后我添加了一个屏障任务，然后向上述每个队列添加另外两个任务。

如您所见，它尊重命名队列的串行性质，未命名队列是并发的，所有这些队列彼此并发，但屏障是跨越所有队列的屏障。

class MyDispatchQueue: ConcurrentQueueWithSerialization {
    private var namedQueues = [String: DispatchQueue]()
    private var queue = DispatchQueue(label: Bundle.main.bundleIdentifier! + ".target", attributes: .concurrent)
    private let lock = NSLock()

    private func queue(with label: String) -> DispatchQueue {
        lock.lock()
        defer { lock.unlock() }

        if let queue = namedQueues[label] { return queue }

        let queue = DispatchQueue(label: Bundle.main.bundleIdentifier! + "." + label)
        namedQueues[label] = queue
        return queue
    }

    func async(with label: String, task: @escaping () -> Void) {
        queue.async {
            self.queue(with: label).sync(execute: task)
        }
    }

    func async(task: @escaping () -> Void) {
        queue.async(execute: task)
    }

    func asyncAfter(deadline: DispatchTime, with label: String, task: @escaping () -> Void) {
        queue.asyncAfter(deadline: deadline) {
            self.queue(with: label).sync(execute: task)
        }
    }

    func asyncAfter(deadline: DispatchTime, task: @escaping () -> Void) {
        queue.asyncAfter(deadline: deadline, execute: task)
    }

    func asyncBarrier(task: @escaping () -> Void) {
        queue.async(flags: .barrier, execute: task)
    }
}

请注意，我还同步了对namedQueues 数组的访问，以确保此类的线程安全。