grails 2.3.x 异步和睡眠答案

【问题标题】：grails 2.3.x async and sleepgrails 2.3.x 异步和睡眠
【发布时间】：2013-12-24 02:03:40
【问题描述】：

我在使用 grails 2.3.x 和异步时遇到了一些奇怪的行为。我正在用这段代码做一些测试：

def test1() {
    def list = new PromiseList()
    list << {
        Thread.sleep(1000)
        println "1"
        return "1"
    }
    list << {
        Thread.sleep(2000)
        println "2"
        return "2"
    }
    list << {
        Thread.sleep(3000)
        println "3"
        return  "3"
    }
    list.onComplete { List results ->
        println 'finished: '+results
    }
    list.onError { error ->
        error.printStackTrace()
    }
    render 'finish'
}

但在我的日志中我得到了：

1
| Error java.lang.NullPointerException
| Error     at org.apache.catalina.connector.Request.notifyAttributeAssigned(Request.java:1565)
| Error     at org.apache.catalina.connector.Request.setAttribute(Request.java:1556)
| Error     at org.apache.catalina.connector.RequestFacade.setAttribute(RequestFacade.java:543) 
| Error     at org.apache.catalina.core.ApplicationHttpRequest.setAttribute(ApplicationHttpRequest.java:281)
| Error     at org.codehaus.groovy.grails.web.util.WebUtils.storeGrailsWebRequest(WebUtils.java:682)
| Error     at org.codehaus.groovy.grails.plugins.web.async.WebRequestPromsiseDecorator$_decorate_closure1.doCall(WebRequestPromiseDecoratorLookupStrategy.groovy:61)
| Error     at sun.reflect.GeneratedMethodAccessor283.invoke(Unknown Source)
| Error     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
| Error     at java.lang.reflect.Method.invoke(Method.java:606)
| Error     at org.springsource.loaded.ri.ReflectiveInterceptor.jlrMethodInvoke(ReflectiveInterceptor.java:1260)
| Error     at org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:90)
| Error     at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:233)
| Error     at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:1086)
| Error     at groovy.lang.ExpandoMetaClass.invokeMethod(ExpandoMetaClass.java:1110)
| Error     at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:910)
| Error     at groovy.lang.Closure.call(Closure.java:411)
| Error     at groovy.lang.Closure.call(Closure.java:405)
| Error     at groovyx.gpars.group.PGroup$3.call(PGroup.java:287)
| Error     at groovyx.gpars.group.PGroup$4.run(PGroup.java:311)
| Error     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
| Error     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
| Error     at java.lang.Thread.run(Thread.java:724)
2
3

实际上任务（和 onError 闭包）被执行了，但 onComplete 没有（当然）！！

我做错了什么？

除了 Thread.sleep() 实际代码取自以下文档：http://grails.org/doc/latest/guide/async.html

Thread.sleep() 是否由于某种原因与 GPar 不兼容？

【问题讨论】：

标签： grails asynchronous sleep gpars

【解决方案1】：

问题是onComplete 没有阻塞。请求/操作确实在您的任务之前完成，list 超出范围。

您需要使用waitAll() 等待所有任务完成，然后操作返回。最简单的方法是将onComplete 替换为

    def result = list.get ()
    println 'finished: ' + result

list.get()是通过调用waitAll()实现的。

【讨论】：