concurrency - GPar 的数据并行性

标签 concurrency groovy parallel-processing gpars

我在这里找到了这个例子 Data Parallelism

GParsPool.withPool() {
    Closure longLastingCalculation = {calculate()}
    Closure fastCalculation = longLastingCalculation.async()
    Future result=fastCalculation()
    //do stuff while calculation performs …
    println result.get()
}

我觉得它有点广泛。有办法缩短吗?
也许:

GParsPool.withPool() {
    Future result = calculate().async()
    //do stuff while calculation performs …
    println result.get()
}

这行得通吗?
如果不行的话还有别的办法吗?

最佳答案

认为您需要:

Future result = { calculate() }.async()()

关于concurrency - GPar 的数据并行性,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14531276/

相关文章:

c++ - 编译器屏障的目的是什么?

java - 从 Groovy 中的 Iterable<Map.Entry> 创建 map

python - 如何在 python 中并行化大 for 循环

c# - 在上一个异步操作完成之前,第二个操作在此上下文中启动

c++ - 为多处理器查找 DAG 的静态调度 - 库?

concurrency - Memcache 的 append() 是内部原子的吗?

java - 在 Thread.join() 之前调用 Thread.interrupt() 会导致 join() 立即抛出 InterruptedException 吗?

c# - 在共享数据结构上同步

hibernate - 这个HQL查询有什么问题?

maven - Grails:为什么在编译期间执行 Config.groovy 文件?