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

            牽著老婆滿街逛

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

            簡單的多線程同步的小工具類

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

            快速互斥鎖,封裝了臨界區(qū)的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); };
            }
            ;

            讀寫互斥鎖,多線程可以同時(shí)讀取同一個(gè)文件,但是卻不能同時(shí)寫入同一個(gè)文件,對某一個(gè)文件的寫操作必須是某一個(gè)線程所獨(dú)占的。
            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(); };
            }
            ;


            區(qū)域鎖
            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&);
            }
            ;
            曉得區(qū)域鎖咋用吧?
            void xxxFuc()
            {
            ScopeLock
            <FastMutex> mutex;

            }

            區(qū)域解鎖
            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&);
            }
            ;
            與上面的區(qū)域鎖的操作相反。

            NOTE:他們只是簡單的小工具類,他們只是保證了“能用”,當(dāng)中可能有很多不足,或者不適用特別的情況。

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

            精品久久久久久久久免费影院 | 久久婷婷色综合一区二区| 午夜不卡久久精品无码免费| 72种姿势欧美久久久久大黄蕉 | 亚洲伊人久久成综合人影院| 亚洲中文字幕无码一久久区| 99久久精品费精品国产一区二区| 久久久久九九精品影院| 精品久久久久久久无码| 美女久久久久久| 99re这里只有精品热久久 | 久久人人爽人人爽人人片AV不| 久久综合久久久| 亚洲国产精品无码久久SM| 老司机午夜网站国内精品久久久久久久久| 香蕉久久夜色精品国产2020| 亚洲成人精品久久| 国产亚洲精品久久久久秋霞| 精品久久人人妻人人做精品| 99久久这里只有精品| 久久精品国产亚洲AV影院| 亚洲人成电影网站久久| 99久久精品无码一区二区毛片 | 免费观看成人久久网免费观看| 国产精品久久婷婷六月丁香| 久久久久亚洲AV无码专区网站| 久久国产精品-久久精品| 久久狠狠高潮亚洲精品| 色欲综合久久躁天天躁蜜桃| 久久国产亚洲精品| 亚洲午夜精品久久久久久浪潮 | 无夜精品久久久久久| 人妻无码久久精品| 久久久久久国产a免费观看黄色大片| 国产成人无码精品久久久免费| 亚洲国产精久久久久久久| 狠狠色噜噜狠狠狠狠狠色综合久久| 久久久久久久亚洲Av无码| 91久久精一区二区三区大全| 青青草原综合久久大伊人精品| 久久久久久久尹人综合网亚洲|