WIN32核心编程 - 线程操作(二) 同步互斥

  • 公开视频 -> 链接点击跳转公开课程
  • 博客首页 -> 链接点击跳转博客主页

目录

竞态条件

CriticalSection

Mutex

CriticalSection & Mutex

Semaphore

Event

竞态条件

  • 多线程环境下，当多个线程同时访问或者修改同一个数据时，最终结果为线程执行的时许。

  • 如果没有同步机制，会发生竞态条件，可能导致数据不准确，或者程序发生异常等。

#include <iostream>
#include <windows.h>DWORD g_Num = 0;DWORD WINAPI WorkThread(LPVOID lp)
{for (size_t i = 0; i < 10000000; i++){//g_Num++;__asm LOCK INC [g_Num] }return 0;
}int main()
{HANDLE hThread[2] = { 0 };hThread[0] = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);hThread[1] = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);WaitForMultipleObjects(2, hThread, TRUE, -1);std::cout << g_Num << std::endl;return 0;
}

CriticalSection

#include <iostream>
#include <windows.h>DWORD g_Num = 0;
CRITICAL_SECTION cs = { 0 };DWORD WINAPI WorkThread(LPVOID lp)
{for (size_t i = 0; i < 1000000; i++){// 进入临界区EnterCriticalSection(&cs);// TODOg_Num++;// 退出临界区LeaveCriticalSection(&cs);}return 0;
}int main()
{HANDLE hThread[2] = { 0 };// 初始临界区InitializeCriticalSection(&cs);hThread[0] = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);hThread[1] = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);WaitForMultipleObjects(2, hThread, TRUE, -1);std::cout << g_Num << std::endl;// 清理临界区DeleteCriticalSection(&cs);return 0;
}

Mutex

  • 互斥体(Mutex)，用于防止多个线程同时访问或修改共享资源。

  • 同一时刻下只有一个线程可以拥有互斥体的所有权，如果一个线程拥有了互斥体的所有权，则其他请求该互斥体的线程将会被阻塞，直到互斥体权限释放。

  • 创建互斥体 - CreateMutex

  • 请求互斥体 - WaitForSingleObject

  • 释放互斥体 - ReleaseMutex

#include <iostream>
#include <windows.h>HANDLE hMutex = 0;
DWORD g_Num = 0;DWORD WINAPI WorkThread(LPVOID lp)
{for (size_t i = 0; i < 100000; i++){WaitForSingleObject(hMutex, INFINITE);g_Num++;ReleaseMutex(hMutex);}return 0;
}int main()
{hMutex = CreateMutex(NULL, FALSE, NULL); HANDLE hThread1 = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);HANDLE hThread2 = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);WaitForSingleObject(hThread1, INFINITE);WaitForSingleObject(hThread2, INFINITE);CloseHandle(hThread1);CloseHandle(hThread2);CloseHandle(hMutex);std::cout << g_Num << std::endl;return 0;
}

CriticalSection & Mutex

  • 临界区

    • 共享资源的线程同步机制，临界区在同一进程的线程之间提供了互斥访问。

    • 每个线程在访问共享资源之前必须先能够进入临界区，在访问结束后离开临界区，完成线程同步。

  • 互斥体

    • 线程同步机制，用来限制多个线程同时访问共享资源。

    • 互斥体可以同步进程或者线程，且可以跨进程同步。
    • #include <iostream>
#include <Windows.h>int main()
{HANDLE hMutex = CreateMutex(NULL, FALSE, L"0xCC_Mutex");if (hMutex == NULL) return 0;if (GetLastError() == ERROR_ALREADY_EXISTS){MessageBox(NULL, L"禁止多开", L"错误", MB_OKCANCEL);return 0;}std::cout << "Game Start..." << std::endl;system("pause");CloseHandle(hMutex);return 0;
}

  • 性能

    • 临界区在同一进程的线程中比互斥体更快。

  • 功能

    • 互斥体可以跨进程同步，但临界区只能够在同一个进程下的线程之间进行同步。

  • 所有权

    • 互斥体有严格的所有权要求，只有拥有互斥体权限的线程才能够释放它。

  • 死锁
    • 当线程在持有锁的情况下意外死亡(异常)
    • 如果线程在持有临界区锁的情况下意外终结，这个锁不会被释放，导致其他等待该临界区的线程无法正常执行，造成死锁。
    • #include <iostream>
