Linux和windows进程同步与线程同步那些事儿（四）：windows 下进程同步

2024-01-11 19:52
文章标签 linux 线程 windows 同步 进程同步 事儿

本文主要是介绍Linux和windows进程同步与线程同步那些事儿（四）：windows 下进程同步，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Linux和windows进程同步与线程同步那些事儿（一）
Linux和windows进程同步与线程同步那些事儿（二）： windows线程同步详解示例
Linux和windows进程同步与线程同步那些事儿（三）： Linux线程同步详解示例
Linux和windows进程同步与线程同步那些事儿（四）：windows 下进程同步
Linux和windows进程同步与线程同步那些事儿（五）：Linux下进程同步

1. 互斥量（Mutex）：

互斥量是最常用的线程同步机制，它可以确保在同一时间只有一个线程可以访问共享资源。
在Windows中，可以使用CreateMutex函数来创建互斥量。

下面是一个使用互斥量实现进程同步的代码示例。该示例展示了两个进程之间如何使用互斥量来保证共享资源的互斥访问。

#include <iostream>
#include <windows.h>int main() {// 创建互斥量对象HANDLE hMutex = CreateMutex(NULL, FALSE, "MyMutex");if (hMutex == NULL) {std::cout << "互斥量创建失败！" << std::endl;return 1;}// 尝试获取互斥量的所有权DWORD dwWaitResult = WaitForSingleObject(hMutex, INFINITE);if (dwWaitResult == WAIT_OBJECT_0) {std::cout << "进程A获得了互斥量的所有权！" << std::endl;// 模拟共享资源的访问std::cout << "进程A正在访问共享资源..." << std::endl;Sleep(5000);// 释放互斥量的所有权ReleaseMutex(hMutex);std::cout << "进程A释放了互斥量的所有权！" << std::endl;}else {std::cout << "进程A无法获取互斥量的所有权！" << std::endl;}// 关闭互斥量句柄CloseHandle(hMutex);return 0;
}

#include <iostream>
#include <windows.h>int main() {// 创建互斥量对象HANDLE hMutex = CreateMutex(NULL, FALSE, "MyMutex");if (hMutex == NULL) {std::cout << "互斥量创建失败！" << std::endl;return 1;}// 尝试获取互斥量的所有权DWORD dwWaitResult = WaitForSingleObject(hMutex, INFINITE);if (dwWaitResult == WAIT_OBJECT_0) {std::cout << "进程B获得了互斥量的所有权！" << std::endl;// 模拟共享资源的访问std::cout << "进程B正在访问共享资源..." << std::endl;Sleep(3000);// 释放互斥量的所有权ReleaseMutex(hMutex);std::cout << "进程B释放了互斥量的所有权！" << std::endl;}else {std::cout << "进程B无法获取互斥量的所有权！" << std::endl;}// 关闭互斥量句柄CloseHandle(hMutex);return 0;
}

在上面的代码示例中，进程A和进程B都通过调用CreateMutex函数来创建了一个名为"MyMutex"的互斥量对象。接着，它们分别调用WaitForSingleObject函数来尝试获取互斥量的所有权。

如果某个进程成功获取了互斥量的所有权（即dwWaitResult的值为WAIT_OBJECT_0），那么它就可以访问共享资源。在示例中，为了模拟共享资源的访问，我们使用了Sleep函数来暂停程序的执行。

完成对共享资源的访问后，进程需要调用ReleaseMutex函数来释放互斥量的所有权，以便其他进程可以获取互斥量的所有权。

最后，进程要调用CloseHandle函数来关闭互斥量句柄，释放系统资源。

请注意，这只是一个简单的示例，实际的应用中可能还需要处理异常情况、错误处理等。

2. 事件（Event）：

事件用于线程间的通信和同步，允许线程等待某个特定事件的发生。
在Windows中，可以使用CreateEvent函数来创建事件对象。

下面是一个使用事件(Event)实现进程同步的代码示例。该示例展示了两个进程之间如何使用事件来进行进程同步。

