從線程循環中突破

Question

我正在從（降序）時間有序庫中下載圖像。我想停下來，當我們看到已經停下來的照片時。

require 'thread/pool' 

def getimg(uri) 
#... 
    if File.exist? filename 
    raise "Already done." # something like this 
    end 
#... 
end 

pool = Thread.pool(4) 

thumbs.each do |a| 
    pool.process { 
    getimg(URI(a.attr('href'))) 
    } 
end 

Answer 1

傳遞池對象並使用pool.shutdown怎麼樣？

require 'thread/pool' 

def getimg(uri, pool) # <---- 
#... 
    if File.exist? filename 
    pool.shutdown # <-------- 
    return   # <------ 
    end 
#... 
end 

pool = Thread.pool(4) 

thumbs.each do |a| 
    pool.process { 
    getimg(URI(a.attr('href')), pool) # <---- 
    } 
end 

根據the Thread::Pool#process code comment：

關閉池，它會阻止，直到所有任務完成運行。

UPDATE

使用shutdown!代替shutdown。

已關閉！立即關閉游泳池而不完成執行任務。