loop/examples/2. Advanced/ResumableSignalLoop.php

<?php

require 'vendor/autoload.php';

use Amp\Loop;
use danog\Loop\ResumableSignalLoop;

use function Amp\delay;

class ResSigLoop extends ResumableSignalLoop
{
    /**
     * Loop name.
     *
     * @var string
     */
    private $name;
    /**
     * Constructor.
     *
     * @param string   $name     Loop name
     */
    public function __construct(string $name)
    {
        $this->name = $name;
    }
    /**
     * Main loop.
     *
     * @return \Generator
     */
    public function loop(): \Generator
    {
        $number = 0;
        while (true) {
            if (yield $this->waitSignal($this->pause(1))) {
                echo "Got exit signal in $this!".PHP_EOL;
                return;
            }
            echo "$this: $number".PHP_EOL;
            $number++;
        }
    }
    /**
     * Get loop name.
     *
     * @return string
     */
    public function __toString(): string
    {
        return $this->name;
    }
}

Loop::run(function () {
    /** @var ResSigLoop[] */
    $loops = [];
    for ($x = 0; $x < 10; $x++) {
        $loop = new ResSigLoop("Loop number $x");
        $loop->start();
        yield delay(100);
        $loops []= $loop;
    }
    yield delay(5000);
    echo "Resuming prematurely all loops!".PHP_EOL;
    foreach ($loops as $loop) {
        $loop->resume();
    }
    echo "OK done, waiting 5 more seconds!".PHP_EOL;
    yield delay(5000);
    echo "Closing all loops!".PHP_EOL;
    foreach ($loops as $loop) {
        $loop->signal(true);
    }
});