Class: Asynchronic::QueueEngine::InMemory::Queue

Inherits:

Object

• Object
• Asynchronic::QueueEngine::InMemory::Queue

Extended by:

Forwardable

Defined in:

lib/asynchronic/queue_engine/in_memory.rb

Instance Method Summary

• #initialize ⇒ Queue constructor

  A new instance of Queue.

• #pop ⇒ Object
• #push(message) ⇒ Object

Constructor Details

#initialize ⇒ Queue

Returns a new instance of Queue.

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 42

def initialize
  @queue = []
  @mutex = Mutex.new
end

Instance Method Details

#pop ⇒ Object

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 47

def pop
  @mutex.synchronize { @queue.shift }
end

#push(message) ⇒ Object

# File 'lib/asynchronic/queue_engine/in_memory.rb', line 51

def push(message)
  @mutex.synchronize { @queue.push message }
end