Method: Concurrent::CachedThreadPool#initialize

Defined in:

lib/concurrent-ruby/concurrent/executor/cached_thread_pool.rb

#initialize(opts = {}) ⇒ CachedThreadPool

Create a new thread pool.

Options Hash (opts):

• :fallback_policy (Symbol) — default: `:abort` —

  the fallback policy

Raises:

• (ArgumentError) —

  if ‘fallback_policy` is not a known policy

See Also:

• http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Executors.html#newCachedThreadPool--

# File 'lib/concurrent-ruby/concurrent/executor/cached_thread_pool.rb', line 39

def initialize(opts = {})
  defaults  = { idletime: DEFAULT_THREAD_IDLETIMEOUT }
  overrides = { min_threads: 0,
                max_threads: DEFAULT_MAX_POOL_SIZE,
                max_queue:   DEFAULT_MAX_QUEUE_SIZE }
  super(defaults.merge(opts).merge(overrides))
end