class Concurrent::RubyExecutorService

def wait_for_termination(timeout = nil)

def wait_for_termination(timeout = nil)
  stopped_event.wait(timeout)
end