Method: ConcurrentWorker::WorkerPool#join

Defined in:
lib/concurrent_worker/workerpool.rb

#join ⇒ Object 



155
156
157
158
159
160
161
162
 
# File 'lib/concurrent_worker/workerpool.rb', line 155

def join
  @req_counter.wait_until_less_than(1)
  self.shift.join until self.empty?
  @recv_queue.push(nil)
  @recv_thread.join
  @snd_queue.push(nil)
  @snd_thread.join
end