Introducing NodeJS Multithreading Library - a high-performance, lightweight library designed to make multithreading in NodeJS simple and easy. With this library, you can take advantage of the power of multithreading to improve the performance of your Node
npm install multi-threadsmulti-threads.
bash
npm install multi-threads
`
Usage
This code demonstrates how to use the multi-threads module to split a task into multiple threads to speed up the execution of the task.
`javascript
import thread from 'multi-threads';
//split task thread
async function threadTask(){
let count=this.start;
while(count
}
return count;
}
async function thread_splitter(){
console.time('Required Time');
const THREAD_USE=4;
const TOTOAL_COUNT=20E+9; //20 billion
const threads=[];
for(let i=0;i
threads.push(thread.open(threadTask,{start:0,end:TOTOAL_COUNT/THREAD_USE}));
}
const counts=await Promise.all(threads); //await to finish the all thread process
let total_count=counts.reduce( (accumulator, currentValue) => accumulator + currentValue,0); //summing the counts
console.log('Counted:',total_count);
console.timeEnd('Required Time');
}
thread_splitter();
`
The threadTask function is a task that will be executed in each thread. The task counts from this.start to this.end in a loop. The this keyword in the threadTask function refers to the context object that was passed when the thread was created using thread.open. The properties of the context object can be accessed using this.property_name syntax.
The thread_splitter function is responsible for creating the threads and running the task in them. It uses THREAD_USE (4) to determine the number of threads to create. The TOTOAL_COUNT is set to 20 billion and is used to determine the size of the task each thread will be responsible for by dividing TOTOAL_COUNT by THREAD_USE.
For each iteration of the loop, a new thread is created using the thread.open method, and the threadTask function is passed to it along with the start and end parameters to determine the range of numbers the thread will be responsible for counting. The created threads are stored in the threads array.
Finally, Promise.all is used to wait for all the threads to finish executing. The counts array stores the result of each thread. The total_count variable is then calculated by summing the values in the counts array using the reduce method.
The total count and the time required to complete the task are then logged to the console using console.log and console.timeEnd`, respectively.