Class: BBK::App::ConcurrentPoolFactory

Inherits:
Object
  • Object
show all
Defined in:
lib/bbk/app/dispatcher.rb

Class Method Summary collapse

Class Method Details

.call(pool_size, queue_size) ⇒ Object 



23
24
25
26
 
# File 'lib/bbk/app/dispatcher.rb', line 23

def self.call(pool_size, queue_size)
  Concurrent::FixedThreadPool.new(pool_size, max_queue:       queue_size,
                                             fallback_policy: :caller_runs)
end