Edit File - File Manager

Edit File: SwooleTaskDispatcher.php

<?php

namespace Laravel\Octane\Swoole;

use Closure;
use InvalidArgumentException;
use Laravel\Octane\Contracts\DispatchesTasks;
use Laravel\Octane\Exceptions\TaskExceptionResult;
use Laravel\Octane\Exceptions\TaskTimeoutException;
use Laravel\SerializableClosure\SerializableClosure;
use Swoole\Http\Server;

class SwooleTaskDispatcher implements DispatchesTasks
{
    /**
     * Concurrently resolve the given callbacks via background tasks, returning the results.
     *
     * Results will be keyed by their given keys - if a task did not finish, the tasks value will be "false".
     *
     * @param  array  $tasks
     * @param  int  $waitMilliseconds
     * @return array
     *
     * @throws \Laravel\Octane\Exceptions\TaskException
     * @throws \Laravel\Octane\Exceptions\TaskTimeoutException
     */
    public function resolve(array $tasks, int $waitMilliseconds = 3000): array
    {
        if (! app()->bound(Server::class)) {
            throw new InvalidArgumentException('Tasks can only be resolved within a Swoole server context / web request.');
        }

$results = app(Server::class)->taskWaitMulti(collect($tasks)->mapWithKeys(function ($task, $key) {
            return [$key => $task instanceof Closure
                            ? new SerializableClosure($task)
                            : $task, ];
        })->all(), $waitMilliseconds / 1000);

if ($results === false) {
            throw TaskTimeoutException::after($waitMilliseconds);
        }

$i = 0;

foreach ($tasks as $key => $task) {
            if (isset($results[$i])) {
                if ($results[$i] instanceof TaskExceptionResult) {
                    throw $results[$i]->getOriginal();
                }

$tasks[$key] = $results[$i]->result;
            } else {
                $tasks[$key] = false;
            }

$i++;
        }

return $tasks;
    }

/**
     * Concurrently dispatch the given callbacks via background tasks.
     *
     * @param  array  $tasks
     * @return void
     */
    public function dispatch(array $tasks): void
    {
        if (! app()->bound(Server::class)) {
            throw new InvalidArgumentException('Tasks can only be dispatched within a Swoole server context / web request.');
        }

$server = app(Server::class);

collect($tasks)->each(function ($task) use ($server) {
            $server->task($task instanceof Closure ? new SerializableClosure($task) : $task);
        });
    }
}

Back to File Manager