Class: Yunhe::Consumer

Inherits:

Thread

• Object
• Thread
• Yunhe::Consumer

Defined in:

lib/yunhe/consumer.rb

Instance Attribute Summary

• #block ⇒ Object

  Returns the value of attribute block.

• #queue ⇒ Object

  Returns the value of attribute queue.

Instance Method Summary

• #initialize(queue, block) ⇒ Consumer constructor

  Initialize a new consumer queue: the reference of the buffer queue block: the task to process the resource.

Constructor Details

#initialize(queue, block) ⇒ Consumer

Initialize a new consumer queue: the reference of the buffer queue block: the task to process the resource

# File 'lib/yunhe/consumer.rb', line 10

def initialize(queue, block)
  super &(method(:job).to_proc)
  @block = block
  self.queue = queue
end

Instance Attribute Details

#block ⇒ Object

Returns the value of attribute block.

# File 'lib/yunhe/consumer.rb', line 4

def block
  @block
end

#queue ⇒ Object

Returns the value of attribute queue.

# File 'lib/yunhe/consumer.rb', line 3

def queue
  @queue
end