Na}{

File Content: `stress_ruby_thread_pool.rb`

#!/usr/bin/env ruby

$: << File.expand_path('../../lib', __FILE__)

require 'benchmark'
require 'concurrent/executors'

COUNT = 100_000

executor = Concurrent::CachedThreadPool.new
latch = Concurrent::CountDownLatch.new

COUNT.times { executor.post{ nil } }

#COUNT.times do |i|
#  executor.post{ nil }
#  sleep(0.01) if i % 1000 == 0
#end

executor.post{ latch.count_down }
latch.wait

puts "Max length:           #{executor.max_length}" if executor.respond_to?(:max_length)
puts "Largest length:       #{executor.largest_length}" if executor.respond_to?(:largest_length)
puts "Scheduled task count: #{executor.scheduled_task_count}" if executor.respond_to?(:scheduled_task_count)
puts "Completed task count: #{executor.completed_task_count}" if executor.respond_to?(:completed_task_count)

Name	Size	Permission
a-tour-of-go-channels	---	0755
go-by-example-channels	---	0755
actor_stress_test.rb	3305 bytes	0755
atomic_example.rb	392 bytes	0755
benchmark_async.rb	6973 bytes	0755
benchmark_atomic.rb	2592 bytes	0755
benchmark_atomic_1.rb	2585 bytes	0755
benchmark_atomic_boolean.rb	984 bytes	0755
benchmark_atomic_fixnum.rb	964 bytes	0755
benchmark_map.rb	581 bytes	0755
benchmark_new_futures.rb	2210 bytes	0755
benchmark_read_write_lock.rb	4374 bytes	0755
benchmark_structs.rb	4776 bytes	0755
format.rb	1902 bytes	0644
graph_atomic_bench.rb	1769 bytes	0755
init.rb	104 bytes	0644
stress_ruby_thread_pool.rb	791 bytes	0755
thread_local_memory_usage.rb	1644 bytes	0755
thread_local_var_bench.rb	606 bytes	0755
who.rb	711 bytes	0755

Name

Size

Permission

Action

a-tour-of-go-channels

---

0755