在 Grails 应用程序中为长时间运行的作业构建队列的最佳方法是什么？

Question

我有一个 Grails 应用程序，它有一些计算密集型优化，运行时间约为 5 分钟（可能更长）。 目前，我正在主请求线程中执行这些操作，即请求返回需要 5 分钟。 它确实有效，但从可用性的角度来看当然很糟糕。

那么以异步方式实现这一点的最佳方法是什么？ 我假设必须涉及 ThreadPoolExecutor，但如何启动和访问它？ 我可以将其建模为 Grails 服务吗？ 或者一份工作（似乎这些只适用于经常性工作）？

另外，处理工作状态的最佳方式是什么？ 通过一个标志或者数据库中的一个全新的类？ 浏览器是否显示旋转图标并继续轮询直到状态发生变化？

Answer 1

有一个 grails 插件 background-thread 可能正是您正在寻找的。

当然，可以推出自己的线程池或使用现有的 Java 东西。

Answer 2

为此，我将使用 grails JMS 插件。

然后，您可以使用“onMessage”方法创建一个服务，该方法自动与底层 jms 提供程序交互（例如 OpenMQ 或 ActiveMQ

它使这种事情变得非常简单。

Answer 3

后台线程插件已经过时，所以我不建议使用它，而且 JMS 对于后台处理来说似乎有点过分了。 JMS 更像是一个消息队列，而不是后台处理实用程序。

我建议使用 Quartz 插件或使用 gpars。

Answer 4

本着“可能有效的最简单的事情”的精神，我做了这样的事情作为一项简单的服务。 （当然可能太简单了，欢迎批评）。

我使用了 Groovy 的功能，即 Thread 有一个需要闭包的静态启动方法。 请参阅 http://groovy.codehaus.org/groovy-jdk/java /lang/Thread.html

我在服务上实现了一个方法，如下所示：

synchronized def runThreadedTask() {
  if(taskRunning) { 
    // taskRunning is defined as a service level flag to monitor job status
    // if we are already running the task just return
    return;
  }

  Thread.start {
    taskRunning = true
    // do job processing here
    taskRunning = false
  }
}

Answer 5

grails install-plugin background-thread

def backgroundService

backgroundService.execute("doing my thing", {

// 在这里工作

});

Answer 6

自从有人问这个问题以来已经有一段时间了，但由于它刚刚在搜索中出现，我想我应该补充一点，Thread 对象中现在有一个 Groovy 线程闭包。 你只需使用：

Thread.start {
    // async code goes here
}

然后就到此为止了。 您的异步代码可以在完成后调用更新数据方法或其他方法 - 如果您可以运行多个线程，您可能需要同步它。