examples/interfaces/pg_pool.rb in polyphony-0.21 vs examples/interfaces/pg_pool.rb in polyphony-0.22
- old
+ new
@@ -25,9 +25,10 @@
puts "concurrency: #{CONCURRENCY}"
DBPOOL.preheat!
t0 = Time.now
count = 0
+
coprocs = CONCURRENCY.times.map do
spin do
loop do
DBPOOL.acquire do |db|
get_records(db)