Method: ConcurrentWorker::ConcurrentProcess#set_rcv_thread

Defined in:

lib/concurrent_worker.rb

#set_rcv_thread ⇒ Object

# File 'lib/concurrent_worker.rb', line 302

def set_rcv_thread
  Thread.new do
    Thread.handle_interrupt(Object => :never) do
      begin
        Thread.handle_interrupt(Object => :immediate) do
          loop do
            result = @ipc_channel.recv
            break if result == :worker_loop_finished
            raise result if result.kind_of?(Exception)

            call_result_callbacks(result)
          end
        end
      rescue
        Thread.pass
        raise $!
      ensure
        @req_counter.close
        @ipc_channel.close
        call_retired_callbacks
      end
    end
  end
end