#include <iostream>
#include <windows.h>int main() {// 创建事件对象HANDLE hEvent = CreateEvent(NULL, FALSE, FALSE, "MyEvent");if (hEvent == NULL) {std::cout << "事件创建失败！" << std::endl;return 1;}// 等待事件变为有信号状态DWORD dwWaitResult = WaitForSingleObject(hEvent, INFINITE);if (dwWaitResult == WAIT_OBJECT_0) {std::cout << "进程A检测到事件有信号！" << std::endl;// 执行需要同步的操作std::cout << "进程A正在执行同步操作..." << std::endl;Sleep(5000);std::cout << "进程A完成同步操作！" << std::endl;}else {std::cout << "进程A等待事件超时或发生其他错误！" << std::endl;}// 关闭事件句柄CloseHandle(hEvent);return 0;
}

#include <iostream>
#include <windows.h>int main() {// 打开事件对象HANDLE hEvent = OpenEvent(EVENT_MODIFY_STATE, FALSE, "MyEvent");if (hEvent == NULL) {std::cout << "事件打开失败！" << std::endl;return 1;}// 设置事件为有信号状态if (SetEvent(hEvent)) {std::cout << "进程B设置了事件的信号！" << std::endl;}else {std::cout << "进程B设置事件的信号失败！" << std::endl;}// 关闭事件句柄CloseHandle(hEvent);return 0;
}

在上面的代码示例中，进程A通过调用CreateEvent函数来创建了一个名为"MyEvent"的事件对象。而进程B则通过调用OpenEvent函数来打开同一个事件对象。

进程A调用WaitForSingleObject函数来等待事件变为有信号状态。一旦事件有信号，进程A就可以执行需要同步的操作。在示例中，我们使用了Sleep函数来模拟同步操作的执行。

进程B在需要进行同步的时候，调用SetEvent函数来设置事件的信号。这样，进程A就会被唤醒，继续执行同步操作。

请注意，事件对象具有自动复位（auto-reset）的特性，即一旦某个等待事件的进程被唤醒，事件会自动重置为无信号状态，其他等待事件的进程将继续等待。

最后，进程要调用CloseHandle函数来关闭事件句柄，释放系统资源。

3. 临界区（Critical Section）：

临界区用于保护共享资源，确保在同一时间只有一个线程可以访问。
在Windows中，可以使用InitializeCriticalSection函数来初始化临界区。

下面是一个使用临界区(Critical Section)实现进程同步的代码示例。该示例展示了两个进程之间如何使用临界区来进行进程同步。

#include <iostream>
#include <windows.h>CRITICAL_SECTION g_cs;  // 全局临界区对象int main() {// 初始化临界区InitializeCriticalSection(&g_cs);// 进入临界区EnterCriticalSection(&g_cs);std::cout << "进程A进入临界区，执行同步操作..." << std::endl;Sleep(5000);  // 模拟同步操作std::cout << "进程A完成同步操作，退出临界区！" << std::endl;// 离开临界区LeaveCriticalSection(&g_cs);// 销毁临界区DeleteCriticalSection(&g_cs);return 0;
}

#include <iostream>
#include <windows.h>CRITICAL_SECTION g_cs;  // 全局临界区对象int main() {// 初始化临界区InitializeCriticalSection(&g_cs);// 进入临界区EnterCriticalSection(&g_cs);std::cout << "进程B进入临界区，执行同步操作..." << std::endl;Sleep(5000);  // 模拟同步操作std::cout << "进程B完成同步操作，退出临界区！" << std::endl;// 离开临界区LeaveCriticalSection(&g_cs);// 销毁临界区DeleteCriticalSection(&g_cs);return 0;
}

在上面的代码示例中，我们使用CRITICAL_SECTION类型的全局变量g_cs作为临界区对象。

进程A和进程B都会初始化临界区对象，进入临界区进行同步操作。

在示例中，我们使用了Sleep函数来模拟同步操作的执行。

