限制迭代红宝石中的线程数

Question

当我拥有这样的代码时，我会得到“无法创建线程，资源暂时不可用”。目录中有超过24k的文件要处理。

frames.each do |image|
    Thread.new do
        pipeline = ImageProcessing::MiniMagick.
            source(File.open("original/#{image}"))
            .append("-fuzz", "30%")
            .append("-transparent", "#ff00fe")
        result = pipeline.call

        puts result.path
        file_parts = image.split("_")
        frame_number = file_parts[2]
        FileUtils.cp(result.path, "transparent/image_transparent_#{frame_number}")

        puts "Done with #{image}!"
        puts "#{Dir.children("transparent").count.to_s} / #{Dir.children("original").count.to_s}"
        puts "\n"   
    end
end.each{ |thread| thread.join }

因此，我通过调用索引0-1000尝试了第一个1001个文件，然后以这种方式进行了操作：

frames[0..1000].each_with_index do |image, index|
    thread = Thread.new do
        pipeline = ImageProcessing::MiniMagick.
            source(File.open("original/#{image}"))
            .append("-fuzz", "30%")
            .append("-transparent", "#ff00fe")
        result = pipeline.call

        puts result.path
        file_parts = image.split("_")
        frame_number = file_parts[2]
        FileUtils.cp(result.path, "transparent/image_transparent_#{frame_number}")

        puts "Done with #{image}!"
        puts "#{Dir.children("transparent").count.to_s} / #{Dir.children("original").count.to_s}"
        puts "\n"   
    end
    thread.join
end

虽然这是处理的，但速度似乎就像我在观看单线时一样在终端。

但是我希望代码能够限制在OS允许之前允许的任何内容，以便它可以更快地解析它们。

或租赁时：

1. 找到允许的最大线程
2. 获得原始目录的计数，除以允许的线程数。
3. 在该部门的批处理中运行每个。