Module: Rlyeh::Worker

Included in:

Connection

Defined in:

lib/rlyeh/worker.rb

Defined Under Namespace

Modules: ClassMethods Classes: ThreadPool

Class Method Summary

• .included(base) ⇒ Object
• .setup(options = {}) ⇒ Object
• .worker_pool ⇒ Object

Instance Method Summary

• #invoke(*args, &block) ⇒ Object

Class Method Details

.included(base) ⇒ Object

# File 'lib/rlyeh/worker.rb', line 14

def included(base)
  base.extend ClassMethods
end

.setup(options = {}) ⇒ Object

# File 'lib/rlyeh/worker.rb', line 18

def setup(options = {})
  @worker_pool = ThreadPool.pool options
end

.worker_pool ⇒ Object

# File 'lib/rlyeh/worker.rb', line 22

def worker_pool
  @worker_pool ||= setup
end

Instance Method Details

#invoke(*args, &block) ⇒ Object

# File 'lib/rlyeh/worker.rb', line 33

def invoke(*args, &block)
  self.class.worker_pool.invoke *args, &block
end