module ConcurrentWorker::ConcurrentThread

Public Instance Methods

channel_close() click to toggle source
# File lib/concurrent_worker/worker.rb, line 226
def channel_close
  @thread_channel.close
end
cncr_block() click to toggle source
# File lib/concurrent_worker/worker.rb, line 207
def cncr_block
  @thread_channel = Queue.new
  @thread = result_handle_thread do
    yield_base_block
  end
end
receive_req() click to toggle source
# File lib/concurrent_worker/worker.rb, line 218
def receive_req
  @thread_channel.pop
end
send_req(args) click to toggle source
# File lib/concurrent_worker/worker.rb, line 214
def send_req(args)
  @thread_channel.push(args)
end
send_res(args) click to toggle source
# File lib/concurrent_worker/worker.rb, line 222
def send_res(args)
  call_result_callbacks(args)
end
wait_cncr_proc() click to toggle source
# File lib/concurrent_worker/worker.rb, line 230
def wait_cncr_proc
  @thread && @thread.join
end