4

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

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() 由于某种原因与 GPars 不兼容吗？

4

1 回答 1

0

问题是onComplete不会阻塞。请求/操作确实在您的任务之前完成并且list超出了范围。

您需要waitAll()在操作返回之前等待所有任务完成。最简单的方法是onComplete用

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

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

于 2014-07-19T19:30:12.227 回答