class Concurrent::Synchronization::Condition

def wait_until(timeout = nil, &condition)
  @Lock.synchronize { ns_wait_until(timeout, &condition) }
end