Как установить размер ThreadPool в Slick? - PullRequest
Новая
       30

Как установить размер ThreadPool в Slick?

0 голосов
/ 18 сентября 2018

Как мне установить размер threadPool в слике?

Вот мой конфиг: 

pp {
  profile = "slick.jdbc.OracleProfile$"
  db {
    url                 = "jdbc:oracle:thin:@52.4.90.244:1521:pp"
    driver              = oracle.jdbc.OracleDriver
    keepAliveConnection = true
    connectionPool      = disabled
    user                = "xxx"
    password            = "xxx"
  }
}

Я на самом деле делаю только один запрос, в потоковом режиме, действительно ли мне нужен threadPool?Моя цель - просто извлечь все строки из таблицы.

Пока у меня появляется следующая ошибка: 

*** (s.basic.BasicBackend.stream) Signaling onSubscribe(slick.jdbc.JdbcBackend$JdbcStreamingActionContext@76f2bbc1)
*** (s.basic.BasicBackend.action) #1: [fused] cleanUp
      try: andThen
        1: PushStatementParameters StatementParameters(ForwardOnly,ReadOnly,null,null,100)
        2: StreamingResultAction [select * FROM DRUG]
*** (s.basic.BasicBackend.action) #2: SynchronousDatabaseAction.Pin
*** (s.basic.BasicBackend.action) #3: [fused] andThen
      1: PushStatementParameters StatementParameters(ForwardOnly,ReadOnly,null,null,100)
      2: StreamingResultAction [select * FROM DRUG]
*** (s.basic.BasicBackend.action) #4: SynchronousDatabaseAction.Pin
*** (s.basic.BasicBackend.action) #5: SynchronousDatabaseAction.Unpin
*** (s.basic.BasicBackend.stream) Signaling onError(java.util.concurrent.RejectedExecutionException: Task slick.basic.BasicBackend$DatabaseDef$$anon$2@3061964c rejected from slick.util.AsyncExecutor$$anon$2$$anon$1@55d260cc[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0])
...