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

    
            

            




            







												


        


            


            牽著老婆滿街逛
            

            嚴以律己,寬以待人. 三思而后行.
            
GMail/GTalk: yanglinbo#google.com;
            
MSN/Email: tx7do#yahoo.com.cn;
            
QQ: 3 0 3 3 9 6 9 2 0 .
            

            




            
	
					
	
            
		
            
			簡單的多線程同步的小工具類
		
            
		一些適用于Windows下的多線程同步的小工具類。

            快速互斥鎖，封裝了臨界區的Windows API：
            

            class FastMutex
            {
            private:
                CRITICAL_SECTION    m_Cs;

            public:
                FastMutex()             { ::InitializeCriticalSection(&this->m_Cs); }
                            ~FastMutex() { ::DeleteCriticalSection(&this->m_Cs); }
                            void    Lock()        { ::EnterCriticalSection(&this->m_Cs); }
                            bool    TryLock()    { return ::TryEnterCriticalSection(&this->m_Cs) ? true : false; }
                            void    Unlock()    { ::LeaveCriticalSection(&this->m_Cs); }
            }            ;
            

            簡單封裝了Windows的信號量(Semaphore)的API。
            

            class FastSemaphore
            {
            private:
                HANDLE    m_hSemaphore;
                            long m_lMaximumCount;

            public:
                FastSemaphore(            long lMaximumCount)
                            {
                                this->m_hSemaphore = ::CreateSemaphore(NULL, lMaximumCount, lMaximumCount, NULL);

                                if (this->m_hSemaphore == NULL) throw "Call to CreateSemaphore() failed. Could not create semaphore.";
                                this->m_lMaximumCount = lMaximumCount;
                }            ;

                            ~FastSemaphore() { ::CloseHandle(this->m_hSemaphore); };

                            long GetMaximumCount() const { return this->m_lMaximumCount; };
                            void Inc() { ::WaitForSingleObject(this->m_hSemaphore, INFINITE); };
                            void Dec() { ::ReleaseSemaphore(this->m_hSemaphore, 1, NULL); };
                            void Dec(long lCount) { ::ReleaseSemaphore(this->m_hSemaphore, lCount, NULL); };
            }            ;
            

            讀寫互斥鎖，多線程可以同時讀取同一個文件，但是卻不能同時寫入同一個文件，對某一個文件的寫操作必須是某一個線程所獨占的。
            

            class ReadWriteMutex
            {
            private:
                FastMutex        m_qMutex;
                FastSemaphore    m_qSemaphore;

            public:
                ReadWriteMutex(            long lMaximumReaders): m_qSemaphore(lMaximumReaders) {};

                            void    lockRead() { m_qSemaphore.Inc(); };
                            void    unlockRead() { m_qSemaphore.Dec(); };

                            void lockWrite()
                            {
                    m_qMutex.Lock();
                                for (int i = 0; i < maxReaders(); ++i) m_qSemaphore.Inc();
                    m_qMutex.Unlock();
                }            ;

                            void    unlockWrite() {  m_qSemaphore.Dec(m_qSemaphore.GetMaximumCount()); };
                            int        maxReaders() const { return m_qSemaphore.GetMaximumCount(); };
            }            ;
            


            區域鎖
            

            template <class M>
            class ScopedLock
            {
            public:
                inline ScopedLock(M            & mutex): _mutex(mutex)
                            {
                    _mutex.Lock();
                }
                inline             ~ScopedLock()
                            {
                    _mutex.Unlock();
                }

            private:
                M            & _mutex;

                ScopedLock();
                ScopedLock(            const ScopedLock&);
                ScopedLock            & operator = (const ScopedLock&);
            }            ;
            
曉得區域鎖咋用吧？
            

            void xxxFuc()
            {
            ScopeLock            <FastMutex> mutex;

            }
            

            區域解鎖
            

            template <class M>
            class ScopedUnlock
            {
            public:
                inline ScopedUnlock(M            & mutex, bool unlockNow = true): _mutex(mutex)
                            {
                                if (unlockNow)
                        _mutex.Unlock();
                }
                inline             ~ScopedUnlock()
                            {
                    _mutex.Lock();
                }

            private:
                M            & _mutex;

                ScopedUnlock();
                ScopedUnlock(            const ScopedUnlock&);
                ScopedUnlock            & operator = (const ScopedUnlock&);
            }            ;
            
與上面的區域鎖的操作相反。

            NOTE：他們只是簡單的小工具類，他們只是保證了“能用”，當中可能有很多不足，或者不適用特別的情況。 

		
            
			posted on 2008-05-04 10:43 楊粼波 閱讀(446) 評論(0)  編輯 收藏 引用  
		
            
	
            
	
	





            
	    
    




            






            

				

            



    
    







            
	   
	



蜜臀av性久久久久蜜臀aⅴ|
久久精品亚洲精品国产色婷|
中文精品久久久久国产网址|
2020最新久久久视精品爱|
久久久久这里只有精品|
亚洲综合伊人久久综合|
99久久人妻无码精品系列|
99久久婷婷免费国产综合精品|
久久不射电影网|
久久久久久久精品成人热色戒|
精品综合久久久久久98|
久久精品中文字幕无码绿巨人|
伊人久久大香线蕉av不卡
|
亚洲国产天堂久久久久久|
国产成人精品久久免费动漫
|
精品久久久久久成人AV|
久久久国产精华液|
狠狠综合久久综合88亚洲|
久久亚洲精品视频|
久久精品99无色码中文字幕|
国内精品综合久久久40p|
国产一区二区精品久久岳|
精品久久久久久成人AV|
一本色综合网久久|
久久人人爽人人人人片av|
久久99精品免费一区二区|
久久九九亚洲精品|
亚洲综合精品香蕉久久网97|
久久夜色精品国产噜噜亚洲AV|
久久WWW免费人成一看片|
亚洲国产成人久久笫一页|
久久影院午夜理论片无码|
久久av高潮av无码av喷吹|
91超碰碰碰碰久久久久久综合|
国产精品青草久久久久婷婷
|
97超级碰碰碰碰久久久久|
色综合久久无码五十路人妻|
91麻豆国产精品91久久久|
伊人 久久 精品|
99久久夜色精品国产网站|
久久大香萑太香蕉av|