Module: Birdwatcher::Concerns::Concurrency

Included in:

Birdwatcher::Command, Module

Defined in:

lib/birdwatcher/concerns/concurrency.rb

Defined Under Namespace

Modules: ClassMethods

Constant Summary

DEFAULT_THREAD_POOL_SIZE =

The default size of thread pool

10.freeze

Class Method Summary

• .included(base) ⇒ Object

Instance Method Summary

• #thread_pool(size = nil) ⇒ Thread::Pool

  Create a new thread pool.

Class Method Details

.included(base) ⇒ Object

# File 'lib/birdwatcher/concerns/concurrency.rb', line 8

def self.included(base)
  base.extend(ClassMethods)
end

Instance Method Details

#thread_pool(size = nil) ⇒ Thread::Pool

Create a new thread pool

See Also:

• https://github.com/meh/ruby-thread#pool

# File 'lib/birdwatcher/concerns/concurrency.rb', line 20

def thread_pool(size = nil)
  Thread.pool(size || DEFAULT_THREAD_POOL_SIZE)
end