Added prettier standard to support prettier and use it in combination with standard

[poolifier.git] / benchmarks / bench.js

const Benchmark = require('benchmark')
const suite = new Benchmark.Suite()
const FixedThreadPool = require('../lib/fixed')
const DynamicThreadPool = require('../lib/dynamic')
const size = 30
const tasks = 1

// pools
const fixedPool = new FixedThreadPool(size, './yourWorker.js', {
  maxTasks: 10000
})
const dynamicPool = new DynamicThreadPool(
  size / 2,
  size * 3,
  './yourWorker.js',
  { maxTasks: 10000 }
)
const workerData = { proof: 'ok' }

// wait some seconds before start, my pools need to load threads !!!
setTimeout(async () => {
  test()
}, 3000)

// fixed pool proof
async function fixedTest () {
  return new Promise((resolve, reject) => {
    let executions = 0
    for (let i = 0; i <= tasks; i++) {
      fixedPool.execute(workerData).then(res => {
        executions++
        if (executions === tasks) {
          resolve('FINISH')
        }
      })
    }
  })
}

async function dynamicTest () {
  return new Promise((resolve, reject) => {
    let executions = 0
    for (let i = 0; i <= tasks; i++) {
      dynamicPool.execute(workerData).then(res => {
        executions++
        if (executions === tasks) {
          resolve('FINISH')
        }
      })
    }
  })
}

async function test () {
  // add tests
  suite
    .add('PioardiStaticPool', async function () {
      await fixedTest()
    })
    .add('PioardiDynamicPool', async function () {
      await dynamicTest()
    })
    // add listeners
    .on('cycle', function (event) {
      console.log(String(event.target))
    })
    .on('complete', function () {
      this.filter('fastest').map('name')
      console.log('Fastest is ' + this.filter('fastest').map('name'))
    })
    // run async
    .run({ async: true })
}