[poolifier.git] / examples / multiFunctionExample.js

const { FixedThreadPool, availableParallelism } = require('poolifier')

const pool = new FixedThreadPool(
  availableParallelism(),
  './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
	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)