Documentación

Aprenda a usar TrueAsync para crear aplicaciones PHP concurrentes.

Channel::count

(PHP 8.6+, True Async 1.0)

public Channel::count(): int

Devuelve el número actual de valores en el búfer del canal.

Channel implementa la interfaz Countable, por lo que puede usar count($channel).

Para un canal rendezvous (capacity = 0), esto siempre devuelve 0.

Valores de retorno

El número de valores en el búfer (int).

Ejemplos

Ejemplo #1 Monitoreo del nivel de llenado del búfer

<?php

use Async\Channel;

$channel = new Channel(5);

$channel->send(1);
$channel->send(2);
$channel->send(3);

echo count($channel);        // 3
echo $channel->count();      // 3

$channel->recv();
echo count($channel);        // 2

Ejemplo #2 Registro de carga del canal

<?php

use Async\Channel;

$tasks = new Channel(100);

spawn(function() use ($tasks) {
    while (!$tasks->isClosed()) {
        $usage = $tasks->count() / $tasks->capacity() * 100;
        echo "Búfer al " . round($usage) . "% de capacidad\n";
        delay(1000);
    }
});

Ver también