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)