Ractor::Port Fan-Out: One Producer, Many Workers

ractor_fanout.rb

tasks   = Ractor::Port.new
results = Ractor::Port.new

workers = 4.times.map do
  Ractor.new(tasks, results) do |t, r|
    loop do
      job = t.receive
      r.send(job * job)
    end
  end
end

10.times { |i| tasks.send(i) }
10.times { puts results.receive }