gistfile1.p6

class Foo {
  has ThreadPoolScheduler $!scheduler = ThreadPoolScheduler.new;

  has Channel $.c = Channel.new;
  has Thread $.t;

  method push ($any) {
    $!c.send($any);
  }

  method BUILD {
    say "run";
    my $stop;
    $!scheduler = ThreadPoolScheduler.new;
    $!scheduler.cue(
      :every(0),
      :catch{$stop},
      {
        say "start";
        loop {
        my $msg = $!c.receive;
        note "Got $msg";
        note "Got $msg still";
        last if $msg == 3;
        }
        say "stop";
      },
      );
    say "...ning";
  }
}

my $a = Foo.new;
#$a.run;
say "Sleep";
$a.push(7);
sleep 1;
$a.push(3);
say "pushed";
sleep 2;
say "die";