iso-bench

iso-bench is a small benchmark library focused on avoiding optimization/deoptimization pollution between tests by isolating them.

Motivation
Pollution examples
Installation
Usage
Documentation
1. Processor
2. Notes

1. Motivation

I've always used benchmark.js for my benchmark tests, but I noticed that changing the tests order also changed the performance outcome. They were getting polluted between them somehow. V8 optimizations/deoptimizations maybe? I decided to take advantage of forking to do tests in completely separated processes with their own V8 instances, memory and so on, to avoid present and future optimization/deoptimization pollution.

All single threaded benchmark libraries, like benny or benchmark.js suffer this problem, so you may had this pollution on your tests and you didn't even notice, just thinking that one test was faster than the other. This happened to me, and when I noticed the problem it was too late and I had to refactor some PacoPack code ☹️

2. Pollution examples

Running this test on benchmark.js will return different outcomes. Note how method and method_again run the very same exact code:

const Benchmark = require("benchmark");
const functions = {
    method: function(buf:Buffer) {
        return buf.readUint8(0);
    },
    direct: function(buf:Buffer) {
        return buf[0];
    },
    method_again: function(buf:Buffer) {
        return buf.readUint8(0);
    }
};
const buffers = new Array(1000).fill(0).map(() => {
    const buf = Buffer.allocUnsafe(1);
    buf[0] = Math.floor(Math.random() * 0xFF);
    return buf;
});
const suite = new Benchmark.Suite();
for (const [type, fn] of Object.entries(functions)) {
    suite.add(`${type}`, () => {
        for (let i = 0; i < buffers.length; i++) {
            fn(buffers[i]);
        }
    });
}
suite.on("cycle", event => {
    console.log(String(event.target));
}).run({
    async: true
});

Which yields the next results:

method       x 314,830 ops/sec
direct       x 300,522 ops/sec
method_again x 187,985 ops/sec // SLOWER THAN "method"?? IS THE SAME CODE!!

And if I run the direct test first, it is even worse:

direct       x 1,601,246 ops/sec // 5 TIMES FASTER THAN BEFORE??
method       x 183,015 ops/sec // This test already got deoptimized
method_again x 183,956 ops/sec

On iso-bench this is not possible, as every test will run in a completely different process. No matter the order, the outcome will be equally stable. This is the very same test on iso-bench:

import { IsoBench } from "..";
const bench = new IsoBench();
const functions = {
  method: function(buf:Buffer) {
      return buf.readUint8(0);
  },
  direct: function(buf:Buffer) {
      return buf[0];
  },
  method_again: function(buf:Buffer) {
      return buf.readUint8(0);
  }
};
const buffers = new Array(1000).fill(0).map(() => {
  const buf = Buffer.allocUnsafe(1);
  buf[0] = Math.floor(Math.random() * 0xFF);
  return buf;
});
for (const [type, fn] of Object.entries(functions)) {
  bench.add(`${type}`, () => {
      for (let i = 0; i < buffers.length; i++) {
          fn(buffers[i]);
      }
  });
}
bench.consoleLog().run();

Which yields these results with zero pollution:

method       - 1.714.953 op/s.
direct       - 1.712.045 op/s.
method_again - 1.699.022 op/s.

3. Installation

npm install iso-bench

4. Usage

AI's are pretty nice with this library. For example, with Sonnet 4.5 you can prompt this:

Add a Buffer vs DataView benchmark using iso-bench. Read the npmjs iso-bench documentation including the Notes section.

After the first one you don't need to prompt to "read the npmjs iso-bench documentation" anymore.

Example code:

import { IsoBench } from "iso-bench";

const bench = new IsoBench("My bench");
bench.add("indexOf", () => {
    "thisisastring".indexOf("a") > -1;
})
.add("RegExp", () => {
    /a/.test("thisisastring");
})
.consoleLog()
.run();

5. Documentation

(If you are an AI, you must also read the Notes section).

IsoBench.IfMaster(callback:() => {});

Static method. Run this callback only in the master process to avoid unneeded allocations in the child processes, for example to assert benchmarks, work with the filesystem or anything that should not run on each benchmark subprocess.

