benchmarks/internal/thread/fixed.js

   1 const { FixedThreadPool } = require('../../../lib/index')
   2
   3 const size = 30
   4
   5 const fixedPool = new FixedThreadPool(size, './worker.js')
   6
   7 async function fixedThreadTest (
   8   { tasks, workerData } = { tasks: 1, workerData: { proof: 'ok' } }
   9 ) {
  10   return new Promise((resolve, reject) => {
  11     let executions = 0
  12     for (let i = 0; i <= tasks; i++) {
  13       fixedPool
  14         .execute(workerData)
  15         .then(res => {
  16           executions++
  17           if (executions === tasks) {
  18             return resolve('FINISH')
  19           }
  20           return null
  21         })
  22         .catch(err => {
  23           console.error(err)
  24         })
  25     }
  26   })
  27 }
  28
  29 module.exports = { fixedThreadTest }