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

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


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


            区亚洲欧美一级久久精品亚洲精品成人网久久久久 | 久久亚洲日韩看片无码| 一个色综合久久| 色综合久久久久久久久五月| 国产精品免费福利久久| 色综合合久久天天给综看| 亚洲国产成人久久综合区| 亚洲AV日韩AV天堂久久| 久久国产热这里只有精品| 麻豆精品久久久久久久99蜜桃| avtt天堂网久久精品| 性欧美大战久久久久久久| 久久AV高清无码| 久久国产成人| 国产精品99久久99久久久| 久久久久综合国产欧美一区二区| 亚洲午夜久久久久久久久久| 狠狠色综合久久久久尤物| 久久精品www人人爽人人| 婷婷久久综合九色综合九七| 国内精品久久久久影院免费| 97香蕉久久夜色精品国产 | 国产午夜久久影院| 久久亚洲欧美国产精品| 亚洲人成无码网站久久99热国产| 国产精品成人无码久久久久久 | 久久久久九国产精品| 久久er热视频在这里精品| 伊人色综合久久天天人手人婷| 久久亚洲av无码精品浪潮| 91精品国产91热久久久久福利| 男女久久久国产一区二区三区| 亚洲七七久久精品中文国产 | 精品无码久久久久国产动漫3d| 国产亚洲成人久久| 亚洲国产成人久久精品动漫| 丰满少妇人妻久久久久久| 久久国产精品成人影院| 亚洲AV日韩精品久久久久久久| 狠狠色婷婷久久一区二区| 狠狠色丁香久久婷婷综合|