2

我在 grails 2.3.1 - 尝试使用异步功能。

这是批量数据处理。我正在尝试同步 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()
4

1 回答 1

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)
于 2014-01-24T04:45:37.640 回答