使用node.js并行操作数组的元素？

const async = require('async');

const array = [1, 2, 3, 4, 5];

function processItem(item, callback) {
  // 模拟异步操作
  setTimeout(() => {
    console.log(item);
    callback();
  }, 1000);
}

async.each(array, processItem, (err) => {
  if (err) {
    console.error('Error:', err);
  } else {
    console.log('All items processed');
  }
});

const array = [1, 2, 3, 4, 5];

function processItem(item) {
  return new Promise((resolve) => {
    // 模拟异步操作
    setTimeout(() => {
      console.log(item);
      resolve();
    }, 1000);
  });
}

Promise.all(array.map(processItem))
  .then(() => {
    console.log('All items processed');
  })
  .catch((err) => {
    console.error('Error:', err);
  });

const array = [1, 2, 3, 4, 5];

function processItem(item) {
  return new Promise((resolve) => {
    // 模拟异步操作
    setTimeout(() => {
      console.log(item);
      resolve();
    }, 1000);
  });
}

(async () => {
  const promises = [];
  for (const item of array) {
    promises.push(processItem(item));
  }
  await Promise.all(promises);
  console.log('All items processed');
})();

const { Worker, isMainThread, parentPort, workerData } = require('worker_threads');

if (isMainThread) {
  const array = [1, 2, 3, 4, 5];
  const workers = [];

  for (const item of array) {
    const worker = new Worker(__filename, { workerData: item });
    workers.push(worker);
  }

  let completedWorkers = 0;
  workers.forEach((worker) => {
    worker.on('message', () => {
      completedWorkers++;
      if (completedWorkers === array.length) {
        console.log('All items processed');
      }
    });
  });
} else {
  const item = workerData;
  // 模拟CPU密集型任务
  console.log(item);
  parentPort.postMessage('done');
}