Class: Async::LimitedQueue
- Inherits:
-
Queue
- Object
- Condition
- Notification
- Queue
- Async::LimitedQueue
- Defined in:
- lib/async/queue.rb
Instance Attribute Summary collapse
-
#limit ⇒ Object
readonly
Returns the value of attribute limit.
Attributes inherited from Queue
Instance Method Summary collapse
- #dequeue ⇒ Object
- #enqueue(item) ⇒ Object
-
#initialize(limit = 1, **options) ⇒ LimitedQueue
constructor
A new instance of LimitedQueue.
-
#limited? ⇒ Boolean
Whether trying to enqueue an item would block.
Methods inherited from Queue
Methods inherited from Notification
Methods inherited from Condition
Constructor Details
#initialize(limit = 1, **options) ⇒ LimitedQueue
Returns a new instance of LimitedQueue.
75 76 77 78 79 80 81 |
# File 'lib/async/queue.rb', line 75 def initialize(limit = 1, **) super(**) @limit = limit @full = Notification.new end |
Instance Attribute Details
#limit ⇒ Object (readonly)
Returns the value of attribute limit.
83 84 85 |
# File 'lib/async/queue.rb', line 83 def limit @limit end |
Instance Method Details
#dequeue ⇒ Object
98 99 100 101 102 103 104 |
# File 'lib/async/queue.rb', line 98 def dequeue item = super @full.signal return item end |
#enqueue(item) ⇒ Object
90 91 92 93 94 95 96 |
# File 'lib/async/queue.rb', line 90 def enqueue item while limited? @full.wait end super end |
#limited? ⇒ Boolean
Returns Whether trying to enqueue an item would block.
86 87 88 |
# File 'lib/async/queue.rb', line 86 def limited? @items.size >= @limit end |