Add worker termination test

Author: nsavoire

ts/test/test-worker-threads.ts

@@ -1,6 +1,7 @@
 // eslint-disable-next-line node/no-unsupported-features/node-builtins
 import {execFile} from 'child_process';
 import {promisify} from 'util';
+import {Worker} from 'worker_threads';
 
 const exec = promisify(execFile);
 
@@ -11,4 +12,34 @@ describe('Worker Threads', () => {
     const nbWorkers = 2;
     return exec('node', ['./out/test/worker.js', String(nbWorkers)]);
   });
+
+  it('should not crash when worker is terminated', async function () {
+    this.timeout(30000);
+    const nruns = 5;
+    const concurrentWorkers = 20;
+    for (let i = 0; i < nruns; i++) {
+      const workers = [];
+      for (let j = 0; j < concurrentWorkers; j++) {
+        const worker = new Worker('./out/test/worker2.js');
+        worker.postMessage('hello');
+
+        worker.on('message', () => {
+          worker.terminate();
+        });
+
+        workers.push(
+          new Promise<void>((resolve, reject) => {
+            worker.on('exit', exitCode => {
+              if (exitCode === 1) {
+                resolve();
+              } else {
+                reject(new Error('Worker exited with code 0'));
+              }
+            });
+          })
+        );
+      }
+      await Promise.all(workers);
+    }
+  });
 });

ts/test/worker2.ts

@@ -0,0 +1,23 @@
+import {parentPort} from 'node:worker_threads';
+import {time} from '../src/index';
+
+const delay = (ms: number) => new Promise(res => setTimeout(res, ms));
+
+const DURATION_MILLIS = 1000;
+const INTERVAL_MICROS = 10000;
+const withContexts =
+  process.platform === 'darwin' || process.platform === 'linux';
+
+time.start({
+  durationMillis: DURATION_MILLIS,
+  intervalMicros: INTERVAL_MICROS,
+  withContexts: withContexts,
+  collectCpuTime: withContexts,
+  collectAsyncId: false,
+});
+
+parentPort?.on('message', () => {
+  delay(50).then(() => {
+    parentPort?.postMessage('hello');
+  });
+});