• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            大龍的博客

            常用鏈接

            統計

            最新評論

            IOCP與線程 -------- 轉

            IOCP與線程

            author : Kevin Lynx

             

            什么是完成包?

            完成包,即IO Completion Packet,是指異步IO操作完畢后OS提交給應用層的通知包。IOCP維護了一個IO操作結果隊列,里面
            保存著各種完成包。應用層調用GQCS(也就是GetQueueCompletionStatus)函數獲取這些完成包。

            最大并發線程數

            在一個典型的IOCP程序里,會有一些線程調用GQCS去獲取IO操作結果。最大并發線程數指定在同一時刻處理完成包的線程數目。
            該參數在調用CreateIoCompletionPort時由NumberOfConcurrentThreads指定。

            工作者線程

            工作者線程一般指的就是調用GQCS函數的線程。要注意的是,工作者線程數和最大并發線程數并不是同一回事(見下文)。工作者
            線程由應用層顯示創建(_beginthreadex 之類)。工作者線程通常是一個循環,會不斷地GQCS到完成包,然后處理完成包。

            調度過程

            工作者線程以是否阻塞分為兩種狀態:運行狀態和等待狀態。當線程做一些阻塞操作時(線程同步,甚至GQCS空的完成隊列),線程
            處于等待狀態;否則,線程處于運行狀態。

            另一方面,OS會始終保持某一時刻處于運行狀態的線程數小于最大并發線程數。每一個調用GQCS函數的線程OS實際上都會進行記錄,
            當完成隊列里有完成包時,OS會首先檢查當前處于運行狀態的工作線程數是否小于最大并發線程數,如果小于,OS會按照LIFO的順
            序讓某個工作者線程從GQCS返回(此工作者線程轉換為運行狀態)。如何決定這個LIFO?這是簡單地通過調用GQCS函數的順序決定的。

            從這里可以看出,這里涉及到線程喚醒和睡眠的操作。如果兩個線程被放置于同一個CPU上,就會有線程切換的開銷。因此,為了消
            除這個開銷,最大并發線程數被建議為設置成CPU數量。

            從以上調度過程還可以看出,如果某個處于運行狀態的工作者線程在處理完成包時阻塞了(例如線程同步、其他IO操作),那么就有
            CPU資源處于空閑狀態。因此,我們也看到很多文檔里建議,工作者線程數為(CPU數*2+2)。

            在一個等待線程轉換到運行狀態時,有可能會出現短暫的時間運行線程數超過最大并發線程數,這個時候OS會迅速地讓這個新轉換
            的線程阻塞,從而減少這個數量。(關于這個觀點,MSDN上只說:by not allowing any new active threads,卻沒說明not allowing
            what)

            調度原理

            這個知道了其實沒什么意義,都是內核做的事,大致上都是操作線程control block,直接摘錄<Inside IO Completion Ports>:

            The list of threads hangs off the queue object. A thread's control block data structure has a pointer in it that
            references the queue object of a queue that it is associated with; if the pointer is NULL then the thread is not
            associated with a queue.

            So how does NT keep track of threads that become inactive because they block on something other than the completion
            port" The answer lies in the queue pointer in a thread's control block. The scheduler routines that are executed
            in response to a thread blocking (KeWaitForSingleObject, KeDelayExecutionThread, etc.) check the thread's queue
            pointer and if its not NULL they will call KiActivateWaiterQueue, a queue-related function. KiActivateWaiterQueue
            decrements the count of active threads associated with the queue, and if the result is less than the maximum and
            there is at least one completion packet in the queue then the thread at the front of the queue's thread list is
            woken and given the oldest packet. Conversely, whenever a thread that is associated with a queue wakes up after
            blocking the scheduler executes the function KiUnwaitThread, which increments the queue's active count.

            posted on 2008-06-24 12:26 大龍 閱讀(231) 評論(0)  編輯 收藏 引用

            中文字幕日本人妻久久久免费| 国产精品一久久香蕉国产线看| 日韩美女18网站久久精品| 国产精品乱码久久久久久软件 | 久久久精品人妻无码专区不卡 | 久久久久国色AV免费观看| 久久精品国产免费观看三人同眠| 少妇精品久久久一区二区三区| 久久99精品久久久久久水蜜桃| 色综合久久久久综合体桃花网| 国产福利电影一区二区三区久久老子无码午夜伦不 | 亚洲人成无码www久久久| 精品国际久久久久999波多野| 久久久久国色AV免费看图片| 国产综合久久久久久鬼色| 热RE99久久精品国产66热| 亚洲国产精品人久久| 久久久一本精品99久久精品88| 一本久久免费视频| 久久不见久久见免费影院www日本| 久久亚洲国产成人精品性色| 中文字幕久久精品| 亚洲国产精品一区二区三区久久 | 久久亚洲国产成人影院| 久久精品国产亚洲Aⅴ香蕉 | 99久久国产精品免费一区二区| 一本一道久久a久久精品综合 | 亚洲AV日韩AV永久无码久久| 无码八A片人妻少妇久久| 香蕉aa三级久久毛片 | 99久久综合狠狠综合久久止| 久久综合给合久久狠狠狠97色| 久久久久久久波多野结衣高潮| 亚洲天堂久久久| 蜜桃麻豆WWW久久囤产精品| 狠狠色婷婷久久一区二区| 亚洲中文字幕无码久久2017| 久久天天躁狠狠躁夜夜avapp| 精品无码久久久久久午夜| 伊人久久综在合线亚洲2019| 精品国产一区二区三区久久蜜臀|