Class: CI::Queue::Redis::Base::State
- Inherits:
-
Object
- Object
- CI::Queue::Redis::Base::State
- Defined in:
- lib/ci/queue/redis/base.rb
Instance Method Summary collapse
-
#initialize ⇒ State
constructor
A new instance of State.
- #set(*state) ⇒ Object
- #wait(timeout) ⇒ Object
Constructor Details
#initialize ⇒ State
Returns a new instance of State.
275 276 277 278 279 |
# File 'lib/ci/queue/redis/base.rb', line 275 def initialize @state = nil @mutex = Mutex.new @cond = ConditionVariable.new end |
Instance Method Details
#set(*state) ⇒ Object
281 282 283 284 285 286 |
# File 'lib/ci/queue/redis/base.rb', line 281 def set(*state) @state = state @mutex.synchronize do @cond.broadcast end end |
#wait(timeout) ⇒ Object
288 289 290 291 292 293 |
# File 'lib/ci/queue/redis/base.rb', line 288 def wait(timeout) @mutex.synchronize do @cond.wait(@mutex, timeout) end @state end |