Method: Actuator::ConditionVariable#wait

Defined in:
lib/actuator/mutex.rb

#wait(mutex, timeout = nil) ⇒ Object



81
82
83
84
85
86
87
88
89
# File 'lib/actuator/mutex.rb', line 81

def wait(mutex, timeout=nil)
  job = Job.current
  waiter = [mutex, job]
  @waiters << waiter
  mutex.sleep timeout
  self
ensure
  @waiters.delete waiter
end