Ruby Ractor multiple worker example

gistfile1.txt

#!/usr/bin/env ruby


class Upcaser
  def process(string)
    string.upcase
  end
end

class Downcaser
  def process(string)
    string.downcase
  end
end

Consumers = [Upcaser, Downcaser]

# Setup the consuming Ractors
consumers = Consumers.map do |consumer|
  Ractor.new consumer do |consumer|
    Ractor.yield consumer.new.process(Ractor.recv)
  end
end

word = ARGV[0]
# publish the message to the consumers
consumers.map { |con|
  Ractor.new con, word do |con, word|
    con << word
  end
}

# wait for consumer ractors to process messages
# delete them when work returned from ractor
until consumers.empty? do
  r, output = Ractor.select(*consumers)
  consumers.delete(r)
  puts output
end