Advertisement
Guest User

Untitled

a guest
Jan 6th, 2017
89
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.60 KB | None | 0 0
  1. //from log it seems that I created too many pools when I need only one
  2. def HikariPlayground = {
  3. (0 to 2000000).par.foreach {
  4. blah =>
  5. val q: ConnectionIO[Int] = DailyUpdateQuery(Features("","",Array(blah,blah))).run
  6. val p: Task[Int] = for {
  7. xa <- HikariTransactor[Task]("org.postgresql.Driver", "jdbc:postgresql:nova", "nova", "emeth") //utils.GetHikariTransactor
  8. _ <- xa.configure{
  9. hx =>
  10. Task.delay(hx.setMaximumPoolSize(65535))
  11. }
  12. a <- q.transact(xa) ensuring xa.shutdown
  13. } yield a
  14. p.unsafePerformSync
  15. }
  16. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement