class Async::Queue

@public Since ‘stable-v1`.
A queue which allows items to be processed in order.

def <<(item)
	@items << item
	
	self.signal unless self.empty?
end

def async(parent: (@parent or Task.current), &block)
	while item = self.dequeue
		parent.async(item, &block)
	end
end

def dequeue
	while @items.empty?
		self.wait
	end
	
	@items.shift
end

def each
	while item = self.dequeue
		yield item
	end
end

def empty?
	@items.empty?
end

def enqueue(*items)
	@items.concat(items)
	
	self.signal unless self.empty?
end

def initialize(parent: nil)
	super()
	
	@items = []
	@parent = parent
end

def size
	@items.size
end

Modules