通用异步数组的 enumerate() 方法

Question

您好，我尝试为我的自定义异步数组创建 enumerate() 方法，但仍然出现编译错误。我的自定义类看起来像这样：

class AsyncArray<T> {

private var array = [T]()
private var queue = DispatchQueue(label: "async_queue", attributes: .concurrent)

    func enumerated() -> EnumeratedSequence<[T]> {
        var value = EnumeratedSequence<[T]>() // compilation error Cannot invoke initializer for type 'EnumeratedSequence<[T]>' with no arguments
        queue.sync {
            value = self.array.enumerated()
        }
        return value
    }
}

如何在我的自定义类中实现enumerated() 方法？

Answer 1

您分配给value 只是为了在sync 调用中立即覆盖它。没必要。

DispatchQueue.sync 让你直接返回结果：

import Dispatch

class AsyncArray<T> {
    private var array = [T]()
    private var queue = DispatchQueue(label: "async_queue", attributes: .concurrent)

    func enumerated() -> EnumeratedSequence<[T]> {
        return queue.sync {
            return self.array.enumerated()
        }
    }
}

供参考：如果您需要分配给捕获的变量，就像您尝试做的那样（例如，这将是一个async 调用所必需的），它看起来像这样：

import Dispatch

class AsyncArray<T> {
    private var array = [T]()
    private var queue = DispatchQueue(label: "async_queue", attributes: .concurrent)

    func enumerated() -> EnumeratedSequence<[T]> {
        var result: EnumeratedSequence<[T]>?
        return someAsyncCall {
            result = self.array.enumerated()
        }
        waitForAsyncCallToFinish()
        return result!
    }
}