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

    
            

            




            







												


        

            
	

            
	
            
		
            
			
                
            歲月流轉，往昔空明
            
				
            
			            		
		
            
	
            

            

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

管理

			
			
				

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

            

			            		
		
            
	
            

            


            


            
	
					

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

            







            
	    
    




            






            

				

            


    
    







            
	   
	



久久亚洲AV永久无码精品|
久久99精品久久久久久久久久
|
亚洲中文字幕无码久久综合网
|
久久精品国产免费观看三人同眠|
久久精品国产色蜜蜜麻豆|
久久久久亚洲AV综合波多野结衣|
亚洲国产成人久久笫一页|
亚洲国产美女精品久久久久∴|
久久青青草原精品国产|
国内精品久久久久|
久久se精品一区二区影院
|
一本色道久久综合亚洲精品|
久久男人Av资源网站无码软件
|
一本伊大人香蕉久久网手机|
欧美久久天天综合香蕉伊|
无码精品久久久天天影视|
亚洲国产天堂久久综合网站|
久久无码高潮喷水|
狠狠色丁香久久综合婷婷|
欧美亚洲另类久久综合婷婷|
国产91久久精品一区二区|
2021久久精品免费观看|
青草影院天堂男人久久|
人妻无码αv中文字幕久久琪琪布|
AV无码久久久久不卡蜜桃|
国产精品久久久久久久app|
国产精品无码久久综合网|
欧美熟妇另类久久久久久不卡
|
浪潮AV色综合久久天堂|
午夜福利91久久福利|
国产—久久香蕉国产线看观看|
日韩人妻无码一区二区三区久久|
久久精品无码一区二区app|
久久久久国产精品|
久久精品国产亚洲一区二区|
久久人人爽人人爽人人AV东京热|
久久久久久久久66精品片|
久久久久亚洲av毛片大|
精品乱码久久久久久夜夜嗨
|
国产精品免费久久久久影院|
九九久久99综合一区二区|