牽著老婆滿街逛

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

統計

隨筆 - 1513
文章 - 45
評論 - 907
引用 - 0

公告

言論：
1.每日自省；
2.享受人生；
3.盡力而為；
4.堅持不懈；
5.切莫急躁；
6.慎言敏行；
7.動心忍性；
8.上善若水。

常用鏈接

留言簿(11)

隨筆分類(466)

隨筆檔案(1513)

文章分類(46)

文章檔案(45)

相冊

收藏夾(39)

搜索

積分與排名

積分 - 2530813
排名 - 2

閱讀排行榜

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

一些適用于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 楊粼波閱讀(455) 評論(0) 編輯收藏引用

只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

牽著老婆滿街逛

導航

統計

公告

常用鏈接

留言簿(11)

隨筆分類(466)

隨筆檔案(1513)

文章分類(46)

文章檔案(45)

相冊

收藏夾(39)

工具官網

技術網站

開源網站

其他窩點

收藏網站

銀行官網

友情鏈接

資源共享

搜索

積分與排名

最新評論

閱讀排行榜

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