Method: Thread::Pool#wait_done

Defined in:
lib/thread/pool.rb

#wait_done ⇒ Object

Wait until all tasks are consumed. The caller will be blocked until then.



197
198
199
200
201
202
 
# File 'lib/thread/pool.rb', line 197

def wait_done
  @done_mutex.synchronize {
    return if done?
    @done.wait @done_mutex
  }
end