You're Invited:Meet the Socket Team at BlackHat and DEF CON in Las Vegas, Aug 4-6.RSVP
Socket
Book a DemoInstallSign in
Socket

multi-threads

Package Overview
Dependencies
Maintainers
1
Versions
9
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

multi-threads - npm Package Compare versions

Comparing version

to
1.0.2

2

package.json
{
"name": "multi-threads",
"version": "1.0.1",
"version": "1.0.2",
"description": "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 NodeJS applications. Whether you're working on a complex server-side application or just need to run multiple tasks simultaneously, this library has got you covered. The library utilizes JavaScript's built-in Worker threads to create multiple threads, each with its own event loop and memory heap. This means you can run multiple independent tasks in parallel without affecting the main thread and blocking the event loop. The library is easy to use and comes with a simple API that makes it easy to create and manage worker threads. It also includes features such as error handling and communication between threads, making it a complete solution for multithreading in NodeJS. With NodeJS Multithreading Library, you can easily speed up your applications, improve their responsiveness, and make them more scalable. So, why wait? Start taking advantage of multithreading in NodeJS today with this library!",

@@ -5,0 +5,0 @@ "main": "./lib/index.js",

@@ -8,3 +8,5 @@ # NodeJS Multithreading Library

To install the package, run the following command in your terminal:
npm install multi-threads
{
npm install multi-threads
}

@@ -15,34 +17,37 @@ ## Usage

import thread from 'multi-threads';
{
import thread from 'multi-threads';
//split task thread
async function threadTask(){
let count=this.start;
while(count<this.end){
count++;
//split task thread
async function threadTask(){
let count=this.start;
while(count<this.end){
count++;
}
return count;
}
return count;
}
async function thread_spliter(){
console.time('Required Time');
async function thread_spliter(){
console.time('Required Time');
const THREAD_USE=4;
const TOTOAL_COUNT=20E+9; //20 billion
const THREAD_USE=4;
const TOTOAL_COUNT=20E+9; //20 billion
const threads=[];
for(let i=0;i<THREAD_USE;i++){
//pass the split task to thread
threads.push(thread.open(threadTask,{start:0,end:TOTOAL_COUNT/THREAD_USE}));
const threads=[];
for(let i=0;i<THREAD_USE;i++){
//pass the split task to thread
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');
}
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_spliter();
}
thread_spliter();

@@ -49,0 +54,0 @@