Method: ConcurrentWorker::WorkerPool#set_recv_thread

Defined in:
lib/concurrent_worker/workerpool.rb

#set_recv_thread ⇒ Object 



54
55
56
57
58
59
60
61
62
63
 
# File 'lib/concurrent_worker/workerpool.rb', line 54

def set_recv_thread
  Thread.new do
    while result = @recv_queue.pop
      @result_callbacks.each do |callback|
        callback.call(*result[0])
      end
      @req_counter.pop
    end
  end
end