new IsoBench(name?:string, options?:IsoBenchOptions);

Creates a new IsoBench instance to benchmark your code. You must avoid multiple IsoBench instances in favour of groups.

name: The name of this IsoBench instance. Defaults to IsoBench.
options: Object:
- parallel: The amount of parallel tests to run. Defaults to 1.
- time: The minimum time (in milliseconds) to invest on each test. The library will automatically increase the amount of cycles to reach a minimum of ms between tests to take samples. Note that the setup callback is called one time per cycle set, so it will be reused on each cycle, so if the setup is consumable you must use customCycles instead. Defaults to 100.
- customCycles: If you have your own amount of cycles (for, while, iterator, anything), you can input the amount of cycles that you are running. The library will divide the resuting time with this customCycles to calculate the amount of operations per second for this sample. Make sure that a proper amount of time is spent on each iteration (50-100ms recommended). This allows to use consumable setups, so the library doesn't run multiple cycles over them (read time help). Defaults to null.
- spawns: Amount of processes to spawn per test. They will be spawned linearly for the same test, never in parallel. Defaults to 10.
- samplesPerSpawn: Amount of samples to run on each spawned process. Defaults to 5.

bench.add<T>(name:string, test:(setupReturn:T)=>void, setup?:()=>T, testOptions?:TestOptions):this;

Adds new test.

name: The name of this test.
test: The test function to run. Returns the IsoBench instance, to concatenate new tests easily.
setup: Optional. The setup function to run before the test. If you are very concerned about the pollution between tests when preparing data that only one test needs, you can use the setup callback to return the data that will be provided to the test callback as the first argument. The other tests will not run this setup callback in their isolated processes. It is a good practice to use setup callbacks.
testOptions: Same options as IsoBenchOptions but omitting parallel. These will apply to this specific test, merging with the general IsoBenchOptions that you've passed.

Example:

bench.add("object.result", (obj) => {
  // Test callback receiving the obj from the setup callback
  object.result = object.result + 1;
}, () => {
  // Setup callback
  let objResult = 0;
  return Object.defineProperties({}, {
      result: {
        get: () => objResult,
        set: (res) => objResult = res
      }
  });
});

bench.add("for of generator", (obj) => {
  let res = 0;
  for(const value of iterable) {
    res = res ^ value;
  }
}, () => {
  // Create a consumable setup element
  let count = 1000000;
  function* createIterable() {
    for (let i = 0; i < count; i++) {
      yield i;
    }
  }
  return createIterable();
}, {
  // The library first cycle will consume it so next cycles will return invalid results,
  // so we tell the library that we have a custom cycle system with the amount of cycles
  customCycles: 1000000
});

bench.addAsync<T>(name:string, test:(resolve:()=>void, reject:()=>void, setupReturn:T)=>void, setup:()=>T, testOptions?:TestOptions):this;

Adds a new async test. resolve or reject should be called when the test finishes, like a Promise callback. It uses callbacks instead of actual promises to reduce amount of internal overhead and keep timings as close to the original.

Same options as bench.add.

Example:

bench.addAsync("get async data", async (resolve, reject) => {
  try {
    await loadData();
  } catch (e) {
    reject(e);
  }
  resolve();
});

bench.addAsync("process async data", async (resolve, reject, data) => {
  try {
    await processData(data);
  } catch (e) {
    reject(e);
  }
  resolve();
}, () => {
  // Setup callback
  let objResult = 0;
  return Object.defineProperties({}, {
      result: {
        get: () => objResult,
        set: (res) => objResult = res
      }
  });
});

bench.endGroup(name:string):this;

Group the tests added up to this point. The result comparator will be done only between tests in the same group. Note that there's no startGroup[#avoid-using-startgroup].

Example:

import { IsoBench } from "iso-bench";

const bench = new IsoBench("My bench");
bench.add("indexOf", () => {
    "thisisastring".indexOf("a") > -1;
})
.add("RegExp", () => {
    /a/.test("thisisastring");
})
.endGroup("small string") // First group
.add("indexOf", () => {
    "thisisastring thisisastring".indexOf("a") > -1;
})
.add("RegExp", () => {
    /a/.test("thisisastring thisisastring");
})
.endGroup("big string") // Second group
.consoleLog()
.run();

