require 'coxswain'
require 'open-uri'
 
pool = Coxswain.pool(10) do |url|
  open(url){|socket| socket.read}
end
 
url = 'http://codeforpeople.com'
n = 20
 
# Here the master dispatches work to the pool of workers
n.times { pool.dispatch(url) }
 
 
##########################################################
 
# another example to dispatch jobs could look like:
 
loop do
   job = Job.fetch #blocks and waits for a new job
   pool.dispatch(job)
end
# this example isn't good because it will make the master block
# and not be able to do anything else, so either you can use
# the example below which doesn't block the main thread,
# or we need a helper method that makes a job loop in a thread
# listening for jobs... or maybe someone has a better idea?
 
 
# or with EM
 
EM.run {
   @queue = EMJack::Connection.new
 
   @queue.each_job do |job|
       ret = pool.dispatch(job)
       @queue.delete(job) if ret
   end
}