• <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); };
            }
            ;

            讀寫互斥鎖,多線程可以同時讀取同一個文件,但是卻不能同時寫入同一個文件,對某一個文件的寫操作必須是某一個線程所獨(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 楊粼波 閱讀(443) 評論(0)  編輯 收藏 引用


            只有注冊用戶登錄后才能發(fā)表評論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            久久99精品久久久久久不卡| 91精品国产91久久久久福利| 99精品久久久久久久婷婷| 国产精品国色综合久久| 99久久综合狠狠综合久久止| 99精品久久久久久久婷婷| 亚洲国产欧洲综合997久久| 国产精品九九九久久九九| 99久久夜色精品国产网站| 囯产精品久久久久久久久蜜桃| 怡红院日本一道日本久久| 久久久久久噜噜精品免费直播 | 国产精品久久国产精品99盘 | 久久久久久A亚洲欧洲AV冫| 99热精品久久只有精品| 人妻精品久久无码区| 久久国产热这里只有精品| 久久99精品久久久久久野外| 久久久久国产一区二区| 伊人久久大香线蕉AV一区二区| 久久国产亚洲高清观看| 欧美一级久久久久久久大| 996久久国产精品线观看| 色综合久久88色综合天天| 久久无码AV一区二区三区| 囯产精品久久久久久久久蜜桃| 国产亚洲精久久久久久无码77777 国产亚洲精品久久久久秋霞 | 久久精品国产亚洲AV不卡| 亚洲一区精品伊人久久伊人| 亚洲精品美女久久久久99| 久久99国产精品久久| 奇米综合四色77777久久| 996久久国产精品线观看| 久久久WWW成人| 久久久久亚洲AV片无码下载蜜桃| 久久精品国产亚洲AV无码娇色| 久久国产精品久久国产精品| 中文字幕无码久久久| 久久99国产精品久久99| 久久亚洲中文字幕精品一区| 国内精品久久久久久野外|