一个来源多个工人

我们想要并行处理数据。

让我们用一些数据填充源代码：

source = Queue.new
data = (1..100)
data.each { |e| source << e }

然后创建一些工作来处理数据：

(1..16).to_a.map do
  Thread.new do
    until source.empty?
      item = source.pop
      sleep 0.5
      puts "Processed: #{item}"
    end
  end
end.map(&:join)