ruby - 如何在 ruby​​ 中使循环多线程？

Question

如何使这些循环与 ruby​​ 的多线程功能并行？

1.

from = 'a' * 1
to = 'z' * 3


("#{from}".."#{to}").each do |combination|  

    # ...

end

2.

@@alphabetSet_tr.length.times do |i|
    @@alphabetSet_tr.length.times do |j|
        @@alphabetSet_tr.length.times do |k|
            combination = @@alphabetSet_tr[i] + @@alphabetSet_tr[j] + @@alphabetSet_tr[k]
        end
    end
end

注意:@@alphabetSet_tr 是一个包含 29 项的数组

Answer 1

如果您想利用您的核心，您可以使用Queue将工作负载分配给固定数量的线程:

require 'thread'

queue = Queue.new

number_of_cores = 32

threads = (0..number_of_cores).map do
  Thread.new do
    combination = queue.pop
    while combination
      # do stuff with combination...

      # take the next combination from the queue
      combination = queue.pop
    end
  end
end

# fill the queue:
("#{from}".."#{to}").each do |combination|  
  queue << combination
end

# drain the threads
number_of_cores.times { queue << nil }

threads.each { |t| t.join }

如果您担心队列本身的大小会成为问题 - 您可以使用 SizedQueue如果它大于特定大小，它将阻止推送操作 - 限制其内存使用 -

queue = SizedQueue.new(10000)