examples/interfaces/pg_pool.rb in polyphony-0.17 vs examples/interfaces/pg_pool.rb in polyphony-0.19

- old
+ new

@@ -26,10 +26,10 @@ DBPOOL.preheat! t0 = Time.now count = 0 coprocs = CONCURRENCY.times.map { - coproc { loop { DBPOOL.acquire { |db| get_records(db); count += 1 } } } + spin { loop { DBPOOL.acquire { |db| get_records(db); count += 1 } } } } sleep 5 puts "count: #{count} query rate: #{count / (Time.now - t0)} queries/s" coprocs.each(&:interrupt)