如何在 nodejs 中使用工作线程？

Question

我有以下代码，其中传递的数组长度太高并且处理每个数组元素需要一秒钟的时间，我如何在以下情况下使用工作线程？

function processData(arr){
    var result = [];
    for(var i = 0; i < arr.length; i++){
        result.push(process(arr[i]));
    }
    return result;
}

function process() {
    // some code here takes 1 second to execute
}

processData(arr);

Answer 1

你可以使用workerpool npm 包在工作线程中完成你的长时间处理工作，像这样

const workerpool = require('workerpool');

const pool =  workerpool.pool();

const arr = [...] // Large Data set which is to be processed

new Promise((resolve, reject) => {
  pool.exec(
    arr => {
      var result = [];
      for(var i = 0; i < arr.length; i++){
        /* 
        Do the long processing on data 
        */
        const processedData = a[i];
        result.push(processedData);
      }
      return result;
    },
    [arr]
  )
  .then(result => resolve(result))
  .catch(err => reject(err));
});