Method: Asynchronic::QueueEngine::InMemory#initialize

Defined in:
lib/asynchronic/queue_engine/in_memory.rb

#initialize(options = {}) ⇒ InMemory

Returns a new instance of InMemory.



5
6
7
8
 
# File 'lib/asynchronic/queue_engine/in_memory.rb', line 5

def initialize(options={})
  @options = options
  @queues ||= Hash.new { |h,k| h[k] = Queue.new }
end