淺談Nodejs如何進行多執行緒處理

本篇文章跟大家介紹一下Nodejs進行多執行緒處理的方法。有一定的參考價值，有需要的朋友可以參考一下，希望對大家有幫助。

Threads à gogo 是nodejs 的原生模組，使用這個模組可以讓nodejs 具備多執行緒處理功能。 【推薦學習：《nodejs 教學》】

安裝方法

npm install threads_a_gogo

下載測試原始碼

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

匯入模組程式碼

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

為什麼要用多執行緒？

1.平行執行，不需排隊，快速。

2.公平性，所有執行緒統一優先權。

3.完整利用資源，讓更多的CPU參與task的處理。

4.所有執行緒共用一個儲存位址。

實例

我們先來做一個簡單的測試，用斐波那契數組來看一下，加入了多執行緒的node有多麼的強悍：（測試機器為4CPU）沒有使用TAGG的正常情況，異步也幫不了我們應對cpu密集型任務

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();
})

我們模擬了8個異步的行為，測試用的node v0.8.16版本，所以process.nextTick還是非同步方法。最後我們輸出結果為：

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

接下來我們使用TAGG模組來測試同樣的執行8次斐波那契數組計算，看看成績如何？

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);

最重的結果：

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

相比不使用多執行緒模型的node，使用了TAGG模組之後，我們在4CPU伺服器上的測試結果要快上一倍還不止。

TAGG模組還有其他更多的功能，例如事件觸發，平滑退出，查看線程工作狀態等等，總之TAGG模組給node注入了新的活力，讓node一直飽受詬病的處理cpu密集任務問題得到了一個妥善的解決，就算你不擅長c 程式碼，也能夠輕鬆寫出多執行緒的真正的非阻塞 node程序了。 　　

#更多程式相關知識，請造訪：程式設計教學！ ！

以上是淺談Nodejs如何進行多執行緒處理的詳細內容。更多資訊請關注PHP中文網其他相關文章！