青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

我的第一本C++書

游歷C++世界的地圖

C++小品:她來聽我的演唱會——C++11中的隨機數、線程(thread)、互斥(mutex)和條件變量(condition)

源文來自: http://imcc.blogbus.com/logs/172675220.html
?

在新頒布的C++新標準C++11中,最令人激動人心的,我想不是auto關鍵字,也不是Lambda表達式,而是其中的對并行計算的支持——新的線程庫(thread)的加入。

多核心CPU的普及應用,C++的主要應用領域,服務器程序,高性能計算等等,都對并行計算提出了新的要求,而這次C++中全新添加的線程庫,就是 對這一趨勢的應對。現在,C++程序員可以輕松地編寫多線程的程序,而無需借助系統API或者是第三方程序庫的支持。線程庫的加入給C++帶來的變化,無 異于 194,翻身的程序員們把歌唱。

C++11中的線程庫,很大程度上直接來自boost這塊C++的試驗田,其基本架構和組件都完全相同,如果你是一個boost線程庫的使用者,那 么在C++11中,你會感覺到是回到了老家一樣,到處都是熟人。而如果你是一個完全的新手,也不要緊,C++11中的線程庫非常簡單,任何人都可以輕松上 手,我就是這樣,但是要深究,還得好好學習。

下面是一個簡單的例子,用到了線程庫中的線程(thread),互斥(mutex),條件變量(condition),來模擬一個演唱會的入場檢票的場景,另外,為了模擬觀眾,用到了C++11中的新的隨機數的產生,模擬一個正態分布的訪客人群。不說了,還是看代碼:

#include <iostream>
#include <queue>
#include <vector>
// 隨機數
#include <random>
// 這里,我使用了boost實現的線程庫,如果你的編譯器已經支持C++11,則使用<thread>是一樣的
#include <boost\thread.hpp>
#include <boost\thread\locks.hpp>
#include <boost\thread\condition.hpp>

using namespace std;
using namespace boost;

// 共享資源和互斥對象
mutex mtx;
bool finish = false;? // 表示觀眾到來是否結束

