Method: Fluent::PluginHelper::Thread#close

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

#close ⇒ Object 



153
154
155
156
157
158
159
160
161
162
 
# File 'lib/fluent/plugin_helper/thread.rb', line 153

def close
  @_threads_mutex.synchronize{ @_threads.keys }.each do |obj_id|
    thread = @_threads[obj_id]
    if !thread || thread.join(@_thread_wait_seconds)
      @_threads_mutex.synchronize{ @_threads.delete(obj_id) }
    end
  end

  super
end