从线程循环中突破

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。

已关闭！立即关闭游泳池而不完成执行任务。