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

- old
+ new

@@ -26,10 +26,10 @@ DBPOOL.preheat! t0 = Time.now count = 0 coprocs = CONCURRENCY.times.map { - spawn { loop { DBPOOL.acquire { |db| get_records(db); count += 1 } } } + coproc { 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)