进程A和进程B在完成同步操作后，都需要离开临界区。

最后，进程要调用DeleteCriticalSection函数来销毁临界区对象，释放系统资源。

请注意，临界区是进程内的同步机制，不适用于跨进程的同步。如果需要跨进程的同步，可以考虑使用互斥量(Mutex)或事件(Event)等其他机制。

4. 信号量（Semaphore）：

信号量是一种经典的线程同步机制，它可以用于控制对共享资源的访问。
在Windows中，可以使用CreateSemaphore函数来创建信号量。

下面是一个使用信号量(Semaphore)实现进程同步的代码示例。该示例展示了两个进程之间如何使用信号量来进行进程同步。

#include <iostream>
#include <windows.h>HANDLE g_semaphore;  // 全局信号量句柄int main() {// 创建一个信号量，初始值为0，用于进程同步g_semaphore = CreateSemaphore(NULL, 0, 1, L"ProcessSync");std::cout << "进程A执行同步操作..." << std::endl;Sleep(5000);  // 模拟同步操作std::cout << "进程A完成同步操作，释放信号量！" << std::endl;ReleaseSemaphore(g_semaphore, 1, NULL);  // 释放信号量，允许进程B执行// 关闭信号量句柄CloseHandle(g_semaphore);return 0;
}

#include <iostream>
#include <windows.h>HANDLE g_semaphore;  // 全局信号量句柄int main() {// 创建一个信号量，初始值为0，用于进程同步g_semaphore = CreateSemaphore(NULL, 0, 1, L"ProcessSync");// 进程B等待信号量，直到进程A释放信号量WaitForSingleObject(g_semaphore, INFINITE);std::cout << "进程B执行同步操作..." << std::endl;Sleep(5000);  // 模拟同步操作std::cout << "进程B完成同步操作，释放信号量！" << std::endl;ReleaseSemaphore(g_semaphore, 1, NULL);  // 释放信号量，允许其他进程执行// 关闭信号量句柄CloseHandle(g_semaphore);return 0;
}

在上面的示例代码中，我们使用了HANDLE类型的全局变量g_semaphore作为信号量句柄。
进程A创建了一个名为"ProcessSync"的信号量，并执行同步操作之后，调用ReleaseSemaphore函数释放信号量。

进程B在等待信号量状态下，调用WaitForSingleObject函数等待进程A释放信号量，然后执行同步操作。
最后，进程要调用CloseHandle函数来关闭信号量句柄，释放系统资源。

请注意，信号量是一种用于进程间同步的机制，可以在不同进程之间实现同步。在示例中，我们使用了一个简单的二进制信号量，它的初始值为0，进程A通过ReleaseSemaphore函数将其值设置为1，使进程B可以继续执行。

5. 命名管道（Named Pipe）：

命名管道是一种进程间通信的机制，可以用于实现进程间的数据交换和同步。
在Windows中，可以使用CreateNamedPipe函数来创建命名管道。

在 Windows 下，可以使用命名管道（Named Pipe）实现多进程间的同步。命名管道是一种特殊的文件，用于在不同进程间进行通信。下面是一个使用命名管道实现多进程同步的 C++ 代码示例：

进程A：写入数据

#include <iostream>
#include <windows.h>int main()
{HANDLE hPipe;// 创建命名管道LPCWSTR pipeName = TEXT("\\\\.\\pipe\\my_pipe");hPipe = CreateNamedPipe(pipeName,PIPE_ACCESS_DUPLEX,PIPE_TYPE_MESSAGE | PIPE_WAIT,1,              // 最大实例数65536,          // 输出缓冲区大小65536,          // 输入缓冲区大小0,              // 默认超时时间NULL            // 安全属性);// 等待进程B连接ConnectNamedPipe(hPipe, NULL);// 向管道写入数据const char* data = "Hello, World!";DWORD bytesWritten;WriteFile(hPipe, data, strlen(data) + 1, &bytesWritten, NULL);// 关闭管道DisconnectNamedPipe(hPipe);CloseHandle(hPipe);return 0;
}

