並行スレッドの制限

Question

私はsftp経由でファイルをアップロードするプログラムでスレッドを使用しています。アップロードできるファイルの数は、潜在的に非常に大きくても非常に小さくてもかまいません。私は同時アップロード数が5以下になりたいと思っています。私の理解は、通常、これに使用される条件変数ですが、それは一度に1つのスレッドしか許さないように見えます。

cv = ConditionVariable.new 

t2 = Thread.new { 
    mutex.synchronize { 
    cv.wait(mutex) 
    upload(file) 
    cv.signal 
    } 
} 

私はcvがリリースされたらそれをリリースするのを待つように指示するべきだと思います。私の質問は、数字を制限しながら、一度に1つ以上を許可するにはどうしたらいいですか？

編集：私は1回のクリックインストーラの代わりに

Answer 1

使用して、ThreadPoolのをからWindows上でのRuby 1.8.7を使用しています。 Deadlock in ThreadPool（具体的には受け入れられた回答）を参照してください。

Answer 2

注意すべきことですが、JRubyを使用していない限り、Rubyには実際の並行性はありません。また、スレッド内の例外は、デバッグモードでない限り、メインループをフリーズします。

require "thread" 

POOL_SIZE = 5 

items_to_process = (0..100).to_a 

message_queue = Queue.new 

start_thread = 
    lambda do 
    Thread.new(items_to_process.shift) do |i| 
     puts "Processing #{i}" 
     message_queue.push(:done) 
    end 
    end 

items_left = items_to_process.length 

[items_left, POOL_SIZE].min.times do 
    start_thread[] 
end 

while items_left > 0 
    message_queue.pop 
    items_left -= 1 
    start_thread[] unless items_left < POOL_SIZE 
end