Rubyでスレッドの同時実行数を制限します。 カウンティングセマフォを使えば良いのですが、標準添付ライブラリには入ってない(多分)ので、実装します。 素直にやるとこういう感じ -> rubyでカウンティングセマフォ カウンタとMutexを用意して、カウンタが0の時に待つ機構を作って…と、割とめんどくさいことをしないといけません。 シンプルに 標準添付ライブラリのQueueを使えばこれらの処理がサクッと実装できちゃいます。 require 'thread' locks = Queue.new 2.times { locks.push :lock } Array.new(10) do |i| Thread.new do lock = locks.pop print "#{i}\n" sleep 2 locks.push lock end end.each(&:join) このコードでは10スレ
![Rubyで「スレッドの同時実行数を制限する」シンプルな方法 - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/06aeb0ca24fbe15221ef365bc5a82fa54d418cf9/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fcdn.qiita.com%252Fassets%252Fpublic%252Farticle-ogp-background-412672c5f0600ab9a64263b751f1bc81.png%3Fixlib%3Drb-4.0.0%26w%3D1200%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTk3MiZoPTM3OCZ0eHQ9UnVieSVFMyU4MSVBNyVFMyU4MCU4QyVFMyU4MiVCOSVFMyU4MyVBQyVFMyU4MyU4MyVFMyU4MyU4OSVFMyU4MSVBRSVFNSU5MCU4QyVFNiU5OSU4MiVFNSVBRSU5RiVFOCVBMSU4QyVFNiU5NSVCMCVFMyU4MiU5MiVFNSU4OCVCNiVFOSU5OSU5MCVFMyU4MSU5OSVFMyU4MiU4QiVFMyU4MCU4RCVFMyU4MiVCNyVFMyU4MyVCMyVFMyU4MyU5NyVFMyU4MyVBQiVFMyU4MSVBQSVFNiU5NiVCOSVFNiVCMyU5NSZ0eHQtYWxpZ249bGVmdCUyQ3RvcCZ0eHQtY29sb3I9JTIzMjEyMTIxJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTU2JnM9NGI3MzdjOTA2OWE0M2IxYzVlZTMzYjI0ZWQ1ZmY4N2U%26mark-x%3D142%26mark-y%3D57%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZoPTc2Jnc9NzcwJnR4dD0lNDBuYS1vLXlzJnR4dC1jb2xvcj0lMjMyMTIxMjEmdHh0LWZvbnQ9SGlyYWdpbm8lMjBTYW5zJTIwVzYmdHh0LXNpemU9MzYmdHh0LWFsaWduPWxlZnQlMkN0b3Amcz0zNzk1MjQwYzUwYWZhMGYwMjI3M2UyMGY5YWM1YWQ0OQ%26blend-x%3D142%26blend-y%3D486%26blend-mode%3Dnormal%26s%3D50645b7ef7e3114309bb50fa9cd642be)