Class: PgPipeline::Runtime::Queue

Inherits:

Object

• Object
• PgPipeline::Runtime::Queue

Defined in:

lib/pg_pipeline/runtime/queue.rb

Instance Method Summary

• #close ⇒ Object
• #closed? ⇒ Boolean
• #dequeue ⇒ Object
• #empty? ⇒ Boolean
• #enqueue(item) ⇒ Object
• #initialize ⇒ Queue constructor

  A new instance of Queue.

• #size ⇒ Object

Constructor Details

#initialize ⇒ Queue

Returns a new instance of Queue.

# File 'lib/pg_pipeline/runtime/queue.rb', line 6

def initialize
  @queue = ::Thread::Queue.new
end

Instance Method Details

#close ⇒ Object

# File 'lib/pg_pipeline/runtime/queue.rb', line 21

def close
  @queue.close
  nil
end

#closed? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/pg_pipeline/runtime/queue.rb', line 26

def closed? = @queue.closed?

#dequeue ⇒ Object

# File 'lib/pg_pipeline/runtime/queue.rb', line 17

def dequeue
  @queue.pop
end

#empty? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/pg_pipeline/runtime/queue.rb', line 27

def empty? = @queue.empty?

#enqueue(item) ⇒ Object

# File 'lib/pg_pipeline/runtime/queue.rb', line 10

def enqueue(item)
  @queue.push(item)
  item
rescue ClosedQueueError
  nil
end

#size ⇒ Object

# File 'lib/pg_pipeline/runtime/queue.rb', line 28

def size = @queue.size