worker_threads 导致应用卡死

[Cweili]

官方例子中，添加 worker_threads 调用 Worker 后，会导致整个应用卡死，PC 与 Android 均能复现

[chexiongsheng]

直接贴下测试代码

[Cweili]

index.js

const { Worker } = require('worker_threads')
const worker = new Worker(path.join(__dirname, 'worker.js'), {
  workerData: { filePath: path.join(__dirname, 'index.js') }
})
worker.on('message', (message) => {
  console.log('Worker message received: ' + JSON.stringify(message));
  
  if (message.type === 'start') {
    console.log('MD5 calculation started');
  } else if (message.type === 'result') {
    console.log(message.md5);
  } else if (message.type === 'error') {
    console.error(new Error(message.error));
  }
});

worker.on('error', (err) => {
  console.log('Worker error: ' + err.message);
});

worker.on('exit', (code) => {
  if (code !== 0) {
    console.error(new Error(`Worker stopped with exit code ${code}`));
  }
});

worker.js

const { parentPort, workerData } = require('worker_threads');
const crypto = require('crypto');
const { createReadStream } = require('fs');

function calculateMD5(filePath) {
  return new Promise((resolve, reject) => {
    const hash = crypto.createHash('md5');
    const stream = createReadStream(filePath);
    stream.on('data', (chunk) => hash.update(chunk));
    stream.on('end', () => resolve(hash.digest('hex')));
    stream.on('error', (err) => reject(err));
  });
}

;(async () => {
  try {
    const md5 = await calculateMD5(workerData.filePath);
    parentPort.postMessage({
      type: 'result',
      md5
    });
  } catch (err) {
    parentPort.postMessage({
      type: 'error',
      error: err.message
    });
  }
})();

parentPort.postMessage({
  type: 'start'
});