examples/multiFunctionExample.js

   1 const { FixedThreadPool, availableParallelism } = require('poolifier')
   2
   3 const pool = new FixedThreadPool(
   4   availableParallelism(),
   5   './multiFunctionWorker.js',
   6   {
   7     errorHandler: e => console.error(e),
   8     onlineHandler: () => console.info('worker is online')
   9   }
  10 )
  11
  12 pool
  13   .execute({ text: 'hello' }, 'fn0')
  14   .then(res => console.info(res))
  15   .catch(err => console.error(err))
  16 pool
  17   .execute({ text: 'multiple functions' }, 'fn1')
  18   .then(res => console.info(res))
  19   .catch(err => console.error(err))
  20
  21 setTimeout(pool.destroy(), 3000)