Class: CI::Queue::Redis::Base::State

Inherits:
Object
  • Object
show all
Defined in:
lib/ci/queue/redis/base.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ State

Returns a new instance of State.



299
300
301
302
303
 
# File 'lib/ci/queue/redis/base.rb', line 299

def initialize
  @state = nil
  @mutex = Mutex.new
  @cond = ConditionVariable.new
end

Instance Method Details

#set(*state) ⇒ Object 



305
306
307
308
309
310
 
# File 'lib/ci/queue/redis/base.rb', line 305

def set(*state)
  @state = state
  @mutex.synchronize do
    @cond.broadcast
  end
end

#wait(timeout) ⇒ Object 



312
313
314
315
316
317
 
# File 'lib/ci/queue/redis/base.rb', line 312

def wait(timeout)
  @mutex.synchronize do
    @cond.wait(@mutex, timeout)
  end
  @state
end