圣杯。无法连接，池已耗尽

Question

在为了使用多线程而修改了一个服务方法之后，我发现如果不止一个用户多次尝试请求页面(并调用服务方法)，服务器就会抛出“无法连接，池耗尽”异常。让我提供一个我的服务类的例子。

class DocumentService {
   def convertToJSON() {
      docs.collect { doc ->
         taskExecutor.submit({
            Document.withNewSession {
                def json = convertDocumentToJSON(doc)
            }
         } as Callable)
      }.collect { it.get() }
   }

   def convertDocumentToJSON(doc){
      def json = [:]
      // ... fill json with data using doc and GORM requests
      evaluateStatus(json)
      return json
   }

   def evaluateStatus(json){
      //... some work using database through GORM
   }
}

我已经在这个问题上挣扎了一个多星期，我找不到解决方案。我不太明白Grails如何与会话、连接和事务一起工作。我的猜测是跟随。当调用ConvertDocumentToJSON时，它从池中获取连接（4个用户，每个用户25个线程=100个连接），但随后他们需要调用评估状态方法，该方法也会尝试从池中获取连接以满足自己的需要。但是池已经耗尽，没有一个线程可以释放连接，因为它们都在等待评估状态。所以，有死锁。我试图将SUPPORT传播类型放置为评估状态，但我得到“pooled连接已关闭”异常。然后我想它可能工作，如果我从convertDocumentToJSON移动评估状态调用并编写这样的代码

def convertToJSON(){
  docs.collect { doc ->
    taskExecutor.submit({
        Document.withNewSession {
            def json = convertDocumentToJSON(doc)
            evaluateStatus(json) // move call from convertDocumentToJSON
        }
      } as Callable)
  }.collect { it.get() }
}

但在这种情况下，我也遇到了同样的错误（耗尽的池）。请给我建议，我应该在代码中修复什么

Answer 1

你需要一些东西来限制连接的使用，尝试使用GPars，例如

import groovyx.gpars.GParsPool

GParsPool.withPool() {
    docs.collect {
        // do your stuff...
    }
}

常见的groovy收集方法有xxxx个并行版本，例如collectParallel，您可以使用它们来提高性能。