кто знает разницу между for await of и for of?

if (cluster.isMaster) {
   for(let i = 0; i < cpuCount; i++) {
       //cluster.schedulingPolicy = cluster.SCHED_NONE;
       cluster.fork();
   }
   function chunkArrayDrob(myArray, chunk_size){
       let results = [];
       while (myArray.length) {
           results.push(myArray.splice(0, chunk_size));
       }
       return results;
   }
   let readLinesCount;
   let lastPieceOfData = '';
   read.on('data', (chunk) => {
       const chunkArray = (lastPieceOfData + chunk).split('\n');
       lastPieceOfData = chunkArray[chunkArray.length - 1];
       const workerData = chunkArray.slice(0, -1);
       readLinesCount = readLinesCount + chunkArray.length - 1;
       //worker.send(workerData.length);
       const step = Math.ceil(parseInt(workerData.length) / cpuCount);
       let result = chunkArrayDrob(workerData, step);
       for(let i = 0; i < cpuCount; i++) {
           const worker = cluster.fork();
           worker.send(result[i+1]);
       }

   });

Очень давно юзал эту либу, но помню что там можно было переключаться между листами, ищи что-то sheet

ты в самом начале создал cpuCount ворекров, потом на каждый чанк создаёшь ещё столько же воркеров??

ну не совсем я хочу на каждом чанке отправлять данные воркерам

cluster.fork()  создаёт воркера

ну да

ну да

каждому свою

function eachWorker(callback) {
 for (const id in cluster.workers) {
   callback(cluster.workers[id]);
 }
}
eachWorker((worker) => {
 worker.send('big announcement to all workers');
});  
тоесть это решыт проблему создания кучи воркеров в чанках

function eachWorker(callback) {
 for (const id in cluster.workers) {
   callback(cluster.workers[id]);
 }
}
eachWorker((worker) => {
 worker.send('big announcement to all workers');
});  
тоесть это решыт проблему создания кучи воркеров в чанках

вам не нужно создавать воркеров при получаении данных, вам надо только отправить данные воркерам, и как я понимаю не всем, а только одному