channel

channel.cr

j = 0
SIZE = 10000
a = Deque(Int32).new(SIZE)
#a = [] of Int32

in_channel = Channel(String).new
out_channel = Channel(String).new

spawn do
  loop do
    receive = in_channel.receive
    puts "in: #{receive}"

    spawn do
      a << j
      j += 1
      out_channel.send("out: #{receive}")
    end
  end
end

SIZE.times do |i|
  spawn do
    in_channel.send("msg-#{i}")
  end
end

SIZE.times do
  puts out_channel.receive
end

puts j
puts a.size