在 Grails 2.3 中运行一些异步的东西

Question

在我的 Grails 服务中，我希望异步运行方法的一部分。

以下是 2.3.x http://grails.org/doc/2.3.0.M1/guide/async.html 的文档

我愿意

public class MyService {
    public void myMethod() {
        Promise p = task {
            // Long running task
        }
        p.onError { Throwable err ->
            println "An error occured ${err.message}"
        }
        p.onComplete { result ->
            println "Promise returned $result"
        }
        // block until result is called
        def result = p.get()
    }
}

但是，我想在没有任何阻塞的情况下执行我的。 p.get() 方法阻塞。如何在没有任何阻塞的情况下执行承诺。我不在乎myMethod() 是否返回，这是一种“一劳永逸”的方法。

Answer 1

因此，根据documentation，如果您不调用.get() 或.waitAll() 而只是使用onComplete，您可以在不阻塞当前线程的情况下运行您的任务。

这是一个非常愚蠢的示例，我在控制台中将其作为概念证明。

import static grails.async.Promises.*
def p = task {
    // Long running task
    println 'Off to do something now ...'
    Thread.sleep(5000)
    println '... that took 5 seconds'
    return 'the result'
}

p.onError { Throwable err ->
    println "An error occured ${err.message}"
}
p.onComplete { result ->
    println "Promise returned $result"
}

println 'Just to show some output, and prove the task is running in the background.'

运行上面的例子会得到以下输出：

Off to do something now ...  
Just to show some output, and prove the task is running in the background.  
... that took 5 seconds   
Promise returned the result