#include <Windows.h>CRITICAL_SECTION CriticalSection = { 0 };DWORD WINAPI WorkThread(LPVOID lp)
{EnterCriticalSection(&CriticalSection);printf("TID -> %d \r\n", GetCurrentThreadId());Sleep(5000);LeaveCriticalSection(&CriticalSection);return 0;
}int main()
{InitializeCriticalSection(&CriticalSection);HANDLE hThread1 = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);Sleep(1000);TerminateThread(hThread1, 1);HANDLE hThread2 = CreateThread(NULL, 0, WorkThread, NULL, 0, NULL);WaitForSingleObject(hThread2, INFINITE);DeleteCriticalSection(&CriticalSection);return 0;
}
    • 如果线程在持有互斥体锁的情况下意外终结，Windows会自动释放其所有权，使得其他线程可以继续正常执行。
    • #include <iostream>
#include <Windows.h>HANDLE hMutex = NULL;DWORD WINAPI WorkThread1(LPVOID lp)
{WaitForSingleObject(hMutex, INFINITE);printf("TID -> %d \r\n", GetCurrentThreadId());Sleep(5000);TerminateThread(GetCurrentThread(), -1);//todoreturn 0;
}DWORD WINAPI WorkThread2(LPVOID lp)
{printf("Wait For Thread1 Leave\r\n");WaitForSingleObject(hMutex, INFINITE);printf("TID -> %d \r\n", GetCurrentThreadId());ReleaseMutex(hMutex);return 0;
}int main()
{hMutex = CreateMutex(NULL, FALSE, NULL);HANDLE hThread1 = CreateThread(NULL, 0, WorkThread1, NULL, 0, NULL);Sleep(1000);HANDLE hThread2 = CreateThread(NULL, 0, WorkThread2, NULL, 0, NULL);WaitForSingleObject(hThread2, INFINITE);CloseHandle(hMutex);CloseHandle(hThread1);CloseHandle(hThread2);return 0;
}

Semaphore

  • 信号量是一种同步对象，用于控制多个线程对共享资源的访问。它是一个计数器，用来表示可用资源的数量。当信号量的值大于0，它表示有资源可用；当值为0，表示没有可用资源。

    • 等待：试图减少信号量的值。如果信号量的值大于0，减1并继续执行。如果信号量的值为0，则线程阻塞，直到信号量的值变为大于0。

    • 释放：增加信号量的值。如果有其他线程因等待这个信号量而阻塞，它们中的一个将被唤醒。

  • 创建信号量

    • 在 Windows 系统中，使用 CreateSemaphore 或 CreateSemaphoreEx 函数创建信号量。

  • 等待（Wait）和释放（Release）信号量

    • 等待信号量通常使用 WaitForSingleObject 或 WaitForMultipleObjects 函数。

    • 释放信号量使用 ReleaseSemaphore 函数。

