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


            污污内射久久一区二区欧美日韩 | 91久久九九无码成人网站| 久久九九兔免费精品6| 天天躁日日躁狠狠久久| 免费国产99久久久香蕉| 伊人久久无码精品中文字幕| 天堂久久天堂AV色综合| 久久丫精品国产亚洲av不卡| 色99久久久久高潮综合影院| 99久久这里只精品国产免费 | 99久久精品国产一区二区| 精品久久久久久无码人妻热| a高清免费毛片久久| 2021最新久久久视精品爱| 精品久久久久久国产潘金莲| 偷窥少妇久久久久久久久| 99久久99这里只有免费的精品| 久久精品国产色蜜蜜麻豆| 国产成人99久久亚洲综合精品| 久久夜色精品国产亚洲| 免费久久人人爽人人爽av| 久久精品免费观看| 精品久久久久久久| 亚洲国产精品无码久久一线| 精品久久久无码中文字幕天天 | 欧美精品福利视频一区二区三区久久久精品 | 色综合久久最新中文字幕| 久久久高清免费视频| 国产成人久久精品二区三区| 2019久久久高清456| 久久综合精品国产一区二区三区| 久久人人爽人人爽人人片AV麻烦| 国产精品成人无码久久久久久 | 99久久国产综合精品麻豆| 亚洲国产精品久久电影欧美| 久久亚洲sm情趣捆绑调教| 天天综合久久一二三区| 久久乐国产综合亚洲精品| 久久国内免费视频| 尹人香蕉久久99天天拍| 久久久久亚洲精品日久生情|