GroupedMultithread.js

gistfile1.js

const { fork } = require('child_process');

const data = [
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  },
  {
    email: "[email protected]",
    password: '123'
  }
];

const parseMultiThreadData = (data, thread) => {
  let groupedProccess = [];
  const numOfProcess = data.length / thread;

  let a = thread;
  for (let i = 0; i < numOfProcess; i++) {
    console.log(`===[ Proses ke ${i + 1} ]===`);
    console.log(data.slice(i * thread, a));
    groupedProccess.push(data.slice(i * thread, a));
    a += thread;
  }

  // return groupedProccess;
}

// const startMultiThread = (parsedData) => {
//   parsedData.forEach(data => {
//     data.forEach(item => {
//       const process = fork('./automation.js');
//       process.send(item);
//       process.on('message', (message) => {
//         console.info(message);
//       });
//     })
//   })
// }

parseMultiThreadData(data, 4);

// (async () => {
//   const parsedData = await parseMultiThreadData(data, 4);
//   await startMultiThread(parsedData)
// })