#include <iostream>
#include <Windows.h>#define MAX_COUNT_SEMAPHORE 3HANDLE g_SemapHore = NULL;
HANDLE g_hThreadArr[10] = { 0 };DWORD WINAPI WorkThread(LPVOID lp)
{WaitForSingleObject(g_SemapHore, INFINITE);for (size_t i = 0; i < 10; i++){std::cout << "COUNT -> " << (int)lp << std::endl;Sleep(500);}ReleaseSemaphore(g_SemapHore, 1, NULL);return 0;
}int main()
{g_SemapHore = CreateSemaphore(NULL,						//安全属性MAX_COUNT_SEMAPHORE,		//初始计数MAX_COUNT_SEMAPHORE,		//最大计数NULL						//信号名称);if (g_SemapHore == NULL){std::cout << GetLastError() << std::endl;return 1;}for (size_t i = 0; i < 10; i++){g_hThreadArr[i] = CreateThread(NULL,0,WorkThread,(LPVOID)i,0,NULL);}WaitForMultipleObjects(10, g_hThreadArr, TRUE, INFINITE);//closehandlereturn 0;
}

Event

  • 在Windows编程中，事件是一种同步机制，用于在多个线程之间发送信号。事件对象可以是手动重置或自动重置。

    • 手动重置事件（Manual Reset Event）：当事件被设置（signaled）后，它将保持这个状态直到显式地被重置。这意味着多个等待该事件的线程都可以在事件被重置之前被唤醒。

    • 自动重置事件（Auto Reset Event）：当事件被一个等待的线程接收（signaled）后，系统会自动将事件状态重置为非信号状态（non-signaled）。这意味着每次只允许一个线程被唤醒。

  • 创建事件

    • 使用Windows API函数CreateEvent可以创建一个事件对象

    • lpEventAttributes：指向安全属性的指针，如果设置为NULL，则使用默认安全性。

    • bManualReset：如果为TRUE，则创建一个手动重置事件，否则创建自动重置事件。

    • bInitialState：如果为TRUE，则初始状态为信号状态；如果为FALSE，则为非信号状态。

    • lpName：事件的名称。

  • 设置事件（将事件状态设置为信号状态）使用SetEvent函数

  • 重置事件（将事件状态设置为非信号状态）使用ResetEvent函数

  • 等待事件 等待一个事件对象变为信号状态使用WaitForSingleObject函数

#include <iostream>
#include <Windows.h>DWORD WINAPI WorkThread(LPVOID lp)
{HANDLE hEvent = *(HANDLE*)lp;std::cout << "Thread - " << GetCurrentThreadId() << " Waiting For Event" << std::endl;WaitForSingleObject(hEvent, INFINITE);std::cout << "Thread - " << GetCurrentThreadId() << " actived" << std::endl;return 0;
}int main()
{HANDLE hThreads[3] = { 0 };HANDLE hEvent = NULL;hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);if (hEvent == NULL) return 0;for (size_t i = 0; i < 3; i++){hThreads[i] = CreateThread(NULL, 0, WorkThread, &hEvent, 0, NULL);}Sleep(2000);SetEvent(hEvent);WaitForMultipleObjects(3, hThreads, TRUE, INFINITE);CloseHandle(hEvent);return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/41771.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

探索企业信用巅峰：3A企业认证的魅力与价值

探索企业信用巅峰：3A企业认证的魅力与价值

在现代商业环境中&#xff0c;企业的信用和信誉是其发展的核心要素之一。3A企业认证作为信用评级的最高等级&#xff0c;正在吸引越来越多企业的关注。究竟什么是3A企业认证&#xff1f;它为什么对企业如此重要&#xff1f;本文将深入探讨3A企业认证的独特魅力和巨大价值。 3A企…
阅读更多...
0Day漏洞防御篇：GeoServer CVE-2024-36401远程代码执行漏洞

0Day漏洞防御篇：GeoServer CVE-2024-36401远程代码执行漏洞

GeoServer是一个用Java编写的开源软件服务器&#xff0c;允许用户共享和编辑地理空间数据。它为提供交互操作性而设计&#xff0c;使用开放标准发布来自任何主要空间数据源的数据。GeoServer存在远程代码执行漏洞&#xff08;CVE-2024-36401&#xff09;&#xff0c;未经身份认…
阅读更多...
Spring整合SpringSecurity

Spring整合SpringSecurity

SpringSecurity基础使用 SpringSecurity是一个安全框架&#xff0c;主要功能是认证和授权 从Spring入手SpringSecurity 1. Spring整合SpringSecurity applicationContext.xml <beans xmlns"http://www.springframework.org/schema/beans"xmlns:xsi"http…
阅读更多...
大模型幻觉问题知识点总结

大模型幻觉问题知识点总结

大模型幻觉问题知识点总结 定义&#xff1a; 大模型幻觉问题是指在自然语言处理&#xff08;NLP&#xff09;中&#xff0c;基于大规模预训练模型&#xff08;如GPT-3、BERT等&#xff09;生成的文本看似合理且连贯&#xff0c;但实际上包含错误、不准确或虚假的信息。这种现象…
阅读更多...
Aigtek高压放大器指标有哪些要求和标准

Aigtek高压放大器指标有哪些要求和标准

高压放大器是一类关键的电子设备&#xff0c;用于放大电信号并提供强大的输出。在不同的应用领域&#xff0c;高压放大器可能有不同的要求和标准。以下是一些常见的高压放大器指标要求和标准&#xff0c;以确保其性能和可靠性&#xff1a; 1.幅度增益和频率响应 高压放大器的主…
阅读更多...
人大金仓携手中国一汽引领国产数据库行业新浪潮

人大金仓携手中国一汽引领国产数据库行业新浪潮

在国产化政策的推动下,人大金仓携手中国一汽联合开发更贴近汽车产业特定需求的数据库功能和组件。从2023年2月至今,人大金仓已累计部署690套数据库,适配应用系统170个,支撑中国一汽20多个核心系统和重要系统。目前,中国一汽在国内企业数据库国产化替换率遥遥领先。此次合作为国…
阅读更多...
猫咪健康新选择！福派斯鲜肉猫粮里的果蔬纤维大揭秘

猫咪健康新选择！福派斯鲜肉猫粮里的果蔬纤维大揭秘

你们是不是对福派斯鲜肉猫粮中那些丰富的果蔬粗纤维特别好奇呢&#xff1f;&#x1f914; 其实&#xff0c;这些看似简单的粗纤维&#xff0c;对猫咪的健康可是大有裨益的&#xff01; 粗纤维在猫粮中起到多种重要作用&#xff0c;并且对猫咪的健康和消化系统有着显著的影响。以…
阅读更多...
热门开源项目推荐：探索开源世界的精彩

热门开源项目推荐：探索开源世界的精彩

热门开源项目推荐 随着开源程序的发展&#xff0c;越来越多的程序员开始关注并加入开源大模型的行列。开源不仅为个人学习和成长提供了绝佳的平台&#xff0c;也为整个技术社区带来了创新和进步。无论你是初学者还是经验丰富的开发者&#xff0c;参与开源项目都能让你受益匪浅…
阅读更多...
乡村振兴指数与其30个原始变量数据（Shp/Dta/Excel格式，2000-2022年)

