In: |
monitor.rb
|
Parent: | Object |
FIXME: This isn’t documented in Nutshell.
Since MonitorMixin.new_cond returns a ConditionVariable, and the example above calls while_wait and signal, this class should be documented.
# File monitor.rb, line 136 def broadcast @monitor.__send__(:mon_check_owner) Thread.critical = true for t in @waiters t.wakeup end @waiters.clear Thread.critical = false Thread.pass end
# File monitor.rb, line 127 def signal @monitor.__send__(:mon_check_owner) Thread.critical = true t = @waiters.shift t.wakeup if t Thread.critical = false Thread.pass end
# File monitor.rb, line 89 def wait(timeout = nil) @monitor.__send__(:mon_check_owner) timer = create_timer(timeout) Thread.critical = true count = @monitor.__send__(:mon_exit_for_cond) @waiters.push(Thread.current) begin Thread.stop return true rescue Timeout return false ensure Thread.critical = true if timer && timer.alive? Thread.kill(timer) end if @waiters.include?(Thread.current) # interrupted? @waiters.delete(Thread.current) end @monitor.__send__(:mon_enter_for_cond, count) Thread.critical = false end end