Class: UnifiedQueues::Single::Driver::DepqDriver

Inherits:
UnifiedQueues::Single::Driver show all
Defined in:
lib/unified-queues/single/driver/depq.rb

Overview

Implicit heap queue driver. Uses the Depq class from depq gem for queueing. Priority is supported.

Instance Attribute Summary

Attributes inherited from UnifiedQueues::Single::Driver

#native

Instance Method Summary collapse

Methods inherited from UnifiedQueues::Single::Driver

#evented?, #initialize, #linear?

Constructor Details

This class inherits a constructor from UnifiedQueues::Single::Driver

Instance Method Details

#clear! ⇒ Object

Clears the queue.



68
69
70
 
# File 'lib/unified-queues/single/driver/depq.rb', line 68

def clear!
    @native.clear
end

#empty? ⇒ Boolean

Indicates queue is empty.

Parameters:

  • +true+ (Boolean) —

    if it’s, false otherwise

Returns:

  • (Boolean) 


60
61
62
 
# File 'lib/unified-queues/single/driver/depq.rb', line 60

def empty?
    @native.empty?
end

#length ⇒ Integer

Returns length of the queue.

Returns:

  • (Integer) 


77
78
79
 
# File 'lib/unified-queues/single/driver/depq.rb', line 77

def length
    @native.size
end

#pop(blocking = false) ⇒ Object

Pops value out of the queue. Note, value with minimal priority will be popped out. Blocking isn’ŧ supported.

Parameters:

  • blocking (Boolean|Integer) (defaults to: false) —

    true or timeout if it should block, false otherwise

Returns:

  • (Object) —

    queued value



51
52
53
 
# File 'lib/unified-queues/single/driver/depq.rb', line 51

def pop(blocking = false)
    @native.delete_min
end

#push(value, key = value) ⇒ Object

Pushes the value into the queue. Priority is supported.

Parameters:

  • value (Object) —

    value for push

  • key (Object) (defaults to: value) —

    key for priority queues



39
40
41
 
# File 'lib/unified-queues/single/driver/depq.rb', line 39

def push(value, key = value)
    @native.insert(value, key)
end

#type ⇒ :linear

Returs type of the queue.

Returns:

  • (:linear) 


86
87
88
 
# File 'lib/unified-queues/single/driver/depq.rb', line 86

def type
    :linear
end