andywer / andywer/threads.js

Make workers pull from your own queue

Aperta
#440 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
TypeScript
Stelle
3.5k
Fork
173
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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?

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.