Typhoeus

# File lib/typhoeus.rb, line 45
def self.add_easy_request(easy_object)
  Thread.current[:curl_multi] ||= Typhoeus::Multi.new
  Thread.current[:curl_multi].add(easy_object)
end

# File lib/typhoeus.rb, line 22
def self.easy_object_pool
  @easy_objects ||= []
end

# File lib/typhoeus.rb, line 37
def self.get_easy_object
  if easy_object_pool.empty?
    Typhoeus::Easy.new
  else
    easy_object_pool.pop
  end
end

# File lib/typhoeus/remote.rb, line 4
def self.included(base)
  base.extend ClassMethods
end

# File lib/typhoeus.rb, line 26
def self.init_easy_object_pool
  20.times do
    easy_object_pool << Typhoeus::Easy.new
  end
end

# File lib/typhoeus.rb, line 50
def self.perform_easy_requests
  multi = Thread.current[:curl_multi]
  start_time = Time.now
  multi.easy_handles.each do |easy|
    easy.start_time = start_time
  end
  multi.perform
end

# File lib/typhoeus.rb, line 32
def self.release_easy_object(easy)
  easy.reset
  easy_object_pool << easy
end