vemserver/workerThread.rb

   1 require 'singleton'
   2 require './channel'
   3
   4 class WorkerThread
   5
   6   def initialize(channel)
   7     @channel = channel
   8   end
   9
  10   def start
  11     puts "worker_thread start"
  12     Thread.new do
  13       while true do
  14         request = @channel.take_request
  15         request.execute
  16       end
  17     end
  18   end
  19
  20 end