gistfile1.txt

#!/usr/bin/env perl6

use v6;

sub MAIN {
    my $supply = (1, 2, 3, 4, 5).Supply;
    my $sched = ThreadPoolScheduler.new(
        :initial_threads(4),
        :max_threads(8),
    );
    $supply.schedule-on($sched);
    $supply.tap(
        sub ($item) {
            say "Tap #1 got $item in thread #{$*THREAD.id}";
        }
    );
    say "Adding next tap";
    $supply.tap(
        sub ($item) {
            say "Tap #2 got $item in thread #{$*THREAD.id}";
        },
        :done( { say "Tap #2 is done in thread #{$*THREAD.id}" } ),
    );
}