channel.pl6

my $channel = Channel.new;
await (^20).map: -> $r { 
  start { 
    #sleep (0,1,2).pick;
    $channel.send({sleep 1; $r});
  }
}
await (^3).map: -> $r { 
  start { 
    while $channel { 
      my $x = $channel.receive;
      say "Worker $r: Consume $x()";
    }
  }
}
say now - INIT now;