Make workers pull from your own queue
- Langage dominant
- TypeScript
- Étoiles
- 3.5k
- Forks
- 173
- Métriques de merge des PR
- Aucune PR mergée en 30 j
Description
I know threadsjs has a queue method available on it's `Pool` class, but I want to create my own queue, in particular I'm writing a persistent queue.
I would like the worker threads to pull from the queue when they are ready/idle for the next task. And this pulling mechanism needs to be blocking to avoid busy-looping on the workers. That is they should just be awaiting on a promise that only resolves when a task is available for dispatch.
What is the right way to do this? Should I be extending the `Pool` class, or can I make the workers directly pull from some sort of shared queue data structure system?
Guide de contribution
Aucun guide de contribution indexé pour ce dépôt
Évaluation
Cette issue n'a pas encore été évaluée.