Method: Fluent::PluginHelper::Thread#after_shutdown

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

#after_shutdown ⇒ Object 



140
141
142
143
144
145
146
147
148
149
150
151
 
# File 'lib/fluent/plugin_helper/thread.rb', line 140

def after_shutdown
  super
  wakeup_threads = []
  @_threads_mutex.synchronize do
    @_threads.each_value do |thread|
      wakeup_threads << thread if thread.alive? && thread.status == "sleep"
    end
  end
  wakeup_threads.each do |thread|
    thread.wakeup if thread.alive?
  end
end