Muduo 多執行緒模型對比

本文主要對比muduo多執行緒模型方案8 和方案9 。

方案8：reactor + thread pool ，有乙個執行緒來充當reactor 接受連線分發事件，將要處理的事件分配給thread pool中的執行緒，由thread pool 來完成事件處理。例項**見：examples/sudoku/server_threadpool.cc

這裡擷取關鍵部分**進行說明。

class

sudokuserver

void

start()

private

:void

onconnection(

const

tcpconnectionptr& conn)

void

onmessage(

const

tcpconnectionptr& conn, buffer* buf, timestamp)

}...}}

bool

processrequest(

const

tcpconnectionptr& conn,

const

string& request)

else

return

goodrequest;

}static

void

solve(

const

tcpconnectionptr& conn,

const

string& puzzle,

const

string& id)

else

}eventloop* loop_;

tcpserver server_;

threadpool threadpool_;

// 注意型別，方案8， reactor + threadpool

intnumthreads_;

timestamp starttime_;

};void

threadpool::start(

intnumthreads) // 建立 thread pool，具體thread 排程這裡暫時不分析

}方案9：main-reactor + subreactors, one loop per thread，有乙個主線程來扮演main-reactor 專門語句 accept 連線，其它執行緒負責讀寫檔案描述符（socket）

class

sudokuserver

void

start()

private

:void

onconnection(

const

tcpconnectionptr& conn)

void

onmessage(

const

tcpconnectionptr& conn, buffer* buf, timestamp)

...}

}bool

processrequest(

const

tcpconnectionptr& conn,

const

string& request)

...}

// 注意這裡沒有型別為threadpool的 threadpool_成員，整個類使用muduo預設執行緒模型的eventloopthreadpool，tcpserver 聚合了eventloopthreadpool

eventloop* loop_;

tcpserver server_;

intnumthreads_;

timestamp starttime_;

};void

tcpserver::setthreadnum(

intnumthreads)

void

tcpserver::start()

if(!acceptor_->listenning())

}void

eventloopthreadpool::start(

const

threadinitcallback& cb) // 開啟執行緒的方式是使用eventloopthread，這個類將eventloop 和 thread 封裝在一起實現 one loop per thread

if(numthreads_ == 0 && cb)

}總結一下，這裡所謂的reactor就是持有poller的結構（稍微有點狹隘，這裡先就這樣理解），poller負責事件監聽和分發。持有eventloop的結構就持有poller。

對於方案8只有乙個類持有eventloop，也就是只建立了乙個eventloop，這個loop就是reactor，其它的thread 是通過threadpool來實現的，因此只有reactor所在的執行緒來完成i/o，其它執行緒用於完成計算任務，所以說這個模型適合於計算密集型而不是i/o密集型。

對於方案9，存在多個reactor，其中main reactor 持有acceptor，專門用於監聽三個半事件中的連線建立，訊息到達和連線斷開以及訊息傳送事件都讓sub reactor來完成。由於main reactor 只關心連線建立事件，能夠適應高併發的io請求，多個subreactor的存在也能兼顧i/o與計算，因此被認為是乙個比較好的方案。

後面還會深入學習muduo網路庫相關的內容，包括reactor結構的簡化，執行緒池的實現，現代c++的編寫方式，使用c++11進行重寫等。現在看來c++11 thread library 提供的介面基本可以替換 posix thread library，雖然底層也許是通過posix thread實現的，畢竟linux核心針對nptl進行過修改。c++11 提供了 thread_local 來描述執行緒區域性儲存，但是沒有pthread_key_create() 提供 destructor那樣的功能，或者遇到需要使用tls的地方轉過來使用posix 提供的介面。

muduo 多執行緒執行緒池 reactor

Muduo 多執行緒模型對比

Muduo 多執行緒模型對比

linux多執行緒網路庫 muduo庫學習

11執行緒多執行緒模型

Muduo 多執行緒模型對比

Muduo 多執行緒模型對比

linux多執行緒網路庫 muduo庫學習

11執行緒 多執行緒模型

相關推薦

11執行緒多執行緒模型