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