grails - 异步作业出错

Question

我正在尝试创建一个不会阻止请求的异步任务。用户发出请求，任务将启动， Controller 将呈现“作业正在运行...”，这是为了避免请求被阻塞等待任务完成。
任务完成后，它将执行 onComplete 并对该任务的结果执行某些操作(例如调用将向用户发送邮件的服务)

| Error 2014-09-16 17:38:56,721 [Actor Thread 3] ERROR gpars.LoggingPoolFactory  - Async execution error: null

代码如下:

package testasync

import static grails.async.Promises.*

class TestController {

  def index() {
    //Create the job
    def job1 = task {
        println 'Waiting 10 seconds'
        Thread.sleep(10000)
        return 'Im done'
    }
    //On error
    job1.onError { Throwable err ->
        println "An error occured ${err.message}"
    }
    //On success
    job1.onComplete { result ->
        println "Promise returned $result"
    }
    render 'Job is running...'
  }

完整的堆栈跟踪:

| Error 2014-09-17 10:35:24,522 [Actor Thread 3] ERROR gpars.LoggingPoolFactory  -  Async execution error: null
Message: null
   Line | Method
 ->>   72 | doCall    in org.grails.async.factory.gpars.GparsPromise$_onError_closure2
  - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
  |     62 | run       in groovyx.gpars.dataflow.DataCallback$1
  |   1145 | runWorker in java.util.concurrent.ThreadPoolExecutor
  |    615 | run       in java.util.concurrent.ThreadPoolExecutor$Worker
  ^    745 | run . . . in java.lang.Thread

Answer 1

我结束了使用带有 grails-executor 插件的 executor 框架。我在这里上传了一个非常基本的例子:https://github.com/agusl88/grails-async-job-queuqe

该代码使用了 grails-executor 插件的“自定义”版本，我从插件库中合并了一些 PR 并打包为 jar，仅用于测试 Prop 。插件的仓库是这样的:https://github.com/basejump/grails-executor