Nodejs怎么進(jìn)行多線程處理
這篇文章主要介紹Nodejs怎么進(jìn)行多線程處理，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！
成都創(chuàng)新互聯(lián)公司于2013年創(chuàng)立，先為常州等服務(wù)建站，常州等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為常州企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問(wèn)題。
Threads à gogo 是nodejs 的原生模塊，使用這個(gè)模塊可以讓nodejs 具備多線程處理功能?！就扑]學(xué)習(xí)：《nodejs 教程》】
安裝方法
npm install threads_a_gogo
下載測(cè)試源碼
git clone http://github.com/xk/node-threads-a-gogo.git
導(dǎo)入模塊代碼
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文件 執(zhí)行boot(),發(fā)送event go，并且監(jiān)聽(tīng) event 事件 cb(err,result)
thread_pool.load('path') //pool中的任意（.all 為全部）thread 讀取path file
pool.any.eval( program, cb ) //pool中的任意（.all 為全部）thread執(zhí)行program為什么要用多線程？
1.平行執(zhí)行，無(wú)需排隊(duì)，快速。
2.公平性，所有線程統(tǒng)一優(yōu)先級(jí)。
3.完整利用資源，讓更多的CPU參與task的處理。
4.所有線程共用一個(gè)儲(chǔ)存地址。
實(shí)例
我們先來(lái)做一個(gè)簡(jiǎn)單的測(cè)試，用斐波那契數(shù)組來(lái)看一下，加入了多線程的node有多么的強(qiáng)悍：（測(cè)試機(jī)器為4CPU）沒(méi)有使用TAGG的正常情況，異步也幫不了我們應(yīng)對(duì)cpu密集型任務(wù)
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個(gè)異步的行為，測(cè)試用的node v0.8.16版本，所以process.nextTick還是異步方法。最后我們輸出結(jié)果為：
165580141 165580141 165580141 165580141 165580141 165580141 165580141 165580141 no thread: 23346ms
接下來(lái)我們使用TAGG模塊來(lái)測(cè)試同樣的執(zhí)行8次斐波那契數(shù)組計(jì)算，看看成績(jī)?nèi)绾危?/p>
function fibo (n) {
return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
}
console.time('8 thread');
var numThreads= 8; //創(chuàng)建線程池，最大數(shù)為8
var threadPool= require('threads_a_gogo').createPool(numThreads).all.eval(fibo); //為線程池注冊(cè)程序
var i=8;
var cb = function(err,data){ //注冊(cè)線程執(zhí)行完畢的回調(diào)函數(shù)
console.log(data);
if(!--i){
threadPool.destroy();
console.timeEnd('8 thread');
}
}
threadPool.any.eval('fibo(40)', cb); //開(kāi)始向線程池中執(zhí)行fibo(40)這個(gè)任務(wù)
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);最重的結(jié)果：
165580141 165580141 165580141 165580141 165580141 165580141 165580141 165580141 8 thread: 9510ms
相比不使用多線程模型的node，使用了TAGG模塊之后，我們?cè)?CPU服務(wù)器上的測(cè)試結(jié)果要快上一倍還不止。
TAGG模塊還有其他更多的功能，比如事件觸發(fā)，平滑退出，查看線程工作狀態(tài)等等，總之TAGG模塊給node注入了新的活力，讓node一直飽受詬病的處理cpu密集任務(wù)問(wèn)題得到了一個(gè)妥善的解決，就算你不擅長(zhǎng)c++代碼，也能夠輕松編寫出多線程的真正的非阻塞node程序了。
以上是“Nodejs怎么進(jìn)行多線程處理”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！
文章題目：Nodejs怎么進(jìn)行多線程處理
文章網(wǎng)址：http://m.jiaotiyi.com/article/gijjsj.html