jacobo · May 17, 2013 17:24
diff --git a/gistfile1.rb b/gistfile1.rb
    require 'celluloid'
    class Worker
      include Celluloid
      def work(x)
        sleep 0.2; puts x*x
      end
    end
    worker_pool = Worker.pool(size: 10)
    (0..99).to_a.each{|x| worker_pool.async.work x }
    sleep 2 #how do I wait the right amount of time before terminating?
    worker_pool.terminate
	require 'celluloid'
	class Worker
	include Celluloid
	def work(x)
	sleep 0.2; puts x*x
	end
	end
	worker_pool = Worker.pool(size: 10)
	(0..99).to_a.each{\|x\| worker_pool.async.work x }
	sleep 2 #how do I wait the right amount of time before terminating?
	worker_pool.terminate
No results found