@@ -204,17 +204,17 @@ log
204204# "producer 0 pushing 2",
205205# "producer 1 pushing 0",
206206# "consumer 0 got 0. payload 0 from producer 0",
207- # "producer 0 pushing 3",
208207# "consumer 1 got 0. payload 1 from producer 0",
209- # "producer 1 pushing 1",
210208# "consumer 2 got 0. payload 2 from producer 0",
211209# "consumer 3 got 0. payload 0 from producer 1",
210+ # "producer 0 pushing 3",
211+ # "producer 1 pushing 1",
212212# "producer 1 pushing 2",
213- # "consumer 0 got 1. payload 3 from producer 0",
213+ # "consumer 1 got 1. payload 3 from producer 0",
214214# "producer 1 pushing 3",
215- # "consumer 3 got 1. payload 1 from producer 1",
216- # "consumer 1 got 1. payload 2 from producer 1",
217- # "consumer 2 got 1. payload 3 from producer 1"]
215+ # "consumer 0 got 1. payload 1 from producer 1",
216+ # "consumer 2 got 1. payload 2 from producer 1",
217+ # "consumer 3 got 1. payload 3 from producer 1"]
218218```
219219
220220The producers are much faster than consumers
@@ -268,20 +268,20 @@ consumers.map(&:value!) # => [:done, :done, :done, :done]
268268# investigate log
269269log
270270# => ["producer 0 pushing 0",
271- # "producer 0 pushing 1",
272271# "producer 1 pushing 0",
273- # "consumer 1 got 0. payload 1 from producer 0",
274- # "producer 0 pushing 2",
275- # "producer 0 pushing 3",
272+ # "producer 0 pushing 1",
276273# "producer 1 pushing 1",
277274# "consumer 0 got 0. payload 0 from producer 0",
278- # "consumer 2 got 0. payload 0 from producer 1",
275+ # "consumer 1 got 0. payload 0 from producer 1",
276+ # "consumer 2 got 0. payload 1 from producer 0",
277+ # "producer 0 pushing 2",
278+ # "consumer 3 got 0. payload 1 from producer 1",
279279# "producer 1 pushing 2",
280- # "consumer 3 got 0. payload 2 from producer 0 ",
280+ # "producer 0 pushing 3 ",
281281# "producer 1 pushing 3",
282- # "consumer 1 got 1. payload 3 from producer 0",
283- # "consumer 0 got 1. payload 1 from producer 1",
282+ # "consumer 1 got 1. payload 2 from producer 0",
284283# "consumer 2 got 1. payload 2 from producer 1",
284+ # "consumer 0 got 1. payload 3 from producer 0",
285285# "consumer 3 got 1. payload 3 from producer 1"]
286286```
287287
0 commit comments