build(deps-dev): bump @types/node

[poolifier.git] / examples / javascript / multiFunctionExample.js

'use strict'
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)