worker_threads: worker handles not cleaned up in async_hooks API #26535

'use strict';

const threads = require('worker_threads');

if (!threads.isMainThread) {
  console.log('Thread: ' + threads.threadId);
  return;
}

const hooks = require('async_hooks');

async function spawn(file) {
  const worker = new threads.Worker(file);
  return new Promise((resolve, reject) => {
    worker.on('exit', resolve);
  });
}

async function wait(ms) {
  return new Promise(cb => setTimeout(cb, ms));
}

(async () => {
  const active = new Map();

  const hook = hooks.createHook({
    init(id, type) {
      if (type === 'WORKER')
        active.set(id, type);
    },
    destroy(id) {
      active.delete(id);
    }
  });

  hook.enable();

  for (let i = 0; i < 10; i++)
    await spawn(__filename);

  await wait(1000);

  hook.disable();

  await wait(1000);

  console.log(active);
})();