线程同步（一）—— 互斥锁

#include <pthread.h>  
#include <unistd.h>  
#include <iostream>

using namespace std;

class ThreadInterface
{
public:
    void CreateThread(void* (*func)(void *));
    void WaitThread();
private:
    pthread_t m_pTread;   
};

void ThreadInterface::CreateThread(void* (*func)(void *))
{
    pthread_create(&m_pTread, NULL, func, NULL); 
}

void ThreadInterface::WaitThread()
{
    pthread_join(m_pTread, NULL); 
}

class MutexLockInterface
{
public:
    void CreateMutexLock();
    void GetMutexLock();
    void ReleaseMutexLock();
    void DestroyMutexLock();
private:  
    pthread_mutex_t m_MutexLock;  
};

void MutexLockInterface::CreateMutexLock()
{
    int ret = pthread_mutex_init(&m_MutexLock, NULL);
    if (0 != ret)
        cout<<"init mutex error!";
}

void MutexLockInterface::GetMutexLock()
{
    pthread_mutex_lock(&m_MutexLock);
}

void MutexLockInterface::ReleaseMutexLock()
{
    pthread_mutex_unlock(&m_MutexLock);
}

void MutexLockInterface::DestroyMutexLock()
{
    pthread_mutex_destroy(&m_MutexLock);
}


class Service
{
public:
    static void* run(void *)    //类成员线程函数为static去除this指针
    {
        //m_MutexLock.GetMutexLock();
        if (0 == m_Tickets)
        {
            cout<<"stop operate!"<<endl;
        }
        else
        {
            cout<<"window2:we have "<<m_Tickets<<"Tickets"<<endl;
            sleep(1);
            --m_Tickets;
        }
        //m_MutexLock.ReleaseMutexLock();
    }
    int SetData(int data){m_Tickets = data;};
    int GetData(){return m_Tickets;};
    static int m_Tickets;
    static MutexLockInterface m_MutexLock;
};
int Service::m_Tickets = 1; //静态变量类外初始化
MutexLockInterface Service::m_MutexLock;

int main()
{
    Service Srv;
    ThreadInterface Thread;
    Srv.m_MutexLock.CreateMutexLock();
    
    Thread.CreateThread(&Srv.run);

    //Srv.m_MutexLock.GetMutexLock();
    if (0 == Srv.GetData())
    {
        cout<<"stop operate!"<<endl;
    }
    else
    {
        cout<<"window1:we have "<<Srv.GetData()<<"Tickets"<<endl;
        sleep(1);　　//延时1s等待线程2
        Srv.SetData(Srv.GetData() - 1);
    }
    //Srv.m_MutexLock.ReleaseMutexLock();
    Thread.WaitThread();    //等待线程结束回收
    cout<<Srv.GetData()<<endl;
    return 0;
}