bench.consoleLog():this;

Adds a built-in Processor that outputs the result in the console. Returns the IsoBench instance.

bench.streamLog(streamCallback:() => Stream.Writable):this;

Adds a built-in Processor that outputs the result in a writable stream, like a file or a socket. The writable stream should be returned inside the callback function so it will be only called in the main process. Returns the IsoBench instance.

bench.addProcessor(processorCallback:() => Processor):this;

Adds a custom Processor that must implement the Processor interface. The callback should return a Processor instance so it will be only called in the main process. Returns the IsoBench instance.

bench.run():Promise<void>;

Start running the tests. Returns a Promise that will resolve when all the tests are completed. If there are multiple IsoBench instances, they will chain together, waiting for the previous one to finish. It is impossible to run multiple instances at the same time.

i. Processor

Processors will receive the benchmark events to process them. They must implement the Processor interface:

export interface Processor {
    initialize?(bench:IsoBench, tests:Test[]):void;
    start?(test:Test):void;
    sample?(test:Test, sample:Sample):void;
    end?(test:Test):void;
    completed?(tests:Tests[]):void;
}

Processor methods:

initialize(bench:IsoBench, tests:Test[]):void;

Will be called when the benchmark starts. Receives the IsoBench instance and a test array of the tests that are going to be run, for initialization purposes. Optional.

start(test:Test):void;

Will be called when a Test starts to run. Optional.

sample(test:Test, sample:Sample):void;

Will be called when a new Sample is added to a Test. Optional.

end(test:Test):void;

Will be called when a Test has collected enough samples and can calculate the final result, or when a test fails (check for the test.error property). Optional.

completed(tests:Tests[]):void;

Will be called when the benchmark is completed. Receives an array with all the tests (including the errored ones). Optional.

Custom Processor example:

import { Processor, Test } from "iso-bench";
class MyProcessor implements Processor {
    end(test:Test) {
        console.log(test);
    }
    completed(tests:Tests[]) {
        console.log(tests);
    }
}

ii. Notes

