Class: Pwrake::FiberQueue
- Inherits:
-
Object
- Object
- Pwrake::FiberQueue
- Defined in:
- lib/pwrake/branch/fiber_queue.rb
Instance Method Summary collapse
- #deq ⇒ Object
- #deq_nonblock ⇒ Object
- #enq(x) ⇒ Object
- #finish ⇒ Object
-
#initialize ⇒ FiberQueue
constructor
A new instance of FiberQueue.
Constructor Details
#initialize ⇒ FiberQueue
Returns a new instance of FiberQueue.
10 11 12 13 14 |
# File 'lib/pwrake/branch/fiber_queue.rb', line 10 def initialize @q = [] @waiter = [] @finished = false end |
Instance Method Details
#deq ⇒ Object
25 26 27 28 29 30 31 32 |
# File 'lib/pwrake/branch/fiber_queue.rb', line 25 def deq while @q.empty? return nil if @finished @waiter.push(Fiber.current) Fiber.yield end return @q.shift end |
#deq_nonblock ⇒ Object
34 35 36 |
# File 'lib/pwrake/branch/fiber_queue.rb', line 34 def deq_nonblock @q.shift end |
#enq(x) ⇒ Object
16 17 18 19 20 21 22 23 |
# File 'lib/pwrake/branch/fiber_queue.rb', line 16 def enq(x) if @finished raise FiberQueueError,"cannot enq to already finished queue" end @q.push(x) f = @waiter.shift f.resume if f end |
#finish ⇒ Object
38 39 40 41 42 43 |
# File 'lib/pwrake/branch/fiber_queue.rb', line 38 def finish @finished = true while f = @waiter.shift f.resume end end |