Class: WEEL::Continue
Overview
}}}
Instance Method Summary collapse
- #clear ⇒ Object
- #continue(*args) ⇒ Object
-
#initialize ⇒ Continue
constructor
{{{.
- #wait ⇒ Object
- #waiting? ⇒ Boolean
Constructor Details
#initialize ⇒ Continue
{{{
274 275 276 277 |
# File 'lib/weel.rb', line 274 def initialize @q = Queue.new @m = Mutex.new end |
Instance Method Details
#clear ⇒ Object
286 287 288 |
# File 'lib/weel.rb', line 286 def clear @q.clear end |
#continue(*args) ⇒ Object
283 284 285 |
# File 'lib/weel.rb', line 283 def continue(*args) @q.push(args.length <= 1 ? args[0] : args) end |
#wait ⇒ Object
289 290 291 |
# File 'lib/weel.rb', line 289 def wait @q.deq end |
#waiting? ⇒ Boolean
278 279 280 281 282 |
# File 'lib/weel.rb', line 278 def waiting? @m.synchronize do !@q.empty? end end |