相关疑难解决方法(0)

在Swift中编写命令行工具(CLT)时,我想处理大量数据.我已经确定我的代码是CPU限制的,性能可以从使用多个内核中受益.因此,我想并行化部分代码.说我想实现以下伪代码:

Fetch items from database
Divide items in X chunks
Process chunks in parallel
Wait for chunks to finish
Do some other processing (single-thread)

现在我一直在使用GCD,一个天真的方法看起来像这样:

let group = dispatch_group_create()
let queue = dispatch_queue_create("", DISPATCH_QUEUE_CONCURRENT)
for chunk in chunks {
    dispatch_group_async(group, queue) {
        worker(chunk)
    }
}
dispatch_group_wait(group, DISPATCH_TIME_FOREVER)

但是GCD需要一个运行循环,因此代码将在组永远不会执行时挂起.runloop可以启动dispatch_main(),但它永远不会退出.也可以运行NSRunLoop几秒钟,但这不是一个坚实的解决方案.无论GCD如何,使用Swift如何实现？