benchmark: switch to spawn intead of fork (#2799)

Author: IvanGoncharov

cspell.json

@@ -32,6 +32,7 @@
     "transpilation",
     "instanceof",
     "flowtype",
+    "noconcurrent",
 
     // Different names used inside tests
     "Skywalker",

package.json

@@ -31,7 +31,7 @@
     "version": "node resources/gen-version.js && npm test && git add src/version.js",
     "fuzzonly": "mocha --full-trace src/**/__tests__/**/*-fuzz.js",
     "changelog": "node resources/gen-changelog.js",
-    "benchmark": "node --noconcurrent_sweeping --expose-gc --predictable ./resources/benchmark.js",
+    "benchmark": "node resources/benchmark.js",
     "test": "npm run lint && npm run check && npm run testonly && npm run prettier:check && npm run check:spelling && npm run build:npm && npm run build:deno && npm run check:integrations",
     "lint": "eslint --cache .",
     "check": "flow check",

resources/benchmark-fork.js

@@ -4,10 +4,10 @@ const os = require('os');
 const fs = require('fs');
 const path = require('path');
 const assert = require('assert');
+const cp = require('child_process');
 
 const { red, green, yellow, cyan, grey } = require('./colors');
 const { exec, rmdirRecursive, readdirRecursive } = require('./utils');
-const { sampleModule } = require('./benchmark-fork');
 
 const NS_PER_SEC = 1e9;
 const LOCAL = 'local';
@@ -312,3 +312,63 @@ if (require.main === module) {
     process.exit(1);
   });
 }
+
+function sampleModule(modulePath) {
+  const sampleCode = `
+    const assert = require('assert');
+
+    assert(global.gc);
+    assert(process.send);
+    const module = require('${modulePath}');
+
+    clock(7, module.measure); // warm up
+    global.gc();
+    process.nextTick(() => {
+      const memBaseline = process.memoryUsage().heapUsed;
+      const clocked = clock(module.count, module.measure);
+      process.send({
+        name: module.name,
+        clocked: clocked / module.count,
+        memUsed: (process.memoryUsage().heapUsed - memBaseline) / module.count,
+      });
+    });
+
+    // Clocks the time taken to execute a test per cycle (secs).
+    function clock(count, fn) {
+      const start = process.hrtime.bigint();
+      for (let i = 0; i < count; ++i) {
+        fn();
+      }
+      return Number(process.hrtime.bigint() - start);
+    }
+  `;
+
+  return new Promise((resolve, reject) => {
+    const child = cp.spawn(
+      process.argv[0],
+      [
+        '--noconcurrent_sweeping',
+        '--predictable',
+        '--expose-gc',
+        '-e',
+        sampleCode,
+      ],
+      {
+        stdio: ['inherit', 'inherit', 'inherit', 'ipc'],
+        env: { NODE_ENV: 'production' },
+      },
+    );
+
+    let message;
+    let error;
+
+    child.on('message', (msg) => (message = msg));
+    child.on('error', (e) => (error = e));
+    child.on('close', () => {
+      if (message) {
+        return resolve(message);
+      }
+      reject(error || new Error('Spawn process closed without error'));
+    });
+  });
+}