进程B：读取数据

#include <iostream>
#include <windows.h>int main()
{HANDLE hPipe;// 连接到命名管道LPCWSTR pipeName = TEXT("\\\\.\\pipe\\my_pipe");hPipe = CreateFile(pipeName,GENERIC_READ,0,              // 共享模式NULL,           // 安全属性OPEN_EXISTING,0,              // 属性和标志NULL            // 模板文件);// 从管道读取数据char buffer[65536];DWORD bytesRead;ReadFile(hPipe, buffer, sizeof(buffer), &bytesRead, NULL);// 打印数据std::cout << buffer << std::endl;// 关闭管道CloseHandle(hPipe);return 0;
}

上述代码中，进程A创建了一个命名管道，并等待进程B连接。然后，它向管道写入数据。进程B连接到同一个命名管道，并读取进程A写入的数据。

让我们更详细地解释一下代码：

  1. 在进程A中，CreateNamedPipe 函数用于创建命名管道。参数 pipeName 指定了命名管道的名称，格式为 \\.\pipe\pipeName。其他参数设置了管道的访问权限、缓冲区大小等。

  2. 进程A调用 ConnectNamedPipe 函数等待进程B连接。

  3. 进程A使用 WriteFile 函数向管道写入数据。

  4. 进程B使用 CreateFile 函数连接到命名管道。

  5. 进程B调用 ReadFile 函数从管道中读取数据。

  6. 最后，进程B关闭了管道。

在实际使用中，可以根据需要对代码进行修改和扩展，以满足你的具体需求。例如，你可以使用多线程创建多个进程，或者通过命名管道进行双向通信。

6. 共享内存（Shared Memory）：

共享内存允许多个进程访问同一块内存区域，从而实现进程间的数据共享和通信。
在Windows中，可以使用CreateFileMapping和MapViewOfFile等函数来创建和访问共享内存区域。

下面是一个使用共享内存在Windows下实现多个进程同步的代码示例：

#include <iostream>
#include <Windows.h>// 共享内存结构体
struct SharedData {HANDLE mutex;         // 互斥量HANDLE event;         // 事件CONDITION_VARIABLE conditionVariable; // 条件变量int counter;          // 共享计数器
};int main() {// 创建共享内存HANDLE hMapFile = CreateFileMapping(INVALID_HANDLE_VALUE,nullptr,PAGE_READWRITE,0,sizeof(SharedData),L"MySharedMemory");if (hMapFile == NULL) {std::cerr << "Failed to create shared memory" << std::endl;return 1;}// 获取共享内存指针SharedData* sharedData = (SharedData*)MapViewOfFile(hMapFile,FILE_MAP_ALL_ACCESS,0,0,sizeof(SharedData));if (sharedData == NULL) {std::cerr << "Failed to map shared memory" << std::endl;CloseHandle(hMapFile);return 1;}// 初始化互斥量、事件和条件变量sharedData->mutex = CreateMutex(nullptr, FALSE, nullptr);sharedData->event = CreateEvent(nullptr, FALSE, FALSE, nullptr);InitializeConditionVariable(&sharedData->conditionVariable);sharedData->counter = 0;// 创建多个进程进行同步操作for (int i = 0; i < 5; i++) {STARTUPINFO si = {};PROCESS_INFORMATION pi = {};wchar_t cmdLine[] = L"ChildProcess.exe"; // 子进程程序名// 启动子进程if (!CreateProcess(nullptr,cmdLine,nullptr,nullptr,FALSE,0,nullptr,nullptr,&si,&pi)) {std::cerr << "Failed to create child process" << std::endl;CloseHandle(hMapFile);return 1;}// 关闭子进程句柄CloseHandle(pi.hThread);CloseHandle(pi.hProcess);}// 等待所有子进程执行完毕WaitForMultipleObjects(5, sharedData->processHandles, TRUE, INFINITE);// 输出计数器值std::cout << "Counter = " << sharedData->counter << std::endl;// 释放资源UnmapViewOfFile(sharedData);CloseHandle(sharedData->mutex);CloseHandle(sharedData->event);CloseHandle(hMapFile);return 0;
}

