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

    
            

            




            







												


        

            
	

            
	
            
		
            
			
                
            歲月流轉(zhuǎn)，往昔空明
            
				
            
			            		
		
            
	
            

            

            
	
            
		
            
		    
		        
		        C++博客
首頁
新隨筆
聯(lián)系
聚合

管理

			
			
				

            
	
            
		
            
			
			
			
				 
				118 
				Posts ::
				3 Stories
				::
				413 Comments
				::
				0 Trackbacks
			
		
            
	
            

            

			            		
		
            
	
            

            


            


            
	
					

            
	
	
	
            
		沒有什么實際意義（boost.threads已經(jīng)加入了讀寫鎖好像），只是說明一下condition的用法。
            鎖由Mutex和Lock構(gòu)成。
            Mutex是由condition實作而成的，Lock和ScopedLock區(qū)別不是很大，分讀寫鎖而已。

            以下是Mutex的代碼
            class?read_write_mutex
            {
            ????mutex?mtx_;
            ????            int?read_cnt_;
            ????condition?cond_;

            public:
            ????read_write_mutex():?read_cnt_(            0){}
            ????            ~read_write_mutex(){}

            ????            void?lock_read(){
            ????????mutex::scoped_lock?            lock(mtx_);
            ????????            while(read_cnt_?<?0){
            ????????????cond_.wait(            lock);
            ????????}
            ????????            ++read_cnt_;
            ????}
            ????
            ????            void?unlock_read(){
            ????????mutex::scoped_lock?            lock(mtx_);
            ????????            --read_cnt_;
            ????????cond_.notify_all();
            ????}

            ????            void?lock_write(){
            ????????mutex::scoped_lock?            lock(mtx_);
            ????????            while(read_cnt_?!=?0){
            ????????????cond_.wait(            lock);
            ????????}
            ????????read_cnt_?            =?-1;
            ????}

            ????            void?unlock_write(){
            ????????mutex::scoped_lock?            lock(mtx_);
            ????????read_cnt_?            =?0;
            ????????cond_.notify_all();
            ????}
            }            ;

            以下是鎖的代碼
            class?scoped_rlock
            {
            ????read_write_mutex            &?cond_;
            public:
            ????scoped_rlock(read_write_mutex            &?c):cond_(c){cond_.lock_read();}
            ????            ~scoped_rlock(){cond_.unlock_read();}
            }            ;

            class?scoped_wlock
            {
            ????read_write_mutex            &?cond_;
            public:
            ????scoped_wlock(read_write_mutex            &?c):cond_(c){cond_.lock_write();}
            ????            ~scoped_wlock(){cond_.unlock_write();}
            }            ;

            以下是測試用例：
            int?top?=?0;
            int?stack[1000];
            read_write_mutex?rwc;
            mutex?io_mutex;

            void?read(int?val)
            {
            ????            for(int?i?=?0;?i?<?20;?++i)
            ????            {
            ????????Sleep(            2);

            ????????scoped_rlock?rlock(rwc);
            ????????            int?s?=?top;

            ????????            {
            ????????????mutex::scoped_lock?            lock(io_mutex);
            ????????????cout?            <<?"read?begin?"?<<?val?<<?endl;
            ????????}

            ????????Sleep(            10);

            ????????            {
            ????????????mutex::scoped_lock?            lock(io_mutex);
            ????????????cout?            <<?"read?end?"?<<?val?<<?endl;
            ????????}

            ????????            if(s?!=?top)
            ????????            {
            ????????????cout?            <<?"error!"<<endl;
            ????????}
            ????}
            }

            void?write(int?val)
            {
            ????            for(int?i?=?0;?i?<?20;?++i)
            ????            {
            ????????Sleep(            2);

            ????????scoped_wlock?wlock(rwc);

            ????????            {
            ????????????mutex::scoped_lock?            lock(io_mutex);
            ????????????cout?            <<?"write?begin?"?<<?val?<<?endl;
            ????????}

            ????????Sleep(            5);

            ????????            {
            ????????????mutex::scoped_lock?            lock(io_mutex);
            ????????????cout?            <<?"write?end?"?<<?val?<<?endl;
            ????????}
            ????}
            }

            int?_tmain(int?argc,?_TCHAR*?argv[])
            {
            ????thread_group?rtg;

            ????            for(int?i?=?0;?i?<?10;?++i)
            ????            {
            ????????rtg.create_thread(boost::bind(            &read,?i));
            ????}

            ????            for(int?i?=?0;?i?<?2;?++i)
            ????            {
            ????????rtg.create_thread(boost::bind(            &write,?i));
            ????}

            ????rtg.join_all();

            ????system(            "pause");

            ????            return?0;
            }

            別忘了頭文件中：
            #include?<boost/thread.hpp>
            #include?            <boost/bind.hpp>
            #include?            <windows.h>
            #include?            <iostream>

            using?namespace?std;
            using?namespace?boost;
            
	
            
	
	
            
		posted on 2006-10-23 19:38 空明流轉(zhuǎn) 閱讀(1814) 評論(0)  編輯 收藏 引用  
	
            

            







            
	    
    




            



            


            

	
            
		
		
            只有注冊用戶登錄后才能發(fā)表評論。
            
		
            
		
				
		
		
		
            
		
            			
		
		
		
		
            
		
            
			
		
            
		
            
			
		
            
		
            
			
            網(wǎng)站導(dǎo)航:
			博客園  
			IT新聞  
			BlogJava  			
			博問  
			Chat2DB  
			管理
			
            		
		
            
		
            
			
				

            


            

            		
		
            
	
            	

            



            

				

            


    
    







            
	   
	



久久天天躁狠狠躁夜夜2020
|
久久亚洲国产最新网站|
热久久最新网站获取|
久久国产欧美日韩精品|
精品人妻伦九区久久AAA片69|
久久高清一级毛片|
97热久久免费频精品99|
久久天天躁狠狠躁夜夜2020
|
久久996热精品xxxx|
久久精品国产久精国产果冻传媒
|
www久久久天天com|
久久精品国产亚洲AV蜜臀色欲|
一本伊大人香蕉久久网手机|
麻豆久久久9性大片|
久久久久国产成人精品亚洲午夜|
亚洲愉拍99热成人精品热久久
|
久久久久人妻一区精品色|
亚洲人成网站999久久久综合
|
国产精品久久久久9999|
色欲综合久久躁天天躁蜜桃|
久久亚洲中文字幕精品一区四|
国内精品伊人久久久久|
久久久无码人妻精品无码|
久久天天躁夜夜躁狠狠
|
99精品国产在热久久无毒不卡|
国产成年无码久久久免费|
尹人香蕉久久99天天拍|
久久青青草视频|
欧美成人免费观看久久|
国产精品久久久久免费a∨|
热久久视久久精品18|
色综合久久夜色精品国产|
国产欧美久久久精品影院|
久久综合鬼色88久久精品综合自在自线噜噜
|
久久精品国产亚洲网站|
精品人妻久久久久久888|
国产成人精品免费久久久久|
97久久超碰国产精品2021|
99久久婷婷免费国产综合精品|
久久精品九九亚洲精品天堂|
国产精品99久久不卡|