ruby マルチスレッド、スレッド上限につきまして

Question

現在以下のように5分間ほど複数の処理をマルチスレッドで実行するように実装しております。

start_time = Time.now
threads = []
while start_time.since(5) > Time.now
threads << Thread.new do
ActiveRecord::Base.connection_pool.with_connection do
(複数の処理)
end
end
end
sleep 5
end

スレッド数の上限を設定するにはどうすればいいでしょうか。
教えていただきたいです。

Comments

[maisumakun]

スレッドの「何」に上限を設定したいのでしょうか？

生成数なのか、処理時間なのか、使用メモリなのか、それ以外の資源なのか、そこを明確にしてください。

[basken]

失礼いたしました。
スレッドの生成数を制限したいと考えております。
（現状の実装では複数の処理分スレッドが作成されてしまうため）

Answer 1

単純にwhileの条件でthreads.lengthもチェックする、で問題ないのではないでしょうか。

threads = []
while start_time.since(5) > Time.now && threads.length < 10

Comments

[basken]

記載している（複数の処理）はリアルタイムに増えていくため、
スレッド数が10個を超えた際に5分間実施していて欲しい処理が止まると、リアルタイムで追加された分の（複数の処理）が実行されなくなってしまいます。

5分間（複数の処理）を繰り返しつつ、スレッドの生成数を10に抑える方法はないでしょうか。

[maisumakun]

最初からスレッドは10個と決めて、5分間繰り返すのはスレッドの中で行う、という方法はどうでしょうか？

[basken]

検討してみます！ありがとうございます。

スレッドを10個と定める方法教えていただけますでしょうか。

[maisumakun]

10.timesでThread.newを繰り返せばいいだけです。

[basken]

以下のような実装になったのですが
（複数の処理）は最大10スレッドの並列処理を5分繰り返すようになっているのでしょうか。

10.times do
threads << Thread.new do
while start_time.since(5) > Time.now
（複数の処理）
end
end
end