zer0-framework / queue
Installs: 2 505
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 2
Forks: 0
Open Issues: 0
Requires
- php: >=7.2
- ext-igbinary: *
- zer0-framework/config: *
- zer0-framework/core: *
This package is auto-updated.
Last update: 2024-10-25 08:04:52 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(); } }