上述答案中关于使用concurrentPerform 的线索是正确的,但没有展开。所以这里是简单的解决方案:
class ConcurrentCalculator<T> {
func calc(for b: [T], _ f: (T) -> T) -> [T?] {
let n = b.count
var a: [T?] = Array(repeating: nil, count: n)
DispatchQueue.concurrentPerform(iterations: n) { i in
a[i] = f(b[i])
}
return a
}
}
这是测试:
let myB = Array(1...100)
func myF(b: Int) -> Int {
b * b
}
let myCalc = ConcurrentCalculator<Int>()
let myA = myCalc.calc(for: myB, myF)
print(myA)
输出看起来像
[1, 4, 9, 16, 25, 36, 49, 64, 81, 100, 121, 144, 169, 196, 225, 256, 289, 324, 361, 400, 441, 484, 529, 576, 625, 676, 729, 784, 841, 900, 961, 1024, 1089, 1156, 1225, 1296, 1369, 1444, 1521, 1600, 1681, 1764, 1849, 1936, 2025, 2116, 2209, 2304, 2401, 2500, 2601, 2704, 2809, 2916, 3025, 3136, 3249, 3364, 3481, 3600, 3721, 3844, 3969, 4096, 4225, 4356, 4489, 4624, 4761, 4900, 5041, 5184, 5329, 5476, 5625, 5776, 5929, 6084, 6241, 6400, 6561, 6724, 6889, 7056, 7225, 7396, 7569, 7744, 7921, 8100, 8281, 8464, 8649, 8836, 9025, 9216, 9409, 9604, 9801, 10000]
当然这是一个基本的解决方案:它不是线程安全的,而且它可能会遇到大型数组的内存问题。这可以稍后添加。
这种方法的美妙之处在于您不需要计算可用线程等。它只会使用所有可用线程。