التزامن المحدود وخيوط العمل

import { Worker, isMainThread, parentPort, workerData } from 'node:worker_threads';
import { once } from 'node:events';
if (isMainThread) {
  const worker = new Worker(new URL(import.meta.url), { workerData: 100 });
  const exited = once(worker, 'exit');
  const [answer] = await once(worker, 'message');
  const [code] = await exited;
  if (code !== 0) throw new Error('Worker failed');
  console.log(answer);
} else {
  let sum = 0;
  for (let i = 1; i <= workerData; i++) sum += i;
  parentPort.postMessage(sum);
}

5050

يجمع عامل الأعداد من1 إلى100 ثم يخرج. يوضح العمل الصغير الرسائل ولا يدعي أن بدء عامل يسرعه.

import { setTimeout as delay } from 'node:timers/promises';
const input = [1, 2, 3, 4];
const output = new Array(input.length);
let next = 0;
async function worker() {
  while (next < input.length) {
    const index = next++;
    await delay(1);
    output[index] = input[index] * 2;
  }
}
await Promise.all([worker(), worker()]);
console.log(output.join(','));

2,4,6,8

تنشط عمليتان غير متزامنتين كحد أقصى. يُحجز المؤشر قبل await فلا يتكرر توزيعه داخل العازل.