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 



25
26
27
28
 
# File 'lib/bbk/app/dispatcher.rb', line 25

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