常常需要使用pthread_mutex線程同步，每次都要使用pthread_mutex_init, pthread_mutex_lock, pthread_unlock, pthread_mutex_destroy這幾個函數，干脆封裝一下，以便以后重用。
//Mutex.cpp
#include <pthread.h>
#include <iostream>
using namespace std;
class ThreadMutex
{
public:
ThreadMutex()
{
pthread_mutex_init(&mtx, NULL);
}
~ThreadMutex()
{
pthread_mutex_destroy( &mtx );
}
inline void Lock()
{
pthread_mutex_lock( &mtx );
}
inline void UnLock()
{
pthread_mutex_unlock( &mtx );
}
private:
pthread_mutex_t mtx;
};
//以下為測試用例
ThreadMutex g_Mutex;
void *PrintMsg(void *lpPara)
{
char *msg = (char *)lpPara;
g_Mutex.Lock();
for(int i=0; i< 5; i++ )
{
cout << msg << endl;
sleep( 1 );
}
g_Mutex.UnLock();
return NULL;
}
int main()
{
pthread_t t1,t2;
//創建兩個工作線程，第1個線程打印10個1，第2個線程打印10個2。
pthread_create( &t1, NULL, &PrintMsg, (void *)"First print thread" );
pthread_create( &t2, NULL, &PrintMsg, (void *)"Second print thread" );
//等待線程結束
pthread_join( t1, NULL);
pthread_join( t2, NULL);
return 0;
}
通過g++ -o Mutex Mutex.cpp -lpthread編譯。