docs: document availableParallelism() usage
[poolifier.git] / examples / multiFunctionExample.js
CommitLineData
6961ca9a
JB
1const { FixedThreadPool, availableParallelism } = require('poolifier')
2
3const pool = new FixedThreadPool(
4 availableParallelism(),
5 './multiFunctionWorker.js',
6 {
7 errorHandler: e => console.error(e),
8 onlineHandler: () => console.info('worker is online')
9 }
10)
106744f7 11
583a27ce 12pool
a86b6df1 13 .execute({ text: 'hello' }, 'fn0')
53795b86 14 .then(res => console.info(res))
583a27ce 15 .catch(err => console.error(err))
cf9aa6c3 16pool
a86b6df1 17 .execute({ text: 'multiple functions' }, 'fn1')
53795b86 18 .then(res => console.info(res))
583a27ce 19 .catch(err => console.error(err))
106744f7 20
979e2251 21setTimeout(pool.destroy(), 3000)