[poolifier.git] / piscina.js

// IMPORT LIBRARIES
const Piscina = require('piscina')
// FINISH IMPORT LIBRARIES
const size = process.env.POOL_SIZE
const iterations = process.env.NUM_ITERATIONS
const data = {
  test: 'MYBENCH'
}

const piscina = new Piscina({
  filename: './workers/piscina/json-stringify.worker.js',
  minThreads: Number(size),
  maxThreads: size * 3,
  idleTimeout: 1000 * 60 // this is the same as poolifier default
})

async function run () {
  const promises = []
  for (let i = 0; i < iterations; i++) {
    promises.push(piscina.runTask(data))
  }
  await Promise.all(promises)
  process.exit()
}

run()
Commit	Line	Data
	1	// IMPORT LIBRARIES
	2	const Piscina = require('piscina')
	3	// FINISH IMPORT LIBRARIES
	4	const size = process.env.POOL_SIZE
	5	const iterations = process.env.NUM_ITERATIONS
	6	const data = {
	7	test: 'MYBENCH'
	8	}
	9
	10	const piscina = new Piscina({
	11	filename: './workers/piscina/json-stringify.worker.js',
	12	minThreads: Number(size),
	13	maxThreads: size * 3,
	14	idleTimeout: 1000 * 60 // this is the same as poolifier default
	15	})
	16
	17	async function run () {
	18	const promises = []
	19	for (let i = 0; i < iterations; i++) {
	20	promises.push(piscina.runTask(data))
	21	}
	22	await Promise.all(promises)
	23	process.exit()
	24	}
	25
	26	run()