Class: SuckerPunch::Counter::Processed

Inherits:
Object
  • Object
show all
Includes:
Utilities
Defined in:
lib/sucker_punch/counter.rb

Constant Summary collapse

COUNTER =
Concurrent::Map.new do |hash, name|
  hash.compute_if_absent(name) { Concurrent::AtomicFixnum.new }
end

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Utilities

#decrement, #increment, #value

Constructor Details

#initialize(queue_name) ⇒ Processed

Returns a new instance of Processed.


48
49
50
# File 'lib/sucker_punch/counter.rb', line 48

def initialize(queue_name)
  @counter = COUNTER[queue_name]
end

Instance Attribute Details

#counterObject (readonly)

Returns the value of attribute counter


36
37
38
# File 'lib/sucker_punch/counter.rb', line 36

def counter
  @counter
end

Class Method Details

.clearObject


44
45
46
# File 'lib/sucker_punch/counter.rb', line 44

def self.clear
  COUNTER.clear
end