Class: SuckerPunch::Counter::Processed

Inherits:

Object

• Object
• SuckerPunch::Counter::Processed

Includes:

Utilities

Defined in:

lib/sucker_punch/counter.rb

Constant Summary

COUNTER =

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

Instance Attribute Summary

• #counter ⇒ Object readonly

  Returns the value of attribute counter.

Class Method Summary

• .clear ⇒ Object

Instance Method Summary

• #initialize(queue_name) ⇒ Processed constructor

  A new instance of Processed.

Methods included from Utilities

#decrement, #increment, #value

Constructor Details

#initialize(queue_name) ⇒ Processed

Returns a new instance of Processed.

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

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

Instance Attribute Details

#counter ⇒ Object (readonly)

Returns the value of attribute counter.

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

def counter
  @counter
end

Class Method Details

.clear ⇒ Object

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

def self.clear
  COUNTER.clear
end