examples/millions/client.rb in async-io-1.18.5 vs examples/millions/client.rb in async-io-1.20.0
- old
+ new
@@ -18,10 +18,12 @@
puts "Starting #{CONCURRENCY} processes, running #{TASKS} tasks, making #{REPEATS} connections."
puts "Total number of connections: #{CONCURRENCY * TASKS * REPEATS}!"
begin
- container = Async::Container::Forked.new(concurrency: CONCURRENCY) do
+ container = Async::Container::Forked.new
+
+ container.run(count: CONCURRENCY) do
Async do |task|
connections = []
TASKS.times do
task.async do