[poolifier.git] / proof.js

const FixedThreadPool = require('./fixed')
let resolved = 0
const pool = new FixedThreadPool(3, './yourWorker.js')

async function proof () {
  const o = {
    a: 123
  }
  const res = await pool.execute(o)
  // console.log('Here we are')
  console.log('I am logging the result ' + res)
}

// proof()

const start = Date.now()
const iterations = 50000
for (let i = 0; i <= iterations; i++) {
  const o = {
    a: i
  }
  pool.execute(o).then(res => {
    console.log(res)
    resolved++
    if (resolved === iterations) {
      console.log('Time take is ' + (Date.now() - start))
    }
  })
}
Commit	Line	Data
	1	const FixedThreadPool = require('./fixed')
	2	let resolved = 0
	3	const pool = new FixedThreadPool(3, './yourWorker.js')
	4
	5	async function proof () {
	6	const o = {
	7	a: 123
	8	}
	9	const res = await pool.execute(o)
	10	// console.log('Here we are')
	11	console.log('I am logging the result ' + res)
	12	}
	13
	14	// proof()
	15
	16	const start = Date.now()
	17	const iterations = 50000
	18	for (let i = 0; i <= iterations; i++) {
	19	const o = {
	20	a: i
	21	}
	22	pool.execute(o).then(res => {
	23	console.log(res)
	24	resolved++
	25	if (resolved === iterations) {
	26	console.log('Time take is ' + (Date.now() - start))
	27	}
	28	})
	29	}