Contents

# frozen_string_literal: true

class Async::App::Metrics::RubyRuntimeMonitor
  include Async::Logger

  INTERVAL = 2

  def run
    Async::Timer.new(INTERVAL, run_on_start: true, on_error: ->(e) { warn(e) }) do
      fibers = ObjectSpace.each_object(Fiber)
      threads = ObjectSpace.each_object(Thread)
      ractors = ObjectSpace.each_object(Ractor)

      yield({
        ruby_fibers: { value: fibers.count },
        ruby_fibers_active: { value: fibers.count(&:alive?) },
        ruby_threads: { value: threads.count },
        ruby_threads_active: { value: threads.count(&:alive?) },
        ruby_ractors: { value: ractors.count },
        ruby_memory: { value: GetProcessMem.new.bytes.to_s("F"), suffix: "bytes" }
      })
    end
    info { "Started" }
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
async-tools-0.2.7	lib/async/app/metrics/ruby_runtime_monitor.rb
async-tools-0.2.6	lib/async/app/metrics/ruby_runtime_monitor.rb
async-tools-0.2.5	lib/async/app/metrics/ruby_runtime_monitor.rb
async-tools-0.2.4	lib/async/app/metrics/ruby_runtime_monitor.rb
async-tools-0.2.2	lib/async/app/metrics/ruby_runtime_monitor.rb