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

            

			            		
		
            
	
            

            


            


            
	
					

            
	
	
	
            
		沒有什么實(shí)際意義（boost.threads已經(jīng)加入了讀寫鎖好像），只是說明一下condition的用法。
            鎖由Mutex和Lock構(gòu)成。
            Mutex是由condition實(shí)作而成的，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) 閱讀(1802) 評論(0)  編輯 收藏 引用  
	
            

            







            
	    
    




            



            


            

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

            


            

            		
		
            
	
            	

            



            

				

            


    
    







            
	   
	



东京热TOKYO综合久久精品|
一本久久免费视频|
国内精品久久久久久99|
国产美女久久精品香蕉69|
精品久久久久久久|
中文字幕久久亚洲一区|
7777精品久久久大香线蕉|
狠狠色丁香婷婷久久综合不卡
|
日韩美女18网站久久精品|
亚洲精品综合久久|
狠狠色丁香久久婷婷综|
精品久久亚洲中文无码|
国产成人AV综合久久|
色诱久久久久综合网ywww|
欧美午夜A∨大片久久|
国内精品九九久久久精品|
伊人色综合久久天天人守人婷|
久久久久亚洲Av无码专|
欧美一级久久久久久久大|
久久se精品一区二区|
7777精品久久久大香线蕉|
性做久久久久久免费观看|
国产三级精品久久|
久久99精品久久久久婷婷|
热99RE久久精品这里都是精品免费|
国内精品伊人久久久久av一坑
|
99久久无色码中文字幕|
77777亚洲午夜久久多喷|
久久这里的只有是精品23|
久久精品无码一区二区日韩AV
|
国产偷久久久精品专区
|
www亚洲欲色成人久久精品|
97热久久免费频精品99|
久久精品国产亚洲av日韩|
亚洲精品无码久久久久去q
|
一本色道久久99一综合|
精品久久久久久久国产潘金莲|
亚洲国产高清精品线久久|
性高朝久久久久久久久久|
久久国产免费直播|
综合网日日天干夜夜久久|