Method: FreeMessageQueue::SyncronizedQueue#initialize
- Defined in:
- lib/fmq/queues/syncronized.rb
#initialize(manager) ⇒ SyncronizedQueue
Returns a new instance of SyncronizedQueue.
34 35 36 37 |
# File 'lib/fmq/queues/syncronized.rb', line 34 def initialize(manager) super(manager) @semaphore = Mutex.new end |