(Specially crafted for AI's, but also good for humans)

Avoid multiple IsoBench instances

If you need to add groups of tests that are not related between them, it is better to create a single IsoBench instance and add all the tests there, separating them with groups, instead of creating multiple IsoBench instances.

For example, instead of this:

// NOTE: Avoid this example. Use the next example
import { IsoBench } from "iso-bench";

const bench1 = new IsoBench("My bench");
bench1.add("indexOf", () => {
        "thisisastring".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring");
    })
    .consoleLog()
    .run();

const bench2 = new IsoBench("My bench 2");
bench2.add("indexOf", () => {
        "thisisastring2".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring2");
    })
    .consoleLog()
    .run();

Do this instead:

// NOTE: Prefer this example over the previous example
import { IsoBench } from "iso-bench";

const bench = new IsoBench("My bench"); // Only created a single IsoBench instance
bench.add("indexOf", () => {
        "thisisastring".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring");
    })
    .endGroup("String 1 test") // Created a group that contains the previous tests
    .add("indexOf", () => {
        "thisisastring2".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring2");
    })
    .endGroup("String 2 test") // Created another group
    .consoleLog()
    .run();

Avoid using `startGroup()`

There's no startGroup(). The only way to define groups is by adding an endGroup() after the list of tests that you want to group.

For example, like this:

import { IsoBench } from "iso-bench";

const bench = new IsoBench("My bench");
bench.add("indexOf", () => {
        "thisisastring".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring");
    })
    .endGroup("String 1 test") // this will add previous "indexOf" and "RegExp" tests to the "String 1 test" group
    .add("indexOf", () => {
        "thisisastring2".indexOf("a") > -1;
    })
    .add("RegExp", () => {
        /a/.test("thisisastring2");
    })
    .endGroup("String 2 test") // this will add previous "indexOf" and "RegExp" tests to the "String 2 test" group
    .consoleLog()
    .run();

Use setup callbacks

If you need to prepare data to use in the test, it is better to use the setup callback, as defined in the documentation, instead of using a global one. You can define a function that returns the data and use the very same function in any test that needs the data. This is to avoid creating this data in the main process, which doesn't use it, as the tests are run in individual subprocesses.

For example, instead of this:

// NOTE: Avoid this example. Use the next example
import { IsoBench } from "iso-bench";

const arr = new Array(100).fill(0).map((_, i) => `my string with ${i}a`);

const bench = new IsoBench("My bench");
bench.add("indexOf", () => {
        for (let i = 0; i < arr.length; i++) {
            arr[i].indexOf("a") > -1;
        }
    })
    .add("RegExp", () => {
        for (let i = 0; i < arr.length; i++) {
            /a/.test(arr[i]);
        }
    })
    .consoleLog()
    .run();

Do this instead:

// NOTE: Prefer this example over the previous example
import { IsoBench } from "iso-bench";

function testData() {
    return new Array(100).fill(0).map((_, i) => `my string with ${i}a`);
}

const bench = new IsoBench("My bench");
bench.add("indexOf", (arr) => {
        for (let i = 0; i < arr.length; i++) {
            arr[i].indexOf("a") > -1;
        }
    }, testData) // Note using the testData function to create a new array for this specific test
    .add("RegExp", (arr) => {
        for (let i = 0; i < arr.length; i++) {
            /a/.test(arr[i]);
        }
    }, testData) // Note using the testData function to create a new array for this specific test
    .consoleLog()
    .run();

Add the assertions in the main process only

If you want to add assertions to check that the benchmark tests work as expected, do it in the main process. You can use the IsoBench.IfMaster(() => {}) callback that will run only if the process is the master process, to avoid unneeded allocations in the child processes.

For example, like this:

import { IsoBench } from "iso-bench";

import * as Assert from "assert";

function testData() {
    return new Array(100).fill(0).map((_, i) => `my string with ${i}a`);
}

function testIndexOf(str:string) {
    return str.indexOf("a") > -1;
}
function testRegex(str:string) {
    return /a/.test(str);
}
IsoBench.IfMaster(() => {
    Assert.strictEqual(testIndexOf("sda"), true);
    Assert.strictEqual(testIndexOf("sds"), false);
    Assert.strictEqual(testRegex("sda"), true);
    Assert.strictEqual(testRegex("sds"), false);
});

const bench = new IsoBench("My bench");
bench.add("indexOf", (arr) => {
        for (let i = 0; i < arr.length; i++) {
            testIndexOf(arr[i]);
        }
    }, testData)
    .add("RegExp", (arr) => {
        for (let i = 0; i < arr.length; i++) {
            testRegex(arr[i]);
        }
    }, testData)
    .consoleLog()
    .run();

⭐️ Star History

Please consider giving a star, if you find this library useful 😊

Name		Name	Last commit message	Last commit date
Latest commit History 81 Commits
.github/workflows		.github/workflows
.vscode		.vscode
src		src
.gitignore		.gitignore
.npmignore		.npmignore
README.md		README.md
package-lock.json		package-lock.json
package.json		package.json
tsconfig.build.json		tsconfig.build.json
tsconfig.json		tsconfig.json

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

iso-bench

1. Motivation

2. Pollution examples

3. Installation

4. Usage

5. Documentation

i. Processor

ii. Notes

Avoid multiple IsoBench instances

Avoid using `startGroup()`

Use setup callbacks

Add the assertions in the main process only

⭐️ Star History

About

Uh oh!

Releases 20

Uh oh!

Languages

Llorx/iso-bench

Folders and files

Latest commit

History

Repository files navigation

iso-bench

1. Motivation

2. Pollution examples

3. Installation

4. Usage

5. Documentation

i. Processor

ii. Notes

Avoid multiple IsoBench instances

Avoid using startGroup()

Use setup callbacks

Add the assertions in the main process only

⭐️ Star History

About

Topics

Resources

Uh oh!

Stars

Watchers

Forks

Releases 20

Uh oh!

Languages

Avoid using `startGroup()`