Class

Waits until a counted amount of work has been done, like Go's sync.WaitGroup.

Introduction#

Call add() before starting each piece of work, done() when it ends, and await() in the coroutine that waits. await() returns when the counter is zero, and at once if it already is. The counter may be raised again after it reached zero, so one group can be reused.

Class synopsis#

final class WaitGroup implements SelectableInterface {
    /* Methods */
    public WaitGroup::isReady(): bool
    public WaitGroup::add(int $delta = 1): void
    public WaitGroup::done(): void
    public WaitGroup::await(float $timeout = PHP_FLOAT_MAX): void
    public WaitGroup::wait(): void
}

Methods#

Examples#

phasync::run(function () {
    $group = new phasync\Util\WaitGroup();

    foreach ([0.02, 0.01] as $delay) {
        $group->add();
        phasync::go(function () use ($group, $delay) {
            try {
                phasync::sleep($delay);
            } finally {
                $group->done();
            }
        });
    }
    $group->await();
    echo "both done\n";
});

See also#