lib/email_crawler.rb in email_crawler-0.0.7 vs lib/email_crawler.rb in email_crawler-0.0.8
- old
+ new
@@ -10,11 +10,11 @@
require_relative "email_crawler/page_links"
require_relative "email_crawler/email_scanner"
module EmailCrawler
class Runner
- MAX_CONCURRENCY = 10
+ MAX_CONCURRENCY = 50
attr_writer :max_results, :max_links, :max_concurrency
def initialize(google_website)
@google_website = google_website
@@ -60,10 +60,10 @@
threads.each(&:join)
@logger.debug "links_by_url: #{links_by_url.inspect}"
links_by_url.each { |arr| queue.push(arr) }
emails_by_url = ThreadSafe::Hash.new
- threads = (1..[links_by_url.length, MAX_CONCURRENCY].min).map do |i|
+ threads = (1..[links_by_url.length, @max_concurrency].min).map do |i|
Thread.new(i) do |i|
arr = begin
queue.pop(true)
rescue ThreadError; end