mirror of
https://github.com/lloeki/normandy.git
synced 2025-12-06 01:54:40 +01:00
24 lines
405 B
Ruby
24 lines
405 B
Ruby
# http://stackoverflow.com/questions/15715605/multiple-goroutines-listening-on-one-channel
|
|
|
|
require 'channel'
|
|
require 'channel/waitgroup'
|
|
|
|
c = Channel.new
|
|
w = WaitGroup.new
|
|
w.add(5)
|
|
|
|
1.upto(5) do |i|
|
|
go(lambda do |i, ci|
|
|
j = 1
|
|
ci.each do |v|
|
|
sleep(0.001)
|
|
puts format('%d.%d got %d', i, j, v)
|
|
j += 1
|
|
end
|
|
w.done
|
|
end, i, c)
|
|
end
|
|
|
|
1.upto(25) { |i| c << i }
|
|
c.close
|
|
w.wait
|