zer0-framework/queue

Maintainers

Details

github.com/zer0-framework/queue

Homepage

Source

Issues

Installs: 2 505

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 2

Forks: 0

Open Issues: 0

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

Requires

GPL-3.0-or-later 81b53206353a5c944d17431c0d9a50c98319779a

  • Vasily Zorin <kak.serpom.po.yaitsam.woop@gmail.com>

highloadZer0

This package is auto-updated.

Last update: 2024-11-25 08:11:43 UTC

README

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

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

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

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