examples/interfaces/pg_pool.rb in polyphony-0.24 vs examples/interfaces/pg_pool.rb in polyphony-0.25

@@ -9,11 +9,11 @@
   password: nil,
   dbname:   'reality',
   sslmode:  'require'
 }.freeze
 
-DBPOOL = Polyphony::ResourcePool.new(limit: 8) { PG.connect(PGOPTS) }
+DBPOOL = Polyphony::ResourcePool.new(limit: 16) { PG.connect(PGOPTS) }
 
 def get_records(db)
   db.query('select pg_sleep(0.001) as test')
   # puts "got #{res.ntuples} records: #{res.to_a}"
 rescue StandardError => e
@@ -26,11 +26,11 @@
 
 DBPOOL.preheat!
 t0 = Time.now
 count = 0
 
-coprocs = CONCURRENCY.times.map do
+fibers = CONCURRENCY.times.map do
   spin do
     loop do
       DBPOOL.acquire do |db|
         get_records(db)
         count += 1
@@ -38,6 +38,6 @@
     end
   end
 end
 sleep 5
 puts "count: #{count} query rate: #{count / (Time.now - t0)} queries/s"
-coprocs.each(&:interrupt)
+fibers.each(&:interrupt)