Eine kurze Diskussion darüber, wie Nodejs die Multithreading-Verarbeitung durchführt

In diesem Artikel erfahren Sie Nodejs, wie Sie eine Multithreading-Verarbeitung durchführen. Es hat einen gewissen Referenzwert. Freunde in Not können sich darauf beziehen. Ich hoffe, es wird für alle hilfreich sein.

Threads à gogo ist ein natives Modul von NodeJS. Durch die Verwendung dieses Moduls können NodeJS über Multithread-Verarbeitungsfunktionen verfügen. [Empfohlenes Lernen: „nodejs-Tutorial“]

Installationsmethode

npm install threads_a_gogo

Testquellcode herunterladen

git clone http://github.com/xk/node-threads-a-gogo.git　　

Modulcode importieren

var tagg= require('threads_a_gogo');

API

tagg= require('threads_a_gogo') //生成tagg object
var thread = tagg.create( /* no arguments */ ) //生成 thread object
var thread_pool = tagg.createPool( numberOfThreads ) //生成 thread pool
thread.load("boot.js").eval("boot()").emit("go").on("event", cb) //thread读取boot.js文件 执行boot(),发送event go，并且监听 event 事件 cb(err,result)
thread_pool.load('path') //pool中的任意（.all 为全部）thread 读取path file
pool.any.eval( program, cb ) //pool中的任意（.all 为全部）thread执行program

Warum multi -Einfädeln?

1. Parallele Ausführung, keine Warteschlange erforderlich, schnell.

2. Fairerweise haben alle Threads einheitliche Priorität.

3. Nutzen Sie die Ressourcen voll aus und lassen Sie mehr CPUs an der Aufgabenverarbeitung teilnehmen.

4. Alle Threads teilen sich eine Speicheradresse.

Beispiel

Lassen Sie uns zunächst einen einfachen Test durchführen. Verwenden Sie das Fibonacci-Array, um zu sehen, wie leistungsfähig der Knoten mit Multithreading ist: (Die Testmaschine hat 4 CPUs) Es funktioniert normal, ohne TAGG zu verwenden. In dieser Situation kann asynchron Hilft uns nicht bei der Bewältigung CPU-intensiver Aufgaben

function fibo (n) {
return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
}
var n=8
function back(){
if(!--n) return console.timeEnd('no thread');
}
console.time('no thread');

process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})

process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})
process.nextTick(function(){
console.log(fibo (40));
back();
})

Wir haben 8 asynchrone Verhaltensweisen simuliert und die Version node v0.8.16 wurde zum Testen verwendet, daher ist process.nextTick immer noch eine asynchrone Methode. Schließlich lautet unser Ausgabeergebnis:

165580141
165580141
165580141
165580141
165580141
165580141
165580141
165580141
no thread: 23346ms

Als nächstes verwenden wir das TAGG-Modul, um die gleiche Ausführung von 8 Fibonacci-Array-Berechnungen zu testen und zu sehen, was die Ergebnisse sind?

function fibo (n) {
return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
}
console.time('8 thread');
var numThreads= 8; //创建线程池，最大数为8
var threadPool= require('threads_a_gogo').createPool(numThreads).all.eval(fibo); //为线程池注册程序
var i=8;
var cb = function(err,data){ //注册线程执行完毕的回调函数
console.log(data);
if(!--i){
threadPool.destroy();
console.timeEnd('8 thread');
}
}
threadPool.any.eval('fibo(40)', cb); //开始向线程池中执行fibo(40)这个任务
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);
 
threadPool.any.eval('fibo(40)', cb);

Das wichtigste Ergebnis:

165580141
165580141
165580141
165580141
165580141
165580141
165580141
165580141
8 thread: 9510ms

Im Vergleich zu dem Knoten, der das Multithreading-Modell nicht verwendet, sind unsere Testergebnisse auf dem 4CPU-Server nach Verwendung des TAGG-Moduls mehr als doppelt so schnell. Das

TAGG-Modul verfügt über viele weitere Funktionen, wie z. B. Ereignisauslösung, reibungsloses Beenden, Überprüfen des Thread-Arbeitsstatus usw. Kurz gesagt, das TAGG-Modul verleiht node neue Vitalität und macht nodes kritisierte Handhabung zum Problem der CPU- Intensive Aufgaben wurden ordnungsgemäß gelöst. Auch wenn Sie nicht gut mit c++-Code umgehen können, können Sie problemlos multithreadige und wirklich nicht blockierende node-Programme schreiben. 　

Weitere Kenntnisse zum Thema Programmierung finden Sie unter: Programmierunterricht! !

Das obige ist der detaillierte Inhalt vonEine kurze Diskussion darüber, wie Nodejs die Multithreading-Verarbeitung durchführt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!