Playing around with EM

threadpool.rb

require 'rubygems'
require 'bundler/setup'
require 'eventmachine'
require 'httparty'

# Serial Processing:
# results = %[realtime forker].collect do |path|
#   HTTParty.get "http://github.com/api/v2/json/repos/show/#{path}"
# end
# 
# p results.map { |r| r['repository']['name'] }

# Parallel Processing:

results = []
EM.run do
  add_result = lambda { |result| results.push(result) }

  repo_paths.each do |path|
    EM.defer( lambda { "http://github.com/api/v2/json/repos/show/#{path}" }, add_result )
  end

  EM.add_periodic_timer(0.1) do
    EM.stop if results.size == repo_paths.size
  end
end

p results