sparallel/laravel

Parallel PHP via processes for Laravel

dev-master 2025-05-06 09:48 UTC

Requires

• php: ^8.2
• ext-posix: *
• ext-redis: *
• laravel/framework: ^9.0 | ^10.0 | ^11.0 | ^12.0
• predis/predis: ^2.2
• sparallel/sparallel: dev-master

Requires (Dev)

• orchestra/testbench: ^9.13
• phpstan/phpstan: ^2.1
• phpunit/phpunit: ^11.5

MIT

• Pavel

README

php artisan vendor:publish --tag=sparallel-laravel

# sparallel
SPARALLEL_MODE=sync
SPARALLEL_TASK_MEMORY_LIMIT_MB=128
# one of: none, redis
SPARALLEL_WORKERS_REPOSITORY=redis

example

Init

$service = app(\SParallel\Services\SParallelService::class);

$callbacks = [
    'first'  => static fn() => 'first',
    'second' => static fn() => throw new RuntimeException('second'),
    'third'  => static function(
        \SParallel\Services\Context $context,
        \Illuminate\Contracts\Events\Dispatcher $dispatcher // DI support
    ) {
        $context->check();
        
        return 'third';
    },
];

Wait all tasks to finish and get results

/** 
 * @var \SParallel\Services\SParallelService $service 
 * @var array<string, Closure> $callbacks 
 */

$results = $service->wait(
    callbacks: $callbacks,
    timeoutSeconds: 2,
);

if ($results->hasFailed()) {
    foreach ($results->getFailed() as $key => $failedResult) {
        echo "$taskKey: ERROR: " . ($failedResult->error?->message ?: 'unknown error') . "\n";
    }
}

foreach ($results->getResults() as $result) {
    if ($result->error) {
        continue;
    }

    echo "$taskKey: SUCCESS: " . $result->result . "\n";
}

Run tasks and get results at any task completion

/** 
 * @var \SParallel\Services\SParallelService $service 
 * @var array<string, Closure> $callbacks 
 */

$results = $service->run(
    callbacks: $callbacks,
    timeoutSeconds: 2,
);

foreach ($results as $taskKey => $result) {
    if ($result->error) {
        echo "$taskKey: ERROR: " . ($result->error->message ?: 'unknown error') . "\n";
        
        continue;
    }

    echo "$taskKey: SUCCESS: " . $result->result . "\n";
}