Make workers pull from your own queue
- Linguagem predominante
- TypeScript
- Estrelas
- 3.5k
- Forks
- 173
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Descrição
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?
Guia de contribuição
Nenhum guia de contribuição indexado para este repositório
Avaliação
Esta issue ainda não foi avaliada.