[poolifier.git] / examples / staticExample.js

const FixedThreadPool = require('../lib/fixed')
let resolved = 0
const pool = new FixedThreadPool(15,
  './yourWorker.js',
  { errorHandler: (e) => console.error(e), onlineHandler: () => console.log('worker is online') })

const start = Date.now()
const iterations = 1000
for (let i = 0; i <= iterations; i++) {
  pool.execute({}).then(res => {
    resolved++
    if (resolved === iterations) {
      console.log('Time take is ' + (Date.now() - start))
    }
  })
}
Commit	Line	Data
c68d4281	1	const FixedThreadPool = require('../lib/fixed')
c2dbbe2b	2	let resolved = 0
bf962cba	3	const pool = new FixedThreadPool(15,
	4	'./yourWorker.js',
	5	{ errorHandler: (e) => console.error(e), onlineHandler: () => console.log('worker is online') })
3e460d6d	6
27006a3d	7	const start = Date.now()
bf962cba	8	const iterations = 1000
c2dbbe2b	9	for (let i = 0; i <= iterations; i++) {
a32e02ba	10	pool.execute({}).then(res => {
c2dbbe2b	11	resolved++
3e460d6d	12	if (resolved === iterations) {
3e460d6d	13	console.log('Time take is ' + (Date.now() - start))
c2dbbe2b	14	}
3e460d6d	15	})
6dc67cda	16	}