Module: Rainbows::FiberSpawn

Includes:
Rainbows::Fiber::Base
Defined in:
lib/rainbows/fiber_spawn.rb

Overview

Simple Fiber-based concurrency model for 1.9. This spawns a new Fiber for every incoming client connection and the root Fiber for scheduling and connection acceptance.

This concurrency model is difficult to use with existing applications, lacks third-party support, and is thus NOT recommended.

This exports a streaming “rack.input” with lightweight concurrency. Applications are strongly advised to wrap all slow IO objects (sockets, pipes) using the Rainbows::Fiber::IO class whenever possible.

Instance Method Summary collapse

Instance Method Details

#worker_loop(worker) ⇒ Object

:nodoc:



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/rainbows/fiber_spawn.rb', line 18

def worker_loop(worker) # :nodoc:
  init_worker_process(worker)
  Rainbows::Fiber::Base.setup(self.class, app)
  limit = worker_connections

  begin
    schedule do |l|
      break if Rainbows.cur >= limit
      io = l.kgio_tryaccept or next
      Fiber.new { process(io) }.resume
    end
  rescue => e
    Rainbows::Error.listen_loop(e)
  end while Rainbows.cur_alive
end