Method: Fluent::Plugin::Output#synchronize_in_threads

Defined in:
lib/fluent/plugin/output.rb

#synchronize_in_threads ⇒ Object 



630
631
632
633
634
635
636
637
 
# File 'lib/fluent/plugin/output.rb', line 630

def synchronize_in_threads
  need_thread_lock = actual_flush_thread_count > 1
  if need_thread_lock
    @flush_thread_mutex.synchronize { yield }
  else
    yield
  end
end