Class: TaskTempest::Producer
Constant Summary collapse
- DEFAULTS =
{ :delay => 1, :buffer_size => 1 }
Instance Attribute Summary collapse
-
#logger ⇒ Object
readonly
Returns the value of attribute logger.
Instance Method Summary collapse
- #consume ⇒ Object
-
#initialize(queue, logger, options = {}) ⇒ Producer
constructor
A new instance of Producer.
Constructor Details
#initialize(queue, logger, options = {}) ⇒ Producer
Returns a new instance of Producer.
14 15 16 17 18 19 20 21 |
# File 'lib/task_tempest/producer.rb', line 14 def initialize(queue, logger, = {}) = DEFAULTS.merge() @queue = queue @logger = logger @delay = [:delay] @buffer = SizedQueue.new([:buffer_size]) Thread.new{ run } end |
Instance Attribute Details
#logger ⇒ Object (readonly)
Returns the value of attribute logger.
7 8 9 |
# File 'lib/task_tempest/producer.rb', line 7 def logger @logger end |
Instance Method Details
#consume ⇒ Object
23 24 25 26 27 28 29 |
# File 'lib/task_tempest/producer.rb', line 23 def consume if @buffer.size > 0 @buffer.pop else nil end end |