RuntimeError (Döngüsel bağımlılık bu hatayı alıyorum

Question

mulithread sabit Uygulamalar hakklı ederken tespit edildi:.. Sabit Uygulamalar

Ben mulithread ediyorum hakklı ederken tespit RuntimeError (Dairesel bağımlılık İşte aşağıda benim kodudur neden oluyor ? Multithread çalışmamın nedeni, bir HTML kazıma uygulaması yazıyorum çünkü Nokogiri :: HTML (open()) çağrısı, geri dönmek için 1 saniye süren bir eşzamanlı engelleme çağrısıdır ve 100.000+ sayfa var ziyaret etmek için, bu sorunun üstesinden gelmek için birkaç iş parçacığı çalıştırmaya çalışıyorum. Bunu yapmanın daha iyi bir yolu var mı?

class ToolsController < ApplicationController 

def getWebsites 
    t1=Thread.new{func1()} 
    t2=Thread.new{func1()} 
    t3=Thread.new{func1()} 
    t4=Thread.new{func1()} 
    t5=Thread.new{func1()} 
    t6=Thread.new{func1()} 
    t1.join 
    t2.join 
    t3.join 
    t4.join 
    t5.join 
    t6.join 
end 

def func1 
    puts Thread.current 
    apps = Apps.order("RANDOM()").where("apps.website IS NULL").take(1) 
    while apps.size == 1 do 
     app = apps[0] 
     puts app.name 
     puts app.iTunes 
     doc = Nokogiri::HTML(open(app.iTunes)) 
     array = doc.css('div.app-links a').map { |link| 
      url = link['href'] 
      url = Domainatrix.parse(url) 
      url.domain + "." + url.public_suffix 
     } 
     array.uniq! 
     if (array.size > 0) 
      app.website = array.join(', ') 
      puts app.website 
     else 
      app.website = "NONE" 
     end 
     app.save 
     apps = Apps.order("RANDOM()").where("apps.website IS NULL").take(1) 
    end 
end 


end 

Answer 1

"iste" evreli değil

Değişim yöntemlerinizi böylece ipler başlamadan önce öyle yapılır "gerekli" olan her şey. Örneğin

:

def get_websites 
    # values = Apps.all # try uncommenting this line if a second-try is required 

    ar = Apps.where("apps.website IS NULL") 

    t1 = Thread.new{ func1(ar) } 
    t2 = Thread.new{ func1(ar) } 

    t1.join 
    t2.join 
end 

def func1(ar) 
    apps = ar.order("RANDOM()").limit(1) 

    while (apps.size == 1) 
     puts Thread.current 
    end 
end 

Ama birileri belirttiği gibi, kumandanın içinde çoklu kullanım şekliniz tavsiye edilmez.