lib/rainbows/xepoll_thread_pool.rb

   1 # -*- encoding: binary -*-
   2 require "thread"
   3 require "sleepy_penguin"
   4 require "raindrops"
   5
   6 module Rainbows::XEpollThreadPool
   7   include Rainbows::Base
   8   extend Rainbows::PoolSize
   9
  10   def init_worker_process(worker)
  11     super
  12     require "rainbows/xepoll_thread_pool/client"
  13     Rainbows::Client.__send__ :include, Client
  14   end
  15
  16   def worker_loop(worker) # :nodoc:
  17     init_worker_process(worker)
  18     Client.loop
  19   end
  20 end
  21