Class: Sidekiq::Processor::Counter

Inherits:

Object

• Object
• Sidekiq::Processor::Counter

Defined in:

lib/sidekiq/processor.rb

Overview

Ruby doesn’t provide atomic counters out of the box so we’ll implement something simple ourselves. bugs.ruby-lang.org/issues/14706

Instance Method Summary

• #incr(amount = 1) ⇒ Object
• #initialize ⇒ Counter constructor

  A new instance of Counter.

• #reset ⇒ Object

Constructor Details

#initialize ⇒ Counter

Returns a new instance of Counter.

# File 'lib/sidekiq/processor.rb', line 199

def initialize
  @value = 0
  @lock = Mutex.new
end

Instance Method Details

#incr(amount = 1) ⇒ Object

# File 'lib/sidekiq/processor.rb', line 204

def incr(amount=1)
  @lock.synchronize { @value = @value + amount }
end

#reset ⇒ Object

# File 'lib/sidekiq/processor.rb', line 208

def reset
  @lock.synchronize { val = @value; @value = 0; val }
end