class Async::PriorityQueue

def initialize(parent: nil)

@parameter parent [Interface(:async) | Nil] The parent task to use for async operations.

Create a new priority queue.

def initialize(parent: nil)
	@items = []
	@closed = false
	@parent = parent
	@waiting = IO::Event::PriorityHeap.new
	@sequence = 0
	
	@mutex = Mutex.new
end

Instance Methods