Grails 异步 - 创建承诺答案

【问题标题】：Grails async - creating promisesGrails 异步 - 创建承诺
【发布时间】：2014-01-24 12:45:37
【问题描述】：

我正在使用 grails 2.3.1 - 尝试使用 async features。

这是批量数据处理。我正在尝试同步 2 个数据库，这涉及比较两者并返回“增量”列表。我正在努力加快进程

文档说我可以向 PromiseList 添加一组闭包，然后调用 onComplete() 来检查所有闭包是否已完成。这些是我的尝试——直接基于文档中的“您也可以手动构建 PromiseList”：

    def tasksMemberDeltas = new PromiseList()
    pages.each {Integer page ->
        tasksMemberDeltas << {findCreateMemberDeltas(page, (page + pageSize) - 1)}
        if (page % 30 == 0) {
            tasksMemberDeltas.onComplete {
                tasksMemberDeltas = new PromiseList()
            }
        }

Error groovy.lang.MissingMethodException: 
 No signature of method: java.util.ArrayList.onComplete()

【问题讨论】：

标签： grails asynchronous

【解决方案1】：

最后我调用了调用 waitAll 的 .get()。进入 .get() 并发现它确实 waitAll 是我的启示。

因此，如果我有一个任务，我会调用：

waitAll finalDeltas

如果我有一个清单，我会打电话：

taskFinalDeltas.get()

onComplete() 在逻辑上与单个增量相关。不是清单。所以这工作正常：

Promise memberDeleteDeltas = task {
        findDeleteAndTagDeltas()
    }
    memberDeleteDeltas.onError { Throwable err ->
        println "An error occured ${err.message}"
    }
    memberDeleteDeltas.onComplete { result ->
        println "Completed create deltas"
    }
    waitAll(memberDeleteDeltas)

【讨论】：