所以我有一个服务设置从用户上传的文件导入大量的数据.我想让用户在处理文件时能够继续在网站上工作.我通过创建一个线程实现了这一点.
Thread.start {
//work done here
}
现在出现的问题是我不想同时运行多个线程.这是我试过的：
class SomeService {
Thread thread = new Thread()
def serviceMethod() {
if (!thread?.isAlive()) {
thread.start {
//Do work here
}
}
}
}
但是,这不行. thread.isAlive()总是返回false.有什么想法可以如何实现？
解决方法
我会考虑使用Executor.
import java.util.concurrent.*
import javax.annotation.*
class SomeService {
ExecutorService executor = Executors.newSingleThreadExecutor()
def serviceMethod() {
executor.execute {
//Do work here
}
}
@PreDestroy
void shutdown() {
executor.shutdownNow()
}
}
使用newSingleThreadExecutor将确保任务一个接一个执行.如果后台任务已经运行,那么下一个任务将被排队,并且在运行任务完成时启动(serviceMethod本身仍将立即返回).
如果您的“在这里工作”涉及GORM数据库访问,您可能希望考虑executor plugin,因为该插件将为后台任务设置适当的持久性上下文(例如Hibernate会话).