swift - 使用BrightFutures控制并行性，BrightFutures是Swift中的“ future ”实现

brightfources是Swift语言中“future”的一个很好的实现。
https://github.com/Thomvis/BrightFutures
我喜欢用它来控制多核CPU的并行性。有人知道控制要使用的CPU核心/物理线程的方法吗？

最佳答案

所有传递给BrightFutures的闭包都是根据BFdefault threading model执行的。似乎您想偏离默认模型。这可以通过传递custom execution context来实现。
可以使用以下函数创建限制其执行的并行任务数的执行上下文：

func executionContextWithControlledParallelism(p: Int) -> ExecutionContext {
        let s = Semaphore(value: p)
        let q = Queue.global.context
        return { task in
            s.wait()
            q {
                task()
                s.signal()
            }
        }
    }

我使用以下代码对此进行了简短的测试：

let context = executionContextWithControlledParallelism(5)

for _ in 0..<100 {
    future(context:context) { () -> Int in
        return fibonacci(Int(arc4random_uniform(15)))
    }
}

必须将context传递到要限制并行性的每个map、flatMap等。我承认那看起来很麻烦。更好的方法（BrightFutures目前不支持这种方法）是设置默认线程模型，如下所示：

let context = executionContextWithControlledParalelism(5)

// this is not supported right now:
BrightFutures.setDefaultThreadingModel(model: {
    return context
})

如果您喜欢这样，请考虑提交一个问题来请求此请求，或者（甚至更好）创建一个拉取请求。