bench.ts

import Benchmark = require('benchmark');
import {Deferred, Event} from 'benchmark';
import PQueue from './source';

const suite = new Benchmark.Suite();

// Benchmark typings aren't up to date, let's help out manually
type Resolvable = Deferred & {resolve: () => void};

suite
	.add('baseline', {
		defer: true,

		fn: async (deferred: Resolvable) => {
			const queue = new PQueue();

			for (let i = 0; i < 100; i++) {
				// eslint-disable-next-line @typescript-eslint/no-empty-function
				queue.add(async () => {});
			}

			await queue.onEmpty();
			deferred.resolve();
		}
	})
	.add('operation with random priority', {
		defer: true,

		fn: async (deferred: Resolvable) => {
			const queue = new PQueue();

			for (let i = 0; i < 100; i++) {
				// eslint-disable-next-line @typescript-eslint/no-empty-function
				queue.add(async () => {}, {
					priority: (Math.random() * 100) | 0
				});
			}

			await queue.onEmpty();
			deferred.resolve();
		}
	})
	.add('operation with increasing priority', {
		defer: true,

		fn: async (deferred: Resolvable) => {
			const queue = new PQueue();

			for (let i = 0; i < 100; i++) {
				// eslint-disable-next-line @typescript-eslint/no-empty-function
				queue.add(async () => {}, {
					priority: i
				});
			}

			await queue.onEmpty();
			// @ts-expect-error benchmark typings incorrect
			deferred.resolve();
		}
	})
	.on('cycle', (event: Event) => {
		console.log(String(event.target));
	})
	.on('complete', function () {
		// @ts-expect-error benchmark typings incorrect
		console.log(`Fastest is ${(this as Benchmark.Suite).filter('fastest').map('name') as string}`);
	})
	.run({
		async: true
	});