这个示例中，首先创建了一个共享内存来存储互斥量、事件和条件变量等同步对象以及一个共享计数器。然后创建了多个子进程，在子进程中进行同步操作。

子进程代码示例（ChildProcess.exe）：

#include <iostream>
#include <Windows.h>struct SharedData {HANDLE mutex;HANDLE event;CONDITION_VARIABLE conditionVariable;int counter;
};int main() {HANDLE hMapFile = OpenFileMapping(FILE_MAP_ALL_ACCESS,FALSE,L"MySharedMemory");if (hMapFile == NULL) {std::cerr << "Failed to open shared memory" << std::endl;return 1;}SharedData* sharedData = (SharedData*)MapViewOfFile(hMapFile,FILE_MAP_ALL_ACCESS,0,0,sizeof(SharedData));if (sharedData == NULL) {std::cerr << "Failed to map shared memory" << std::endl;CloseHandle(hMapFile);return 1;}// 等待主进程通知WaitForSingleObject(sharedData->event, INFINITE);// 互斥量保护临界区WaitForSingleObject(sharedData->mutex, INFINITE);// 执行同步操作sharedData->counter++;std::cout << "Child process counter = " << sharedData->counter << std::endl;// 离开临界区ReleaseMutex(sharedData->mutex);// 通知主进程完成WakeConditionVariable(&sharedData->conditionVariable);// 释放资源UnmapViewOfFile(sharedData);CloseHandle(hMapFile);return 0;
}

在子进程中，首先打开共享内存，并获取共享内存指针。然后等待主进程通知，获取互斥量保护临界区，执行同步操作，离开临界区，通知主进程完成，并释放资源。

总结

互斥量（mutex）：
适用场景：多个进程需要争夺同一个资源时，只能有一个进程访问资源。
优点：简单易用，能够实现多个进程间的互斥访问。
缺点：性能较低，需要进行系统调用，可能引起上下文切换开销。

事件（event）：
适用场景：多个进程需要等待某个特定事件的发生后才能继续执行。
优点：可以在多个进程之间进行高效的同步。
缺点：只能用于单个事件的同步，不能用于争夺资源的同步。

临界区（critical section）：
适用场景：多个进程需要访问共享资源时，只能有一个进程访问资源。
优点：具有较高的性能，适用于保护共享资源的场景。
缺点：只能用于同一个进程内的进程同步，不能用于跨进程同步。

信号量（semaphore）：
适用场景：多个进程需要访问有限数量的资源时，控制同时访问的进程数量。
优点：可以用于控制同时访问资源的进程数量。
缺点：较复杂，容易引发死锁问题。

命名管道（named pipe）：
适用场景：多个进程之间进行双向通信和同步。
优点：提供了进程间的可靠通信和同步机制。
缺点：性能较低，只能用于进程之间的通信和同步。

共享内存（shared memory）：
适用场景：多个进程需要共享大块数据时。
优点：高效的进程间通信，能够实现数据共享。
缺点：需要进行同步，容易引发数据不一致或竞态条件。

综合比较：

  • 互斥量 : 适用于争夺单个资源的情况，使用简单，但性能较低。
  • 事件 : 适用于等待特定事件发生后才能继续执行的场景，同步效率高。
  • 临界区: 适用于保护共享资源的场景，性能较高。
  • 信号量: 适用于控制同时访问资源的进程数量，但使用较复杂，容易产生死锁。
  • 命名管道: 适用于进程间的通信和同步，但性能较低。
  • 共享内存: 适用于共享大块数据的场景，需要进行同步操作，可能引发竞态条件。

根据具体的场景和需求，可以选择合适的进程同步机制来实现进程间的同步和通信。

