0
查了doc,但没有谈到很多细节的实现。想知道是否对于大型阵列,它是否以并发方式执行?Swift数组的Map方法是否同时实现?
查了doc,但没有谈到很多细节的实现。想知道是否对于大型阵列,它是否以并发方式执行?Swift数组的Map方法是否同时实现?
Array
的map
实现明确不执行任何多线程,但没有任何说你不能做一个并发实现。这里是一个多数民众赞成广义与任何Sequence
工作:
import Dispatch
class SharedSynchronizedArray<T> {
var array = [T]()
let operationQueue = DispatchQueue(label: "SharedSynchronizedArray")
func append(_ newElement: T) {
operationQueue.sync {
array.append(newElement)
}
}
}
public struct ConcurrentSequence<Base, Element>: Sequence
where Base: Sequence, Element == Base.Iterator.Element {
let base: Base
public func makeIterator() -> Base.Iterator {
return base.makeIterator()
}
public func map<T>(_ transform: @escaping (Element) -> T) -> [T] {
let group = DispatchGroup()
let resultsStorageQueue = DispatchQueue(label: "resultStorageQueue")
let results = SharedSynchronizedArray<T>()
let processingQueue = DispatchQueue(
label: "processingQueue",
attributes: [.concurrent]
)
for element in self {
group.enter()
print("Entered DispatchGroup for \(element)")
var result: T?
let workItem = DispatchWorkItem{ result = transform(element) }
processingQueue.async(execute: workItem)
resultsStorageQueue.async {
workItem.wait()
guard let unwrappedResult = result else {
fatalError("The work item was completed, but the result wasn't set!")
}
results.append(unwrappedResult)
group.leave()
print("Exited DispatchGroup for \(element)")
}
}
print("Started Waiting on DispatchGroup")
group.wait()
print("DispatchGroup done")
return results.array
}
}
public extension Sequence {
public var parallel: ConcurrentSequence<Self, Iterator.Element> {
return ConcurrentSequence(base: self)
}
}
print("Start")
import Foundation
let input = Array(0..<100)
let output: [Int] = input.parallel.map {
let randomDuration = TimeInterval(Float(arc4random())/Float(UInt32.max))
Thread.sleep(forTimeInterval: randomDuration)
print("Transforming \($0)")
return $0 * 2
}
print(output)
// print(output.parallel.filter{ $0 % 3 == 0 })
print("Done")
让我们[在聊天中继续讨论](http://chat.stackoverflow.com/rooms/142349/discussion-between-alexander-and-hamish)。 – Alexander
地图是一个同步的方法 –
都能跟得上。对于大多数情况来说,多线程将比它的价值更高。不过,您可以自己轻松实现它。 – Alexander
http://stackoverflow.com/a/41215383/3141234 – Alexander