enhancementhelp wanted
Métricas do repositório
- Stars
- (2.297 stars)
- Métricas de merge de PR
- (Métricas PR pendentes)
Description
Instead of doing every time this:
const pool = workerpool.pool(
path.resolve(__dirname, 'worker')
)
const tasks: workerpool.Promise<any, Error>[] = []
for (const entity of entities) {
const task = pool.exec('worker', [entity])
tasks.push(task)
}
await Promise.all(tasks)
await pool.terminate()
We can do:
const pool = workerpool.pool(
path.resolve(__dirname, 'worker')
)
for (const entity of entities) {
pool.exec('worker', [entity])
}
/* Wait all tasks to complete */
await pool.completed()
await pool.terminate()
It would be very handy, if this method is added in the future For example, threads.js already have this feature