LINUX 線(xiàn)程池源代碼:Lock.cpp : 鎖的操作 , 讀鎖可以并發(fā) , 寫(xiě)鎖獨(dú)占.
Queue.h : 隊(duì)列的封裝 , 隊(duì)列的讀和寫(xiě)都加了鎖的保護(hù).
Socket.cpp : 套接口的簡(jiǎn)單封裝.
Thread.cpp : 線(xiàn)程的封裝實(shí)現(xiàn)了些簡(jiǎn)單的線(xiàn)程停止,運(yùn)行等功能 , 啟動(dòng)別的線(xiàn)程的時(shí)候需要繼承次類(lèi).
Worker.cpp : 用戶(hù)接口類(lèi) , 用戶(hù)需繼承此類(lèi)。
ListenThread.cpp(繼承Thread.cpp) : 服務(wù)器監(jiān)聽(tīng)線(xiàn)程.如果有客戶(hù)端連接通知ThreadPool類(lèi),由ThreadPool類(lèi)進(jìn)行任務(wù)分派.
TaskThread.cpp(繼承Thread.cpp) : 具體任務(wù)類(lèi),負(fù)責(zé)接受客戶(hù)端發(fā)送數(shù)據(jù).
ThreadPool.cpp (繼承Thread.cpp) : 線(xiàn)程池類(lèi)負(fù)責(zé)啟動(dòng)別的線(xiàn)程 , 并且進(jìn)行線(xiàn)程調(diào)度。首先啟動(dòng)ListenThread.cpp類(lèi),如果有客戶(hù)端
連接ListenThread.cpp類(lèi)發(fā)送信號(hào)通知ThreadPool.cpp類(lèi),收到信號(hào)再分配給TaskThread.cpp類(lèi),進(jìn)行處理。如果沒(méi)有空閑任務(wù)類(lèi),動(dòng)態(tài)再
標(biāo)簽:
Socket
LINUX
Queue
Lock
上傳時(shí)間:
2014-06-11
上傳用戶(hù):wff