gistfile1.txt

method !run-with-progress ($items, Routine $sub, Str $msg = q{   done}) {
    my $prog = Term::ProgressBar.new( :count( $items.elems ), :p )
        if $!verbose;

    my $supply = $items.Supply;

    if $!threads > 1 {
        my $sched = ThreadPoolScheduler.new( :max_threads($!threads) );
        $supply = $supply.schedule-on($sched);
    }

    my $i = 1;
    $supply.tap(
        sub ($item) {
            $sub($item);
            say "THREAD #{$*THREAD.id}";
            $prog.?update($i);
            $i++;
        }
    );

    $supply.wait;

    $prog.?message($msg);
}