[C++知识库] 进程间通信-互斥锁

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> C++知识库 -> 进程间通信-互斥锁 -> 正文阅读

[C++知识库]进程间通信-互斥锁

CreateMutex()//创建一个互斥体,已经存在会直接返回句柄
OpenMutex()//打开一个互斥体
WaitForSingleObject()//尝试加锁
ReleaseMutex()//解锁
进程间互斥通过互斥锁的名称进行

//进程1

#define _CRT_SECURE_NO_WARNINGS
#include <iostream>
#include <windows.h>
using namespace std;


class MyClass
{
public:
    MyClass(string lockName) 
    {
        name= lockName;
    };
    ~MyClass() 
    {
        CloseHandle(hMutex);
        hMutex = NULL;
    };

    void Lock() 
    {
        hMutex = CreateMutex(NULL, false, name.c_str());
        while (WaitForSingleObject(hMutex, INFINITE) != WAIT_OBJECT_0) //INFINITE 阻塞方式，效率低
        {
            Sleep(1);
        };

    }

    void UnLock() 
    {
        hMutex = CreateMutex(NULL, false, name.c_str());
        ReleaseMutex(hMutex);
    }
private:
    HANDLE hMutex;
    string name;
};

static MyClass* myLock = new MyClass("mypmutex");


string GetTime()
{
    SYSTEMTIME sys;
    GetLocalTime(&sys);
    char temp[256];
    char name[256];
    sprintf(temp, "%4d-%02d-%02d %02d:%02d:%02d-",
        sys.wYear, sys.wMonth,
        sys.wDay, sys.wHour,
        sys.wMinute, sys.wSecond);


    std::string inStr;
    inStr += temp;

    return inStr;
}

int main()
{
   
    for (int i = 0;i < 10; i++)
    {
        // 申请对互斥量的占有
        myLock->Lock();
        // 模拟对公共内存/文件的操作
        cout << GetTime() << "begin sleep" << endl;
        Sleep(5000);
        cout << GetTime() << "process 2222222222222222222" << endl;
        myLock->UnLock();
        // 操作完毕，释放对互斥量的占有
        cout << GetTime() << "reslease ok" << endl;
        Sleep(2000);
    }

    return 0;
}

//进程2

#define _CRT_SECURE_NO_WARNINGS
#include <iostream>
#include <windows.h>
using namespace std;


class MyClass
{
public:
    MyClass(string lockName)
    {
        name = lockName;
    };
    ~MyClass()
    {
        CloseHandle(hMutex);
        hMutex = NULL;
    };

    void Lock()
    {
        hMutex = CreateMutex(NULL, false, name.c_str());
        while (WaitForSingleObject(hMutex, INFINITE) != WAIT_OBJECT_0) //INFINITE 阻塞方式，效率低
        {
            Sleep(1);
        };

    }

    void UnLock()
    {
        hMutex = CreateMutex(NULL, false, name.c_str());
        ReleaseMutex(hMutex);
    }
private:
    HANDLE hMutex;
    string name;
};

static MyClass* myLock = new MyClass("mypmutex");


string GetTime()
{
    SYSTEMTIME sys;
    GetLocalTime(&sys);
    char temp[256];
    char name[256];
    sprintf(temp, "%4d-%02d-%02d %02d:%02d:%02d-",
        sys.wYear, sys.wMonth,
        sys.wDay, sys.wHour,
        sys.wMinute, sys.wSecond);


    std::string inStr;
    inStr += temp;

    return inStr;
}

int main()
{

    for (int i = 0;i < 10; i++)
    {
        // 申请对互斥量的占有
        myLock->Lock();
        // 模拟对公共内存/文件的操作
        cout << GetTime() << "begin sleep" << endl;
        Sleep(5000);
        cout << GetTime() << "process 111111111111111111111111111" << endl;
        myLock->UnLock();
        // 操作完毕，释放对互斥量的占有
        cout << GetTime() << "reslease ok" << endl;
        Sleep(2000);
    }

    return 0;
}

参考：
1.https://blog.csdn.net/cainiaoxunchong/article/details/19089991
2.https://blog.csdn.net/u013659062/article/details/101086972
3.https://blog.csdn.net/icebergliu1234/article/details/104665904