zer0-framework/queue

v0.2.4 2021-11-25 01:49 UTC

Requires

• php: >=7.2
• ext-igbinary: *
• zer0-framework/config: *
• zer0-framework/core: *

GPL-3.0-or-later

• Vasily Zorin

• highload
• Zer0

README

Компонент реализует очереди.

Конфигурация

Имя	Тип	Описание	Значение по-умолчанию
type	string	Тип хранилища	Redis

Пример использования

$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();
    }
}