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