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





            
	    
    




            






            

				

            



    
    







            
	   
	



日韩欧美亚洲国产精品字幕久久久
|
久久国产亚洲高清观看|
狠狠综合久久AV一区二区三区|
久久久噜噜噜久久中文字幕色伊伊|
97精品伊人久久久大香线蕉|
99久久无色码中文字幕|
久久综合偷偷噜噜噜色|
精品综合久久久久久97超人|
久久毛片一区二区|
日本精品久久久久中文字幕8|
一本色道久久综合|
99久久国产免费福利|
久久人人爽人人爽人人片AV高清|
中文字幕久久欲求不满|
久久久久亚洲精品无码蜜桃
|
日本WV一本一道久久香蕉|
久久精品中文字幕久久|
亚洲人成网亚洲欧洲无码久久|
久久精品国产WWW456C0M|
国产2021久久精品|
AV狠狠色丁香婷婷综合久久|
久久人做人爽一区二区三区|
99国内精品久久久久久久|
久久精品国产免费观看三人同眠|
久久精品国产清自在天天线|
久久综合狠狠色综合伊人|
国产精品美女久久久久|
国产亚洲色婷婷久久99精品|
av色综合久久天堂av色综合在|
久久亚洲精品无码播放|
久久综合视频网站|
人妻无码精品久久亚瑟影视|
久久久久国产一区二区|
亚洲欧美成人久久综合中文网
|
精品久久综合1区2区3区激情|
国产成人香蕉久久久久|
久久久久夜夜夜精品国产|
九九99精品久久久久久|
狠狠久久综合伊人不卡|
国产一区二区精品久久岳|
久久精品国产亚洲Aⅴ香蕉|