Contents

class StatsThread
  PERIOD = 60
  
  def initialize
    @processed = 0
    @running = true
    Thread.new do
      while @running
        sleep(PERIOD)
        puts "Processed #{@processed} tasks"
        @processed = 0
      end
    end
  end
  
  def stop
    @running = false
  end
  
  def kill
    @thread.kill
  end
  
  def processed_task
    @processed += 1
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
yodel-0.0.7	lib/yodel/task_queue/stats_thread.rb
yodel-0.0.4	lib/yodel/task_queue/stats_thread.rb
yodel-0.0.3	lib/yodel/task_queue/stats_thread.rb
yodel-0.0.2	lib/yodel/task_queue/stats_thread.rb
yodel-0.0.1	lib/yodel/task_queue/stats_thread.rb