乡村振兴指数与其30个原始变量数据（Shp/Dta/Excel格式，2000-2022年)

数据简介&#xff1a;这份数据是我国各地级市乡村振兴指数与其30各原始变量数据并对其进行地图可视化表达。城镇化是当今中国社会经济发展的必由之路。当前我国城镇化处于发展的关键时期&#xff0c;但城镇化发展的加快却是一把双刃剑&#xff0c;为何要如此形容呢?因为当前城…
阅读更多...
职升网：一级注册计量师就业方向如何？

职升网：一级注册计量师就业方向如何？

首先我们要知道&#xff0c;一级注册计量师可以聘为工程师&#xff0c;可以负责计量基准和标准的量值传递工作。它可以从事一下7个方面的工作&#xff1a; 1.负责制定计量管理制度、工作计划、并组织实施&#xff1b; 2.建设期参与设计工程等计量方面的工作&#xff0c;编制计…
阅读更多...
k8s-第十二节-DaemonSet

k8s-第十二节-DaemonSet

DaemonSet是什么？ DaemonSet 是一个确保全部或者某些节点上必须运行一个 Pod的工作负载资源（守护进程），当有node(节点)加入集群时， 也会为他们新增一个 Pod。 下面是常用的使用案例： 可以用来部署以下进程的pod 集群守护进程，如Kured、node-problem-detector日志收集…
阅读更多...
红黑树模拟实现

