Method: Roma::AsyncProcess#start_async_process

Defined in:
lib/roma/async_process.rb

#start_async_process ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/roma/async_process.rb', line 45

def start_async_process
  @async_thread = Thread.new do
    async_process_loop
  end
  @async_thread[:name] = __method__

  @async_thread_latency = Thread.new do
    async_process_loop_for_latency
  end
  @async_thread_latency[:name] = __method__
rescue => e
  @log.error("#{e}\n#{$ERROR_POSITION}")
end