// 觀眾,主要是為了表示檢票過程中的檢票耗費時間
class viewer
{
public:
??? void check()
??? {
??? ??? // 線程等待
??????? posix_time::milliseconds worktime(400);?
??? ??? this_thread::sleep(worktime);???
??? }
??? void arrival(int t)
??? {
??? ??? posix_time::seconds arrtime(t);?
??? ??? this_thread::sleep(arrtime);???
??? }
};
// 檢票口
// 它有一個隊列,用于保存到來的觀眾,并且用一個線程來處理隊列中的觀眾
class gate
{
??? typedef boost::mutex::scoped_lock scoped_lock;
public:
??? gate():count(0),no(0){};
??? // 啟動線程
??? void start(int n)
??? {
??? ??? no = n;
??? ??? t = thread(&gate::check,this);
??? }

??? // 檢票
??? void check()
??? {
??? ??? // 無限循環,知道觀眾數為0且不會有新的觀眾到來
??? ??? while(true)
??? ??? {
??? ??? ??? viewer v;
??? ??? ??? {
??? ??? ??? ??? // 鎖定互斥對象,開始訪問對列
??? ??? ??? ??? scoped_lock lock(m);
??? ??? ??? ??? if(0==vque.size())? // 如果隊列為空
??? ??? ??? ??? {
??? ??? ??? ??? ??? {
??? ??? ??? ??? ??? // 判斷是否還會有新的觀眾到來,也即是表示到達的線程是否結束
??????????????????? scoped_lock finlk(mtx);
??? ??? ??? ??? ??? if(finish)
??? ??? ??? ??? ??? ??? return; // 如果已經結束,檢票也同樣結束
??? ??? ??? ??? ??? }
??? ??? ??? ??? ??? // 如果觀眾數為0,則等待新的觀眾的到來
??????????????????? while(0 == vque.size())
??? ??? ??? ??? ??? {???
??? ??? ??? ??? ??? ????? // 這里的wait()是條件變量的關鍵,它會先是否lock所鎖定的互斥對象m一定時間,
????????????????????????? // 然后再次鎖定,接著進行(0==vque.size())的判斷。如此往復,知道size不等于0,
????????????????????????? // 循環條件無法滿足而結束循環,這里表達的條件就是,只有size!=0,也就是隊列中有
????????????????????????? // 觀眾才繼續向下。
????????????????????????? cond.wait(lock);
??? ??? ??? ??? ??? }
??? ??? ??? ??? }
??? ??? ??? ??? // 從對列中獲得觀眾,對其進行檢票
??? ??? ??? ??? v = vque.front();
??? ??? ??? ??? vque.pop();
??? ??? ??? ??? cond.notify_one(); // 這里是通知添加觀眾的進程,表示隊列已經有空位置了,可以添加新的觀眾
??? ??? ??? }
??? ??? ??? v.check();
??? ??? ??? ++count;
??? ??? }
??? }
??? // 將觀眾添加到隊列
??? void add(viewer v)
??? {

??? ??? // 同樣運用條件變量,判斷隊列是否已經滿了
??????? // 只有在隊列尚未滿的情況下才向下繼續
??????? scoped_lock lock(m);
??? ??? while(vque.size() >= 15 )
??? ??? {
??? ??? ??? cond.wait(lock);
??? ??? }
??? ??? vque.push(v); // 將觀眾添加到隊列
??? ??? cond.notify_one();? // 通知檢票進程,新的觀眾進入隊列,這樣在size=0時等待的條件可以更新
??? }
??? int getcount()
??? {
??? ??? return count;
??? }
??? int getno()
??? {
??? ??? return no;
??? }
??? // 等待線程執行完畢返回
??? void join()
??? {
??? ??? t.join();
??? }
private:
??? thread t;
??? mutex m;
??? condition cond;
??? queue<viewer> vque;
??? int count;
??? int no;
};

// 一共有10個檢票口
vector<gate> vgates(10);

// 用隨機數模擬觀眾到達
void arrival()
{???
??? default_random_engine re{}; // 產生一個均值為31的正態分布的隨機數
??? normal_distribution<double> nd(31,8);

??? // 將隨機數引擎和分布綁定一個函數對象
??? auto norm = std::bind(nd, re);
??? // 保存隨機數的容器
??? vector<int> mn(64);
???
??? // 產生隨機數
??? for(int i = 0;i<700;++i)
??? ??? ++mn[round(norm())];
???
??? int secs = 100;
??? // 產生0到9的隨機數,表示觀眾隨機地到達某一個檢票口
??? uniform_int_distribution<int>? index{0,9};
??? ?
??? // 進入檢票口隊列
??? for(auto i:mn)
??? {
??? ??? cout<<i<<endl;
??? ??? for(auto vi = 1; vi <= i; ++vi)
??? ??? {
??? ??? ??? // 將觀眾添加到某個gate的隊列中
???????????? (vgates[index(re)]).add(viewer());
??? ??? ??? // 等待一段時間
??? ??? ??? int t = round(secs/(float)(i+1));
??? ??? ??? this_thread::sleep(
??? ??? ??? posix_time::milliseconds(t));
??? ??? }
??? }
??? // 觀眾已經全部到達,進入隊列
???? cout<<"finish"<<endl;
??? mtx.lock();
??? finish = true;
??? mtx.unlock();
??? //cout<<"unlock"<<endl;
}

int main()
{
??? int i = 1;
??? // 啟動檢票線程
??? for(gate& g:vgates)
??? {
??? ??? g.start(i);
??? ??? ++i;
??? }
??? // 啟動到達線程,看看,在C++11中新線程的創建就這么簡單
??? thread arr = thread(arrival);
??? // 等待線程結束
??? arr.join();
??? int total = 0;
??? // 等待檢票線程結束,并輸出處理的人數
??? for(gate& g:vgates)
??? {
??? ??? g.join();
??? ??? total += g.getcount();
??? ??? cout<<"gate "<<g.getno()
??? ??? ??? <<" processed "<<g.getcount()<<" viewers."<<endl;
??? }
??? cout<<"there are "<<total<<"viewers in total."<<endl;
??? return 0;
}
這就是一個線程庫的簡單應用,模擬了非常復雜的場景。

