Parallel

Parallel es una herramienta de programación para la programación de tareas en paralelo, que permite ejecutar múltiples tareas asíncronas simultáneamente en un programa y obtener los resultados una vez que todas las tareas han finalizado. Parallel se basa en Barrier.

Nota
El sistema automáticamente identifica el tipo de controlador y solo es compatible con los controladores Swoole/Swow/Fiber.

Sugerencia
Esta característica requiere workerman>=5.1.0.

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Parallel;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// Servidor Http
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // O Swow::class o Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $parallel = new Parallel();
    for ($i=1; $i<5; $i++) {
        $parallel->add(function () use ($i) {
            // Hacer algo
            return $i;
        });
    }
    $results = $parallel->wait();
    $connection->send(json_encode($results)); // Respuesta: [1,2,3,4]
};
Worker::runAll();

Descripción de la interfaz

interface ParallelInterface
{
    /**
     * Constructor, $concurrent es el número de tareas en paralelo, -1 indica que no hay límite en el número de tareas en paralelo.
     */
    public function __construct(int $concurrent = -1);

    /**
     * Agregar una tarea paralela.
     */
    public function add(callable $callable, ?string $key = null): void;

    /**
     * Esperar a que todas las tareas se completen y devolver los resultados.
     */
    public function wait(): array;

    /**
     * Obtener los resultados de las tareas que han lanzado excepciones.
     */
    public function getExceptions(): array;
}