Contents

# frozen_string_literal: true

module Jaeger
  # Executes a given block periodically. The block will be executed only once
  # when interval is set to 0.
  class RecurringExecutor
    def initialize(interval:)
      @interval = interval
    end

    def start(&block)
      raise 'Already running' if @thread

      @thread = Thread.new do
        if @interval <= 0
          yield
        else
          loop do
            yield
            sleep @interval
          end
        end
      end
    end

    def running?
      @thread&.alive?
    end

    def stop
      @thread.kill
      @thread = nil
    end
  end
end

Version data entries

4 entries across 4 versions & 3 rubygems

Version	Path
dox-jaeger-client-2.0.0	lib/jaeger/recurring_executor.rb
jaeger-client-with-ruby-32-support-2.0.0	lib/jaeger/recurring_executor.rb
jaeger-client-1.3.0	lib/jaeger/recurring_executor.rb
jaeger-client-1.2.0	lib/jaeger/recurring_executor.rb