$pool = $this->app->factory('Queue');
try {
    var_dump($pool->enqueueWait(new SomeTask(), /* ждём ответа */ 3 /* секунды */)->foo);
    // string(3) "bar"
} catch (\Zer0\Queue\Exceptions\WaitTimeoutException $e) {
    // Задача не завершилась за 3 секунды
}

这就是 SomeTask 的样子

final class SomeTask extends \Zer0\Queue\TaskAbstract
{
    /**
     * @var string
     */
    public $foo;

    /**
     *
     */
    public function execute(): void
    {
        $this->foo = 'bar';

        $this->complete();
    }
}