Method: Contender::Pool::PoolExecutor#await_termination

Defined in:
lib/contender/pool/pool_executor.rb

#await_termination(timeout) ⇒ Boolean

Parameters:

  • timeout (Float)

Returns:

  • (Boolean) 


132
133
134
135
136
137
138
139
 
# File 'lib/contender/pool/pool_executor.rb', line 132

def await_termination(timeout)
  synchronize do
    return true if terminated?

    @termination.wait timeout
    terminated?
  end
end