TaskGroup::race

(PHP 8.6+, True Async 1.0)

public TaskGroup::race(): Async\Future

Devuelve un Future que se resuelve con el resultado de la primera tarea completada — ya sea exitosa o fallida. Si la tarea falló con un error, el Future se rechaza con esa excepción. Las tareas restantes continúan ejecutándose.

Si ya existe una tarea completada, el Future se resuelve inmediatamente.

El Future devuelto soporta un token de cancelación mediante await(?Completable $cancellation).

Valor de retorno

Async\Future — un resultado futuro de la primera tarea completada. Llame a ->await() para obtener el valor.

Errores

Lanza Async\AsyncException si el grupo está vacío.
El Future se rechaza con la excepción de la tarea si la primera tarea completada falló con un error.

Ejemplos

Ejemplo #1 Primera respuesta

<?php

use Async\TaskGroup;
use function Async\delay;

spawn(function() {
    $group = new TaskGroup();

    $group->spawn(function() { delay(100); return "lento"; });
    $group->spawn(fn() => "rápido");

    $winner = $group->race()->await();
    echo $winner . "\n"; // "rápido"
});

Ejemplo #2 Solicitudes hedged con tiempo de espera

<?php

use Async\TaskGroup;

spawn(function() {
    $replicas = ['db-replica-1', 'db-replica-2', 'db-replica-3'];
    $group = new TaskGroup();

    foreach ($replicas as $host) {
        $group->spawn(fn() => pg_query($host, 'SELECT * FROM products WHERE id = 42'));
    }

    $timeout = Async\timeout(2.0);

    try {
        $product = $group->race()->await($timeout);
    } catch (Async\TimeoutException) {
        echo "Ninguna réplica respondió en 2 segundos\n";
    }
});

Ver también

TaskGroup::any — Primer resultado exitoso
TaskGroup::all — Todos los resultados

Editar esta página