红黑树模拟实现

目录 概念 性质 节点定义 红黑树的插入 完整代码 概念 红黑树&#xff0c;是一种二叉搜索树&#xff0c;但在每个结点上增加一个存储位表示结点的颜色&#xff0c;可以是Red或Black。通过对任何一条从根到叶子的路径上各个结点着色方式的限制&#xff0c;红黑树确保没有一条…
阅读更多...
充电桩开源平台，开发流程有图有工具

充电桩开源平台，开发流程有图有工具

慧哥充电桩开源平台产品研发流程是确保产品从概念阶段到市场推广阶段的有序进行的关键。以下是对您给出的步骤的详细解释和建议&#xff1a; 设计业务流程: 在这一步&#xff0c;团队需要确定产品的核心功能、目标用户以及如何满足用户需求。进行市场调研&#xff0c;了解竞争…
阅读更多...
PostMan Error:Maximum response size reached

PostMan Error:Maximum response size reached

一、问题描述 用postman本地测试&#xff0c;restful api接口导出文件&#xff0c;文件大小为190M&#xff0c;服务没问题&#xff0c;总是在导出时&#xff0c;抛出&#xff1a;Error:Maximum response size reached。开始以为是服务相应文件过大或者相应时间超时导致的。其实…
阅读更多...
ts和js的关系

ts和js的关系

https://www.typescriptlang.org/zh/docs/handbook/typescript-from-scratch.html TypeScript&#xff08;TS&#xff09;和 JavaScript&#xff08;JS&#xff09;都是用于开发前端和后端应用的编程语言&#xff0c;但它们有一些显著的区别。以下是主要的区别&#xff1a; 1…
阅读更多...
双向链表 -- 详细理解和实现

双向链表 -- 详细理解和实现

欢迎光顾我的homepage 前言 双向链表是一种带头双向循环的链表。在双向链表中&#xff0c;首先存在着一个头结点&#xff1b;其次每个节点有指向下一个节点的指针next 和指向上一个节点的指针prev &#xff1b…
阅读更多...
Trimble realworks 2024.02 中文激活版获取License下载软件

Trimble realworks 2024.02 中文激活版获取License下载软件

Trimble realworks 2024 是领先的3D点云和2D图像处理解决方案&#xff0c;使用可您提供了一组用于处理的工具&#xff0c;以便为您的应用程序&#xff08;或项目&#xff09;获取必要的信息。此处理可以分为三种模式&#xff0c;在注册中&#xff0c;您可以注册相对于其他扫描和…
阅读更多...
通信协议_Modbus协议简介

通信协议_Modbus协议简介

概念介绍 Modbus协议&#xff1a;一种串行通信协议&#xff0c;是Modicon公司&#xff08;现在的施耐德电气Schneider Electric&#xff09;于1979年为使用可编程逻辑控制器&#xff08;PLC&#xff09;通信而发表。Modbus已经成为工业领域通信协议的业界标准&#xff08;De f…
阅读更多...
大舍传媒：如何在海外新闻媒体发稿报道摩洛哥？

大舍传媒：如何在海外新闻媒体发稿报道摩洛哥？

引言 作为媒体行业的专家&#xff0c;我将分享一些关于在海外新闻媒体发稿报道摩洛哥的干货教程。本教程将带您深入了解三个重要的新闻媒体平台&#xff1a;Mediterranean News、Morocco News和North African News。 地中海Mediterranean News Mediterranean News是一个知名…
阅读更多...
合合信息大模型“加速器”重磅上线

合合信息大模型“加速器”重磅上线

大模型技术的发展和应用&#xff0c;预示着更加智能化、个性化未来的到来。如果将大模型比喻为正在疾驰的科技列车&#xff0c;语料便是珍贵的“燃料”。本次世界人工智能大会期间&#xff0c;合合信息为大模型打造的“加速器”解决方案备受关注。 在大模型训练的上游阶段&…
阅读更多...
最新文章

Copyright @ 2022~2023