• <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)  編輯 收藏 引用  
		
            
	
            
	
	





            
	    
    




            






            

				

            



    
    







            
	   
	



99精品国产综合久久久久五月天|
人妻久久久一区二区三区|
久久精品免费一区二区三区|
国产精品久久影院|
狠狠色综合网站久久久久久久|
热久久国产欧美一区二区精品|
亚洲综合日韩久久成人AV|
精品久久久久久国产|
一本综合久久国产二区|
久久综合精品国产二区无码|
国产精品嫩草影院久久|
久久精品中文闷骚内射|
日本高清无卡码一区二区久久|
99久久99久久精品免费看蜜桃|
久久亚洲高清综合|
久久99国产精品一区二区|
99久久国产精品免费一区二区|
久久中文娱乐网|
无遮挡粉嫩小泬久久久久久久|
国产—久久香蕉国产线看观看
|
亚洲另类欧美综合久久图片区|
久久久久免费看成人影片|
久久亚洲精品国产精品婷婷|
久久人人爽人人爽人人片AV麻豆|
亚洲va久久久噜噜噜久久天堂
|
亚洲国产另类久久久精品黑人|
国产精品成人99久久久久91gav|
久久超乳爆乳中文字幕|
久久露脸国产精品|
99久久精品九九亚洲精品|
精品一区二区久久|
97r久久精品国产99国产精|
囯产极品美女高潮无套久久久|
午夜精品久久久久久|
亚洲国产成人久久综合碰|
精品久久久久中文字幕一区|
99久久99久久精品国产片|
久久亚洲国产精品一区二区|
婷婷综合久久狠狠色99h|
欧美亚洲另类久久综合|
99久久免费只有精品国产|