Benchmarks and performance enhancements (#209)

[poolifier.git] / benchmarks / internal / bench.js

const Benchmark = require('benchmark')
const { dynamicClusterTest } = require('./cluster/dynamic')
const { fixedClusterTest } = require('./cluster/fixed')
const { dynamicThreadTest } = require('./thread/dynamic')
const { fixedThreadTest } = require('./thread/fixed')

const suite = new Benchmark.Suite()

const LIST_FORMATTER = new Intl.ListFormat('en-US', {
  style: 'long',
  type: 'conjunction'
})

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

async function test () {
  // Add tests
  suite
    .add('Pioardi:Static:ThreadPool', async function () {
      await fixedThreadTest()
    })
    .add('Pioardi:Dynamic:ThreadPool', async function () {
      await dynamicThreadTest()
    })
    .add('Pioardi:Static:ClusterPool', async function () {
      await fixedClusterTest()
    })
    .add('Pioardi:Dynamic:ClusterPool', async function () {
      await dynamicClusterTest()
    })
    // Add listeners
    .on('cycle', function (event) {
      console.log(event.target.toString())
    })
    .on('complete', function () {
      console.log(
        'Fastest is ' +
          LIST_FORMATTER.format(this.filter('fastest').map('name'))
      )
      // eslint-disable-next-line no-process-exit
      process.exit()
    })
    .run()
}