Channel ping-pong latency

bench.cr

ch = Channel(Int32).new
done = Channel(Time::Span).new

count = (ARGV[0]? || 1000).to_i

4.times do
  spawn do
    delay = Time::Span::ZERO
    count.times do |i|
      delay += Time.measure do
        ch.send i
      end
    end

    done.send delay
  end
end

4.times do
  spawn do
    delay = Time::Span::ZERO
    count.times do |i|
      delay += Time.measure do
        ch.receive?
      end
    end

    done.send delay
  end
end

total_delay = Time::Span::ZERO

8.times do
  total_delay += done.receive
end

puts total_delay