• <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>

            meet-dream

            boost asio 2:threading

            asio在handle級上提供了多線程保護鎖,命名為asio::strand,strand(繩、線之一股, 線, 繩, 串, 海濱, 河岸)顧名思義序列化,這個命名可能和asio的工作原理有關.asio的內部維護了一個隊列,當異步請求的狀態轉移為完成時,service會調用對應的線程對應的handle.如果在多線程方式下,可能有多個handle訪問共享變量.而strand把這一handle針對這一變量的的操作序列為不可分割的一段,這樣另外一段針對這一變量的的操作就必須等該操作完成后才能開始.這樣就起到了互斥信號的作用. 詳見下面的例子: #include #include #include #include #include class printer { public: printer(boost::asio::io_service& io) : strand_(io), timer1_(io, boost::posix_time::seconds(1)), timer2_(io, boost::posix_time::seconds(1)), count_(0) { timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1, this))); timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2, this))); } ~printer() { std::cout << "Final count is " << count_ << "\n"; } void print1() { if (count_ < 10) { std::cout << "Timer 1: " << count_ << "\n"; ++count_; timer1_.expires_at(timer1_.expires_at() + boost::posix_time::seconds(1)); timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1, this))); } } void print2() { if (count_ < 10) { std::cout << "Timer 2: " << count_ << "\n"; ++count_; timer2_.expires_at(timer2_.expires_at() + boost::posix_time::seconds(1)); timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2, this))); } } private: boost::asio::strand strand_; boost::asio::deadline_timer timer1_; boost::asio::deadline_timer timer2_; int count_; }; int main() { //啟動兩個線程 //asio的每個線程必須調用io_service::run,這個有點類似com的coinitlize boost::asio::io_service io; printer p(io); boost::thread t(boost::bind(&boost::asio::io_service::run, &io)); io.run(); t.join(); return 0; } 這個例子的最大不同就是 timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1, this))); 這一行.我們知道 timer1_.async_wait(boost::bind(&printer::print1, this)); 啟動了一個時鐘請求,而print1和print2函數訪問了共享變量cout_,而要互斥地訪問該變量,我們只需要用strand把該這兩個handle包裝一下(wrap).這樣一來兩個線程就可以安全的在屏幕輸出各自的信息(當然,這樣一來,輸出的信息時間的嚴格性就無法保證).如果去掉該wrap,我們將看到屏幕的輸出是無序的,而且變量的值也會出現變小的現象. asio的strand當然可以用在自己的函數內部,同時它也是跨平臺的互斥量噢.

            posted on 2007-05-25 14:06 meet-dream 閱讀(1556) 評論(2)  編輯 收藏 引用 所屬分類: boost library

            評論

            # re: boost asio 2:threading 2007-05-25 17:41 pass86

            亂碼顯示源代碼  回復  更多評論   

            # re: boost asio 2:threading 2007-05-25 17:53 ngaut

            不錯,建議用插入代碼的方式來排版代碼,會漂亮些^_^  回復  更多評論   

            久久久噜噜噜久久中文字幕色伊伊| 久久久无码精品亚洲日韩按摩 | 狠狠色丁香婷婷综合久久来| 国产精品一区二区久久国产| 久久精品亚洲欧美日韩久久| 久久亚洲欧洲国产综合| 久久精品99久久香蕉国产色戒| 久久91精品国产91久久户| 久久免费大片| 国内精品久久国产大陆| 波多野结衣久久精品| 99热成人精品免费久久| 97久久婷婷五月综合色d啪蜜芽| 久久久久中文字幕| 日韩乱码人妻无码中文字幕久久 | 内射无码专区久久亚洲| 久久无码人妻一区二区三区午夜| 久久精品国产精品青草app| 99精品国产综合久久久久五月天| 久久国产成人精品国产成人亚洲| 久久精品国产亚洲av日韩| 久久久久精品国产亚洲AV无码 | 久久婷婷色综合一区二区| 国产福利电影一区二区三区久久久久成人精品综合 | 国产精品久久久久9999高清| 亚洲欧美成人久久综合中文网| 成人精品一区二区久久| 久久精品国产99国产精偷| 久久亚洲AV成人无码电影| 久久综合亚洲鲁鲁五月天| 人妻无码久久精品| 欧美亚洲日本久久精品| 中文字幕亚洲综合久久2| 久久国产一区二区| 亚洲国产精品久久久久婷婷软件| 久久久久99精品成人片欧美| 久久精品中文字幕无码绿巨人| 亚洲中文字幕无码久久精品1| 国产偷久久久精品专区| 东方aⅴ免费观看久久av| 亚洲午夜久久久影院伊人|