Class: Fairy::SizedQueue

Inherits:

Object

• Object
• Fairy::SizedQueue

Extended by:

Forwardable

Defined in:

lib/fairy/share/port.rb

Instance Method Summary

• #initialize(policy, queues_mon = nil, queues_cv = nil) ⇒ SizedQueue constructor

  A new instance of SizedQueue.

Constructor Details

#initialize(policy, queues_mon = nil, queues_cv = nil) ⇒ SizedQueue

Returns a new instance of SizedQueue.

# File 'lib/fairy/share/port.rb', line 957

def initialize(policy, queues_mon = nil, queues_cv = nil)
  if queues_mon
	raise "OnMemoryQueueはfiberをサポートしていません"
  end

  size = policy[:size]
  size ||= CONF.ONMEMORY_SIZEDQUEUE_SIZE
  @queue = XThread::SizedQueue.new(size)
end