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 collapse
- #incr(amount = 1) ⇒ Object
-
#initialize ⇒ Counter
constructor
A new instance of Counter.
- #reset ⇒ Object
Constructor Details
#initialize ⇒ Counter
Returns a new instance of Counter.
199 200 201 202 |
# File 'lib/sidekiq/processor.rb', line 199 def initialize @value = 0 @lock = Mutex.new end |
Instance Method Details
#incr(amount = 1) ⇒ Object
204 205 206 |
# File 'lib/sidekiq/processor.rb', line 204 def incr(amount=1) @lock.synchronize { @value = @value + amount } end |
#reset ⇒ Object
208 209 210 |
# File 'lib/sidekiq/processor.rb', line 208 def reset @lock.synchronize { val = @value; @value = 0; val } end |