Method: Fluent::PluginHelper::Thread#thread_wait_until_start

Defined in:
lib/fluent/plugin_helper/thread.rb

#thread_wait_until_start ⇒ Object 



37
38
39
40
41
 
# File 'lib/fluent/plugin_helper/thread.rb', line 37

def thread_wait_until_start
  until @_threads_mutex.synchronize{ @_threads.values.reduce(true){|r,t| r && t[:_fluentd_plugin_helper_thread_started] } }
    sleep 0.1
  end
end