Class: EM::Worker

Inherits:

Object

• Object
• EM::Worker

Defined in:

lib/em/worker.rb

Instance Method Summary

• #enqueue(task = nil, callback = nil, options = {}, &block) ⇒ Object
• #initialize(options = {}) ⇒ Worker constructor

  A new instance of Worker.

Constructor Details

#initialize(options = {}) ⇒ Worker

Returns a new instance of Worker.

# File 'lib/em/worker.rb', line 5

def initialize(options={})
  @task_queue = EM::Queue.new
  @concurrency = options.fetch(:concurrency, 10)
  start
end

Instance Method Details

#enqueue(task = nil, callback = nil, options = {}, &block) ⇒ Object

# File 'lib/em/worker.rb', line 11

def enqueue(task=nil, callback=nil, options={}, &block)
  task ||= block || Proc.new {}
  @task_queue.push([task, callback, options])
  true
end