Module: ActionSubscriber::ThreadPools

Defined in:
lib/action_subscriber/thread_pools.rb

Constant Summary collapse

MUTEX = 
::Mutex.new
THREADPOOL_DEFAULTS = 
{
  :auto_terminate => true,
  :fallback_policy => :caller_runs,
  :max_queue => 10_000,
}.freeze

Class Method Summary collapse

Class Method Details

.setup_threadpool(name, settings) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/action_subscriber/thread_pools.rb', line 19

def self.setup_threadpool(name, settings)
  MUTEX.synchronize do
    @threadpools ||= {}
    fail ArgumentError, "a #{name} threadpool already exists" if @threadpools.has_key?(name)
    @threadpools[name] = create_threadpool(settings)
  end
end

.threadpools ⇒ Object 



13
14
15
16
17
 
# File 'lib/action_subscriber/thread_pools.rb', line 13

def self.threadpools
  MUTEX.synchronize do
    @threadpools ||= {}
  end
end