因為自己對多線程開發還不太熟悉,這個程序在某些特定條件下會產生了死鎖,還有待進一步完善

posted on 2011-11-12 10:29 陳良喬——《我的第一本C++書》 閱讀(3485) 評論(3)  編輯 收藏 引用

Feedback

# re: C++小品:她來聽我的演唱會——C++11中的隨機數、線程(thread)、互斥(mutex)和條件變量(condition) 2011-11-13 17:16 一念天堂

我是很久沒用 boost thread 了,但是 scoped lock 能跟 condition variable 一起用么?  回復  更多評論   

# re: C++小品:她來聽我的演唱會——C++11中的隨機數、線程(thread)、互斥(mutex)和條件變量(condition) 2012-08-15 10:18 walfud

請問你是在什么平臺下編譯并運行的? 我在 fedora 17 上 thread 會報異常, 說 Operation not permitted.
windows g++ 4.6 下找不到 std::thread...  回復  更多評論   

# re: C++小品:她來聽我的演唱會——C++11中的隨機數、線程(thread)、互斥(mutex)和條件變量(condition) 2012-08-15 10:19 walfud

@walfud
哦, 我錯了, 我以為你是用的 C++11 thread 呢.  回復  更多評論   


青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            久久男人资源视频| 亚洲人成免费| 欧美在线网址| 久久精品午夜| 136国产福利精品导航网址| 欧美福利电影在线观看| 免费亚洲电影| 亚洲永久在线观看| 欧美自拍偷拍午夜视频| 最新成人在线| 中文亚洲欧美| 在线精品视频一区二区| 亚洲人www| 国产精品视频区| 久久综合色一综合色88| 欧美日韩成人网| 欧美在线二区| 欧美激情综合色综合啪啪| 亚洲欧美综合一区| 久久久午夜视频| 宅男66日本亚洲欧美视频| 欧美一区二区三区久久精品茉莉花| 精品福利电影| 一区二区三区日韩欧美| 黑人巨大精品欧美一区二区| 亚洲国产综合在线| 国产日韩欧美高清| 亚洲精品国产精品乱码不99按摩| 国产农村妇女精品| 亚洲国产婷婷香蕉久久久久久99| 国产精品入口夜色视频大尺度| 玖玖精品视频| 国产精品视频在线观看| 亚洲国产精品久久久久| 国产亚洲成av人在线观看导航| 亚洲高清视频一区| 国语自产在线不卡| 亚洲一区综合| 亚洲另类春色国产| 久久女同互慰一区二区三区| 亚洲综合电影| 欧美日韩一区国产| 欧美h视频在线| 国产日韩欧美综合一区| 中文在线资源观看视频网站免费不卡| 曰本成人黄色| 久久精品女人| 亚洲一区二区三区中文字幕在线 | 亚洲国产精品va在线观看黑人| 国产精品久久网站| 日韩天堂av| 一本久道久久综合狠狠爱| 噜噜噜噜噜久久久久久91| 久久久国产视频91| 国产日韩欧美在线播放| 亚洲一区二区免费视频| 亚洲一区高清| 国产精品久久久久99| 亚洲另类春色国产| 一区二区三区国产| 欧美日韩四区| 日韩一区二区电影网| 中文在线不卡视频| 欧美日韩午夜激情| 一区二区三区欧美日韩| 亚洲一区免费视频| 国产精品黄色| 亚洲在线免费观看| 久久精品五月| 在线成人激情| 欧美不卡视频一区发布| 亚洲高清二区| 亚洲无线视频| 国产精品免费一区二区三区在线观看 | 在线观看日韩av电影| 久久精品夜色噜噜亚洲aⅴ| 美女91精品| 亚洲三级网站| 欧美视频在线观看 亚洲欧| 在线亚洲欧美专区二区| 欧美专区一区二区三区| 在线成人中文字幕| 欧美日韩成人在线观看| 亚洲一区图片| 女生裸体视频一区二区三区| 亚洲精品视频在线看| 国产精品hd| 久久精品国产亚洲高清剧情介绍| 蜜桃av一区二区三区| 亚洲精品久久久久久久久久久| 欧美三日本三级三级在线播放| 亚洲五月六月| 欧美sm重口味系列视频在线观看| 亚洲美女毛片| 国产手机视频精品| 欧美理论电影在线观看| 午夜精品亚洲| 亚洲日韩视频| 久久精品首页| 中文国产成人精品| 尤物在线观看一区| 欧美特黄一级大片| 久久精品最新地址| 日韩小视频在线观看专区| 久久久久成人网| 一区二区激情| 亚洲国产精品一区二区www在线| 欧美日韩在线免费| 美女免费视频一区| 亚洲欧美日韩精品久久| 亚洲精选视频在线| 嫩草成人www欧美| 欧美在线观看www| 中文av一区二区| 亚洲视频一二| 亚洲韩日在线| 美女视频黄免费的久久| 亚洲摸下面视频| 日韩一区二区精品葵司在线| 国模私拍一区二区三区| 国产精品卡一卡二| 欧美人与性禽动交情品 | 一本色道久久综合| 亚洲精美视频| 欧美国产日本| 麻豆精品一区二区av白丝在线| 欧美在线观看网址综合| 亚洲香蕉网站| 一本久道久久综合狠狠爱| 亚洲日本理论电影| 91久久综合| 亚洲高清不卡av| 在线免费观看视频一区| 国内精品久久久久久影视8| 国产欧美午夜| 国产欧美日韩另类视频免费观看| 欧美视频一区二区在线观看 | 免费观看欧美在线视频的网站| 欧美在线观看一区二区| 亚洲欧美日韩直播| 欧美一二三视频| 欧美一区二区三区免费看| 亚洲欧美一区在线| 欧美在线首页| 久久精品一区二区三区不卡牛牛| 久久精品国产精品亚洲综合| 久久精品国产一区二区三区| 久久久久久69| 欧美成人r级一区二区三区| 欧美激情在线免费观看| 欧美日韩国产三区| 国产精品久久国产三级国电话系列| 欧美调教vk| 国产伊人精品| 亚洲国产成人久久综合一区| 亚洲人体影院| 亚洲一区二区欧美| 欧美一区免费视频| 老色鬼精品视频在线观看播放| 欧美大片免费看| 亚洲精品在线电影| 久久成人一区| 久久久91精品国产一区二区精品| 久热精品视频在线观看| 欧美高清在线视频观看不卡| 欧美日韩一二区| 国产日韩一区二区三区| 亚洲国产一区二区三区青草影视| 日韩视频免费| 性做久久久久久久久| 老牛影视一区二区三区| 日韩视频不卡| 欧美一区二区三区婷婷月色| 蜜桃久久av一区| 在线免费观看日韩欧美| 亚洲欧美日韩电影| 欧美aaaaaaaa牛牛影院| 欧美日韩影院| 亚洲第一页中文字幕| 亚洲欧美国产日韩天堂区| 蜜臀a∨国产成人精品| 日韩视频在线你懂得| 久久精品99国产精品| 欧美日本久久| 在线观看日韩专区| 亚洲欧美日韩久久精品 | 午夜精品久久久久久久男人的天堂 | 国产伦精品一区二区三区照片91| 在线观看欧美日本| 亚洲综合另类| 亚洲国产天堂久久综合网| 亚洲综合清纯丝袜自拍| 欧美精品久久久久久久久老牛影院| 国产精品日本精品| 一本色道久久综合狠狠躁篇的优点| 久久久久久久综合| 中文在线资源观看网站视频免费不卡| 久久亚洲国产成人| 激情国产一区| 久久精品成人|