这篇关于Linux和windows进程同步与线程同步那些事儿（四）：windows 下进程同步的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/595523。

相关文章

Linux内核的调试（TODO）

Linux内核的调试（TODO）

（TODO）
阅读更多...
基于MySQL Binlog的Elasticsearch数据同步实践

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展，我们的业务数据越来越多，单纯使用 MySQL 已经不能满足我们的数据查询需求，例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后，随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步，我们目前的解决方案是建立数据中间表。把需要检索的业务数据，统一放到一张M
阅读更多...
服务器集群同步时间手记

服务器集群同步时间手记

1.时间服务器配置（必须root用户） （1）检查ntp是否安装 [root@node1 桌面]# rpm -qa|grep ntpntp-4.2.6p5-10.el6.centos.x86_64fontpackages-filesystem-1.41-1.1.el6.noarchntpdate-4.2.6p5-10.el6.centos.x86_64 （2）修改ntp配置文件 [r
阅读更多...
linux-基础知识3

linux-基础知识3

打包和压缩 zip 安装zip软件包 yum -y install zip unzip 压缩打包命令: zip -q -r -d -u 压缩包文件名 目录和文件名列表 -q:不显示命令执行过程-r:递归处理，打包各级子目录和文件-u:把文件增加/替换到压缩包中-d:从压缩包中删除指定的文件 解压:unzip 压缩包名 打包文件 把压缩包从服务器下载到本地 把压缩包上传到服务器(zip
阅读更多...
Linux 网络编程 --- 应用层

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码： 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口，https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor
阅读更多...
【Python编程】Linux创建虚拟环境并配置与notebook相连接

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如，在当前目录下创建一个名为 myenv 的虚拟环境： python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行： source myenv/bin/activate 3.与notebook连接 在虚拟环境中，使用 pip 安装 Jupyter 和 ipykernel： pip instal
阅读更多...
Linux_kernel驱动开发11

Linux_kernel驱动开发11

一、改回nfs方式挂载根文件系统         在产品将要上线之前，需要制作不同类型格式的根文件系统         在产品研发阶段，我们还是需要使用nfs的方式挂载根文件系统         优点：可以直接在上位机中修改文件系统内容，延长EMMC的寿命         【1】重启上位机nfs服务         sudo service nfs-kernel-server resta
阅读更多...
【Linux 从基础到进阶】Ansible自动化运维工具使用

【Linux 从基础到进阶】Ansible自动化运维工具使用

Ansible自动化运维工具使用 Ansible 是一款开源的自动化运维工具，采用无代理架构（agentless），基于 SSH 连接进行管理，具有简单易用、灵活强大、可扩展性高等特点。它广泛用于服务器管理、应用部署、配置管理等任务。本文将介绍 Ansible 的安装、基本使用方法及一些实际运维场景中的应用，旨在帮助运维人员快速上手并熟练运用 Ansible。 1. Ansible的核心概念
阅读更多...
Linux服务器Java启动脚本

Linux服务器Java启动脚本

Linux服务器Java启动脚本 1、初版2、优化版本3、常用脚本仓库 本文章介绍了如何在Linux服务器上执行Java并启动jar包， 通常我们会使用nohup直接启动，但是还是需要手动停止然后再次启动， 那如何更优雅的在服务器上启动jar包呢，让我们一起探讨一下吧。 1、初版 第一个版本是常用的做法，直接使用nohup后台启动jar包， 并将日志输出到当前文件夹n
阅读更多...
[Linux]：进程(下)

[Linux]：进程(下)

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 🎈🎈养成好习惯，先赞后看哦~🎈🎈 所属专栏：Linux学习 贝蒂的主页：Betty’s blog 1. 进程终止 1.1 进程退出的场景 进程退出只有以下三种情况： 代码运行完毕，结果正确。代码运行完毕，结果不正确。代码异常终止（进程崩溃）。 1.2 进程退出码 在编程中，我们通常认为main函数是代码的入口，但实际上它只是用户级
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2