• <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) 閱讀(1809) 評論(0)  編輯 收藏 引用  
	
            

            







            
	    
    




            



            


            

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

            


            

            		
		
            
	
            	

            



            

				

            


    
    







            
	   
	



国产精品日韩深夜福利久久|
久久亚洲欧洲国产综合|
日韩人妻无码精品久久久不卡|
久久天天躁狠狠躁夜夜不卡|
久久人人爽人人爽人人片AV不|
久久精品国产99久久久|
国产精品成人99久久久久91gav
|
国产精品久久久久久影院|
亚洲精品国产成人99久久|
久久综合色老色|
97久久婷婷五月综合色d啪蜜芽
|
久久强奷乱码老熟女网站|
久久婷婷人人澡人人爽人人爱
|
国产成人久久久精品二区三区|
国产精品成人久久久|
国产精品日韩深夜福利久久|
久久天天躁狠狠躁夜夜96流白浆
|
久久99国产精品尤物|
一本一道久久a久久精品综合|
91久久精品视频|
精品久久久久久久久午夜福利|
久久精品国产亚洲AV影院|
久久精品国产亚洲一区二区三区|
国产精品一区二区久久国产|
久久91精品国产91|
女同久久|
久久亚洲中文字幕精品一区四|
日韩精品国产自在久久现线拍|
a级成人毛片久久|
国产91久久精品一区二区|
无码AV中文字幕久久专区|
久久久无码精品亚洲日韩京东传媒
|
日本免费久久久久久久网站|
久久久久久无码Av成人影院|
无码专区久久综合久中文字幕|
77777亚洲午夜久久多人|
18岁日韩内射颜射午夜久久成人|
精产国品久久一二三产区区别|
三级三级久久三级久久|
777午夜精品久久av蜜臀|
97久久天天综合色天天综合色hd|