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) ⇒ 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) ⇒ LimitedQueue
Returns a new instance of LimitedQueue.
60 61 62 63 64 65 |
# File 'lib/async/queue.rb', line 60 def initialize(limit = 1) super() @limit = limit @full = Async::Queue.new end |
Instance Attribute Details
#limit ⇒ Object (readonly)
Returns the value of attribute limit.
67 68 69 |
# File 'lib/async/queue.rb', line 67 def limit @limit end |
Instance Method Details
#dequeue ⇒ Object
82 83 84 85 86 87 88 |
# File 'lib/async/queue.rb', line 82 def dequeue item = super @full.enqueue(nil) unless @full.empty? return item end |
#enqueue(item) ⇒ Object
74 75 76 77 78 79 80 |
# File 'lib/async/queue.rb', line 74 def enqueue item if limited? @full.dequeue end super end |
#limited? ⇒ Boolean
Returns Whether trying to enqueue an item would block.
70 71 72 |
# File 'lib/async/queue.rb', line 70 def limited? @items.size >= @limit end |