Documentación

Aprenda a usar TrueAsync para crear aplicaciones PHP concurrentes.

TaskSet::joinAny

(PHP 8.6+, True Async 1.0)

public TaskSet::joinAny(): Async\Future

Devuelve un Future que se resuelve con el resultado de la primera tarea completada con éxito. Las tareas que terminaron con error se omiten.

Tras la entrega del resultado, la entrada se elimina automáticamente del conjunto.

Las tareas restantes continúan ejecutándose.

Si todas las tareas terminaron con error, el Future se rechaza con CompositeException.

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

Valor de retorno

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

Errores

Ejemplos

Ejemplo #1 Primer resultado exitoso

<?php

use Async\TaskSet;

spawn(function() {
    $set = new TaskSet();

    $set->spawn(fn() => throw new \RuntimeException("fail 1"));
    $set->spawn(fn() => throw new \RuntimeException("fail 2"));
    $set->spawn(fn() => "success!");

    $result = $set->joinAny()->await();
    echo $result . "\n"; // "success!"
    echo $set->count() . "\n"; // 2 (las tareas fallidas permanecen)
});

Ejemplo #2 Todas las tareas fallaron

<?php

use Async\TaskSet;

spawn(function() {
    $set = new TaskSet();

    $set->spawn(fn() => throw new \RuntimeException("err 1"));
    $set->spawn(fn() => throw new \RuntimeException("err 2"));

    $set->seal();

    try {
        $set->joinAny()->await();
    } catch (\Async\CompositeException $e) {
        echo count($e->getExceptions()) . " errors\n"; // "2 errors"
    }
});

Ejemplo #3 Búsqueda resiliente

<?php

use Async\TaskSet;

spawn(function() {
    $set = new TaskSet();

    $set->spawn(fn() => searchGoogle($query));
    $set->spawn(fn() => searchBing($query));
    $set->spawn(fn() => searchDuckDuckGo($query));

    $result = $set->joinAny()->await(Async\timeout(3.0));
    echo "Found, active: {$set->count()}\n";
});

Ver también