Class: Moneta::Semaphore

Inherits:

SynchronizePrimitive

• Object
• SynchronizePrimitive
• Moneta::Semaphore

Defined in:

lib/moneta/synchronize.rb

Overview

Distributed/shared store-wide semaphore

Examples:

Use ‘Moneta::Semaphore`

semaphore = Moneta::Semaphore.new(store, 'semaphore', 2)
semaphore.synchronize do
  # Synchronized access
  # ...
end

Instance Method Summary

• #initialize(store, counter, max = 1) ⇒ Semaphore constructor

  A new instance of Semaphore.

Methods inherited from SynchronizePrimitive

#enter, #leave, #locked?, #synchronize, #try_enter

Constructor Details

#initialize(store, counter, max = 1) ⇒ Semaphore

Returns a new instance of Semaphore.

Parameters:

• store (Moneta store) —

  The store we want to lock

• counter (Object) —

  Key of the counter entry

• max (Integer) (defaults to: 1) —

  Maximum number of threads which are allowed to enter the critical section

# File 'lib/moneta/synchronize.rb', line 99

def initialize(store, counter, max = 1)
  raise 'Store must support feature :increment' unless store.supports?(:increment)
  @store, @counter, @max = store, counter, max
  @store.increment(@counter, 0, expires: false) # Ensure that counter exists
end