Sha256: 52728e200bb9b83cabbd85e434cb944022c1fbe6fb09bfb2a7f5bee849cdd22b
Contents?: true
Size: 1.77 KB
Versions: 55
Compression:
Stored size: 1.77 KB
Contents
# encoding: utf-8
module LogStash
module Util
class ThreadDump
SKIPPED_THREADS = [ "Finalizer", "Reference Handler", "Signal Dispatcher" ].freeze
THREADS_COUNT_DEFAULT = 3.freeze
IGNORE_IDLE_THREADS_DEFAULT = true.freeze
attr_reader :top_count, :ignore, :dump
def initialize(options={})
@options = options
@dump = options.fetch(:dump, JRMonitor.threads.generate({}))
@top_count = options.fetch(:threads, THREADS_COUNT_DEFAULT)
@ignore = options.fetch(:ignore_idle_threads, IGNORE_IDLE_THREADS_DEFAULT)
end
def each(&block)
i=0
dump.each_pair do |thread_name, _hash|
break if i >= top_count
if ignore
next if idle_thread?(thread_name, _hash)
end
block.call(thread_name, _hash)
i += 1
end
end
def idle_thread?(thread_name, data)
idle = false
if SKIPPED_THREADS.include?(thread_name)
# these are likely JVM dependent
idle = true
elsif thread_name.match(/Ruby-\d+-JIT-\d+/)
# This are internal JRuby JIT threads,
# see java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor for details.
idle = true
elsif thread_name.match(/pool-\d+-thread-\d+/)
# This are threads used by the internal JRuby implementation to dispatch
# calls and tasks, see prg.jruby.internal.runtime.methods.DynamicMethod.call
idle = true
else
data["thread.stacktrace"].each do |trace|
if trace.start_with?("java.util.concurrent.ThreadPoolExecutor.getTask")
idle = true
break
end
end
end
idle
end
end
end
end
Version data entries
55 entries across 54 versions & 11 rubygems