[poolifier.git] / examples / multiFunctionExample.js

const { FixedThreadPool } = require('poolifier')
const pool = new FixedThreadPool(15, './multiFunctionWorker.js', {
  errorHandler: e => console.error(e),
  onlineHandler: () => console.info('worker is online')
})

pool
  .execute({ text: 'hello' }, 'fn0')
  .then(res => console.info(res))
  .catch(err => console.error(err))
pool
  .execute({ text: 'multiple functions' }, 'fn1')
  .then(res => console.info(res))
  .catch(err => console.error(err))

setTimeout(pool.destroy(), 3000)
Commit	Line	Data
60fbd6d6	1	const { FixedThreadPool } = require('poolifier')
5c5a1fb7	2	const pool = new FixedThreadPool(15, './multiFunctionWorker.js', {
cf9aa6c3	3	errorHandler: e => console.error(e),
53795b86	4	onlineHandler: () => console.info('worker is online')
cf9aa6c3	5	})
106744f7	6
583a27ce	7	pool
a86b6df1	8	.execute({ text: 'hello' }, 'fn0')
53795b86	9	.then(res => console.info(res))
583a27ce	10	.catch(err => console.error(err))
cf9aa6c3	11	pool
a86b6df1	12	.execute({ text: 'multiple functions' }, 'fn1')
53795b86	13	.then(res => console.info(res))
583a27ce	14	.catch(err => console.error(err))
106744f7	15
979e2251	16	setTimeout(pool.destroy(), 3000)