class AvalancheMQ::VHost::SPUnsortedReadyQueue

Defined in:

avalanchemq/vhost/spqueue.cr

Constructors

Instance Method Summary

Instance methods inherited from class AvalancheMQ::VHost::SPQueue

<=>(other : self) <=>, empty? : Bool empty?, lock : Nil lock, peek : SegmentPosition peek, shift : SegmentPosition shift, unlock : Nil unlock

Constructor methods inherited from class AvalancheMQ::VHost::SPQueue

new(ready : Queue::SortedReadyQueue)
new(ready : Queue::ReadyQueue)
new(unack : Queue::UnackQueue) new

Constructor Detail

def self.new(ready : Queue::SortedReadyQueue) #

FIXME This could be a performance issue on long queues that is using Delayed messages or Priority We need to sort the ready queue by SP for the GC as a SortedReadyQueue could be sorted on any attribute on a SP


[View source]

Instance Method Detail

def empty? : Bool #

[View source]
def lock : Nil #

[View source]
def peek : SegmentPosition #

[View source]
def shift : SegmentPosition #

[View source]
def unlock : Nil #

[View source]