Ein Artikel über Multi-Processing und Multi-Threading von Nodes
青灯夜游
Freigeben： 2022-02-28 19:47:38
nach vorne
3879 Leute haben es durchsucht
Dieser Artikel wird Ihnen helfen, node.js zu verstehen, Multiprozess und Multithreading in node einzuführen und Multiprozess und Multithread zu vergleichen. Ich hoffe, dass er für alle hilfreich ist!
Multiprozess und Multithreading in node.js
In node.js erfolgt die Ausführung von Javascript-Code Single-Threaded, Node selbst ist jedoch tatsächlich Multi-Threaded.
Knoten selbst ist in drei Schichten unterteilt
Die erste Schicht, Node.js Standardbibliothek, dieser Teil wird von Javascript geschrieben, also der API, die wir während der Verwendung direkt aufrufen können, im Quellcode Sie können es im lib-Verzeichnis sehen.
Die zweite Schicht, Knotenbindungen, ist der Schlüssel zur Kommunikation zwischen Javascript und dem zugrunde liegenden C/C++. Ersteres ruft letzteres über Bindungen auf und tauscht Daten untereinander aus. Es ist die Brücke zwischen der ersten Schicht und die dritte Schicht.
Die dritte Schicht ist der Schlüssel zur Unterstützung des Betriebs von Node.js. Sie wird von C/C++ implementiert und ist ein Teil der zugrunde liegenden Logik, die von Node implementiert wird.
Unter anderem stellt die dritte Schicht von Libuv Node.js plattformübergreifende, Thread-Pools, Ereignispools, asynchrone E/A und andere Funktionen zur Verfügung, was der Schlüssel zur Leistungsfähigkeit von Node.js ist. Da Libuv einen Ereignisschleifenmechanismus bereitstellt, blockiert JavaScript die E/A-Verarbeitung nicht. Wenn wir Knoten zum Erstellen von Webdiensten verwenden, müssen wir uns daher keine Sorgen über ein übermäßiges E/A-Volumen machen, das dazu führt, dass andere Anforderungen blockiert werden.
Die Ausführung von Nicht-IO-Aufgaben erfolgt jedoch im Hauptthread des Knotens. Es handelt sich um eine Single-Thread-Ausführungsaufgabe, die die Ausführung anderer Codes blockiert .
const Koa = require('koa');
const app = new Koa();
app.use(async (ctx) => {
const url = ctx.request.url;
if (url === '/') {
ctx.body = {name: 'xxx', age: 14}
}
if(url==='/compute'){
let sum=0
for (let i = 0; i <100000000000 ; i++) {
sum+=i
}
ctx.body={sum}
}
})
app.listen(4000, () => {
console.log('http://localhost:4000/ start')
})
Nach dem Login kopieren
Wenn http im obigen Code /compute anfordert, ruft der Knoten die CPU auf, um eine große Anzahl von Berechnungen durchzuführen. Wenn zu diesem Zeitpunkt andere http-Anfragen eingehen, kommt es zu einer Blockierung.
Es gibt zwei Lösungen: Eine besteht darin, children_process oder cluster zu verwenden, um die Multiprozessberechnung zu ermöglichen, die andere darin, worker_thread zu verwenden Aktivieren Sie Multi-Threading-Berechnungen
Multi-Process gegen Multi-thread
compare-Multi-Threading und Multi-Process:
Properties
multi-Process
multi-thread comparison
Datenaustausch ist komplex und erfordert IPC; Daten werden getrennt und die Synchronisierung ist einfach. Da Prozessdaten gemeinsam genutzt werden, ist der Datenaustausch einfach und die Synchronisierung komplex. Jeder hat seine eigenen Vorzüge CPU und Speicher
belegt viel Speicher, komplexes Umschalten und geringe CPU-Auslastung
Beansprucht weniger Speicher, einfaches Umschalten, hohe CPU-Auslastung
Multithreading ist besser
Zerstören, Umschalten
Erstellen, zerstören , komplex wechseln, langsam
Erstellen, zerstören, wechseln einfach, schnell
Mehr Threads sind besser
Codierung
Einfaches Codieren und bequemes Debuggen
Komplexes Codieren und Debuggen
Komplexes Codieren und Debuggen
Zuverlässigkeit
Prozesse laufen unabhängig voneinander ab und beeinflussen sich nicht gegenseitig.
Threads atmen und teilen das gleiche Schicksal.
Multiprozess ist besser
Kann nur für die Multi-Core-Verteilung verwendet werden
Multiprozess ist besser
Verwenden Sie Multithreading, um das oben genannte Codeberechnungsproblem zu lösen:
//api.js
const Koa = require('koa');
const app = new Koa();
const {Worker} = require('worker_threads')
app.use(async (ctx) => {
const url = ctx.request.url;
if (url === '/') {
ctx.body = {name: 'xxx', age: 14}
}
if (url === '/compute') {
const sum = await new Promise(resolve => {
const worker = new Worker(__dirname+'/compute.js')
//接收信息
worker.on('message', data => {
resolve(data)
})
})
ctx.body = {sum}
}
})
app.listen(4000, () => {
console.log('http://localhost:4000/ start')
})
//computer.js
const {parentPort}=require('worker_threads')
let sum=0
for (let i = 0; i <1000000000 ; i++) {
sum+=i
}
//发送信息
parentPort.postMessage(sum)
Weitere Node-bezogene Informationen. Weitere Informationen finden Sie unter:
nodejs-Tutorial
!
Das obige ist der detaillierte Inhalt vonEin Artikel über Multi-Processing und Multi-Threading von Nodes. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
