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
Methods inherited from Queue
#<<, #async, #each, #empty?, #size
Methods inherited from Notification
Methods inherited from Condition
Constructor Details
#initialize(limit = 1, **options) ⇒ LimitedQueue
Returns a new instance of LimitedQueue.
79 80 81 82 83 84 85 |
# File 'lib/async/queue.rb', line 79 def initialize(limit = 1, **) super(**) @limit = limit @full = Notification.new end |
Instance Attribute Details
#limit ⇒ Object (readonly)
Returns the value of attribute limit.
87 88 89 |
# File 'lib/async/queue.rb', line 87 def limit @limit end |
Instance Method Details
#dequeue ⇒ Object
102 103 104 105 106 107 108 |
# File 'lib/async/queue.rb', line 102 def dequeue item = super @full.signal return item end |
#enqueue(item) ⇒ Object
94 95 96 97 98 99 100 |
# File 'lib/async/queue.rb', line 94 def enqueue item while limited? @full.wait end super end |
#limited? ⇒ Boolean
90 91 92 |
# File 'lib/async/queue.rb', line 90 def limited? @items.size >= @limit end |