Ruby Language One Source Multiple Workers


Exemple

Nous voulons traiter les données en parallèle.

Remplissons la source avec quelques données:

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

Ensuite, créez des travailleurs pour traiter les données:

(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)