reactphp-mq
reactphp-mq copied to clipboard
clue
Mini Queue, the lightweight in-memory message queue to concurrently do many (but not too many) things at once, built on top of ReactPHP.
I am planing to adjust the concurrency depending on external factors, at runtime, after constructed. It would be nice doing it with setConcurrency public function.
Currently when assigning a Queue 1000 tasks with a concurrency of 50, the first 50 items in the Queue will be "pending" almost "at once". Would it be possible to...
This project does not currently implement any retry logic. As such, it is up to consumers of this package to implement custom logic to handle failed jobs. We may want...
At the moment there is no way to continue processing queue in case of one of promises fail. `all` - method cancels the remaining queued promises if one of promises...
