c++ 类似与c# 线程 AutoResetEvent 和 ManualResetEvent的实现

在 C++ 中,没有直接类似于 C# 的 AutoResetEventManualResetEvent 的类,但可以通过一些线程同步机制来实现类似的功能。C++ 提供了一些线程同步原语,如 std::condition_variablestd::mutex,这些可以用来模拟类似于 C# 中 AutoResetEventManualResetEvent 的行为。

AutoResetEventManualResetEvent 的基本区别

  • AutoResetEvent:每次信号被设置后,它只能唤醒一个等待线程,且会自动重置为未信号状态。
  • ManualResetEvent:每次信号被设置后,它会保持信号状态,直到被显式重置,所有等待线程都会被唤醒。

C++ 中的替代方案

1. 使用 std::condition_variable 来实现 AutoResetEvent

在 C++ 中,std::condition_variable 可以用来模拟类似于 AutoResetEvent 的行为。std::condition_variable 会让线程在某个条件上等待,当条件满足时,通知一个或所有等待的线程继续执行。

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <chrono>class AutoResetEvent {
public:AutoResetEvent(bool initial_state = false): signaled(initial_state) {}// 唤醒一个线程void Set() {std::lock_guard<std::mutex> lock(mutex_);signaled = true;cv_.notify_one();  // 唤醒一个等待线程}// 等待线程被唤醒void Wait() {std::unique_lock<std::mutex> lock(mutex_);cv_.wait(lock, [this]() { return signaled; });  // 等待直到 signaled 为 truesignaled = false;  // 唤醒后自动重置为未信号状态}private:bool signaled;  // 是否处于信号状态std::mutex mutex_;std::condition_variable cv_;
};void ThreadA(AutoResetEvent& are)
{std::cout << "线程A开始等待...\n";are.Wait();std::cout << "线程A被唤醒,继续执行\n";
}void ThreadB(AutoResetEvent& are)
{std::this_thread::sleep_for(std::chrono::seconds(2));std::cout << "线程B设置信号\n";are.Set();
}int main() {AutoResetEvent are;std::thread t1(ThreadA, std::ref(are));  // 线程A等待std::thread t2(ThreadB, std::ref(are));  // 线程B设置信号t1.join();t2.join();return 0;
}

代码说明:

  • AutoResetEvent:封装了 std::condition_variablestd::mutex,并通过一个布尔变量 signaled 来标记是否处于信号状态。调用 Set() 方法时会唤醒一个等待线程,调用 Wait() 方法时会让当前线程等待信号。
  • Wait():当 signaledtrue 时,线程会被唤醒,并且 signaled 会自动重置为 false,就像 AutoResetEvent 的行为。

2. 使用 std::condition_variablestd::atomic<bool> 来实现 ManualResetEvent

AutoResetEvent 类似,ManualResetEvent 会在 Set() 后保持信号状态,直到调用 Reset()。可以通过使用 std::atomic<bool> 来维护信号状态,这样可以使多个线程在 Set() 后被唤醒。

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <atomic>
#include <chrono>class ManualResetEvent {
public:ManualResetEvent(bool initial_state = false): signaled(initial_state) {}// 唤醒所有等待线程void Set() {std::lock_guard<std::mutex> lock(mutex_);signaled = true;cv_.notify_all();  // 唤醒所有等待线程}// 重置为未信号状态void Reset() {std::lock_guard<std::mutex> lock(mutex_);signaled = false;}// 等待线程被唤醒void Wait() {std::unique_lock<std::mutex> lock(mutex_);cv_.wait(lock, [this]() { return signaled; });  // 等待直到 signaled 为 true}private:std::atomic<bool> signaled;  // 信号状态std::mutex mutex_;std::condition_variable cv_;
};void ThreadA(ManualResetEvent& mre)
{std::cout << "线程A开始等待...\n";mre.Wait();std::cout << "线程A被唤醒,继续执行\n";
}void ThreadB(ManualResetEvent& mre)
{std::this_thread::sleep_for(std::chrono::seconds(2));std::cout << "线程B设置信号\n";mre.Set();  // 设置信号
}int main() {ManualResetEvent mre;std::thread t1(ThreadA, std::ref(mre));  // 线程A等待std::thread t2(ThreadB, std::ref(mre));  // 线程B设置信号t1.join();t2.join();return 0;
}

代码说明:

  • ManualResetEvent:使用 std::atomic<bool> 来保持信号状态,Set() 会将状态设置为 true 并唤醒所有等待的线程,Reset() 会将状态重置为 false
  • Set():设置信号状态并唤醒所有等待的线程。
  • Wait():等待直到信号状态为 true
  • Reset():手动重置信号状态,使得线程再次进入等待状态。

总结

  • AutoResetEvent 可以通过 std::condition_variable 和一个布尔标志来模拟,调用 Wait() 会让线程等待信号,Set() 会唤醒一个线程并自动重置信号状态。
  • ManualResetEvent 可以通过 std::condition_variablestd::atomic<bool> 来模拟,Set() 会保持信号状态,直到显式调用 Reset() 重置状态。

这些 C++ 代码示例演示了如何利用 std::condition_variablestd::mutex 来实现类似于 C# 中的 AutoResetEventManualResetEvent 的功能。

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

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

相关文章

Excel批量设置行高,Excel表格设置自动换行后打印显示不全,Excel表格设置最合适的行高后打印显示不全,完美解决方案!!!

文章目录 说个问题&#xff08;很严重&#xff01;&#xff01;&#xff01;&#xff09;写个方案会Python看这里Python环境搭建不存在多行合并存在多行合并 不会Python看这里 说个问题&#xff08;很严重&#xff01;&#xff01;&#xff01;&#xff09; 平时处理Excel表格…

洛谷 P1014:Cantor 表

【题目来源】https://www.luogu.com.cn/problem/P1014https://www.acwing.com/problem/content/5510/【题目描述】 现代数学的著名证明之一是 Georg Cantor 证明了有理数是可枚举的。 他是用下面这一张表来证明这一命题的&#xff1a; 1/1 1/2 1/3 1/4 1/5 … 2/1 2/2 …

C语言基础:指针(数组指针与指针数组)

数组指针与指针数组 数组指针 概念&#xff1a;数组指针是指向数组的指针&#xff0c;本质上还是指针 特点&#xff1a; 先有数组&#xff0c;后有指针 它指向的是一个完整的数组 一维数组指针&#xff1a; 语法&#xff1a; 数据类型 (*指针变量名)[行容量][列容量]; 案…

华为管理变革之道:奋斗文化与活力

目录 企业文化是什么&#xff1f; 为什么活下去是华为的文化&#xff1f; 活下来&#xff0c;是华为公司的最低纲领&#xff0c;也是华为公司的最高纲领&#xff01; 资源终会枯竭&#xff0c;唯有文化才能生生不息 企业文化之一&#xff1a;以客户为中心 企业文化之二&a…

JS面试题|[2024-12-26]

1.事件委托是什么 又叫事件代理&#xff0c;原理就是直接利用了事件冒泡的机制来实现&#xff0c;也就是说把子元素的事件绑定到了父元素的身上&#xff0c;如果子元素阻止了事件冒泡&#xff0c;那么委托也就不成立了。 阻止事件冒泡&#xff1a;event.stopPropagation() addE…

upload-labs关卡记录12

直接上传一句话木马&#xff0c;发现提示&#xff1a; 很明显这是一个白名单&#xff0c;而且不是前端的js检查&#xff0c;而是服务端的检查&#xff0c;因此我们使用bp抓包&#xff0c;改一下文件类型试试&#xff1a; 找到包之后&#xff0c;我们对content-type进行一个更改…

ArkTs组件(2)

一.下拉列表组件&#xff1a;Select 1.接口 Select(options: Array<SelectOption>) 参数名类型必填说明optionsArray<SelectOption>是设置下拉选项。 SelectOption对象说明 名称类型必填说明valueResourceStr是 下拉选项内容。 iconResourceStr否 下拉选项图片…

J9学习打卡笔记

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f356; 原作者&#xff1a;K同学啊 IInception v3算法实战 网络结构InceptionAInceptionBInceptionCReductionAReductionB辅助分支个人总结 import os, PIL, random, pathlib import torch impor…

软考和 PMP 哪个含金量更高点?

软考高项比较适用于计算机 IT 行业&#xff0c;而 PMP 不受行业限制&#xff0c;各行各业都适用&#xff0c;没有哪个含金量更高的说法 至于哪个更合适&#xff0c;看你想去国企还是民企&#xff0c;国企软考吃香&#xff0c;外企PMP 吃香 下面说下两者具体有什么区别&#x…

面向微服务的Spring Cloud Gateway的集成解决方案:用户登录认证与访问控制

&#x1f3af;导读&#xff1a;本文档详细描述了一个基于Spring Cloud Gateway的微服务网关及Admin服务的实现。网关通过定义路由规则&#xff0c;利用负载均衡将请求转发至不同的后端服务&#xff0c;并集成了Token验证过滤器以确保API的安全访问&#xff0c;同时支持白名单路…

NLP 中文拼写检测纠正论文 C-LLM Learn to CSC Errors Character by Character

拼写纠正系列 NLP 中文拼写检测实现思路 NLP 中文拼写检测纠正算法整理 NLP 英文拼写算法&#xff0c;如果提升 100W 倍的性能&#xff1f; NLP 中文拼写检测纠正 Paper java 实现中英文拼写检查和错误纠正&#xff1f;可我只会写 CRUD 啊&#xff01; 一个提升英文单词拼…

kong网关使用pre-function插件,改写接口的返回数据

一、背景 kong作为api网关&#xff0c;除了反向代理后端服务外&#xff0c;还可对接口进行预处理。 比如本文提及的一个小功能&#xff0c;根据http header某个字段的值&#xff0c;等于多少的时候&#xff0c;返回一个固定的报文。 使用到的kong插件是pre-function。 除了上…

Linux:进程概念

1.冯诺依曼体系结构 结论&#xff1a; --- CPU不和外设直接打交道&#xff0c;和内存直接打交道。 --- 所有的外设&#xff0c;有数据需要收入&#xff0c;只能载入到内存中&#xff1b;内存写出&#xff0c;也一定是写道外设中。 --- 为什么程序要运行必须加载到内存&#xf…

结构体(初阶)

结构体&#xff1a; 结构体类型的声明 结构体初始化 结构成员访问 结构体传参 1.结构体的声明 1.1结构的基础知识 结构是一些值的集合&#xff0c;这些值称为成员变量。结构的每个成员可以是不同类型的变量。 1.2结构的声明 struct tag { member - list; }variable-lis…

设计模式的主要分类是什么?请简要介绍每个分类的特点。

大家好&#xff0c;我是锋哥。今天分享关于【设计模式的主要分类是什么&#xff1f;请简要介绍每个分类的特点。】面试题。希望对大家有帮助&#xff1b; 设计模式的主要分类是什么&#xff1f;请简要介绍每个分类的特点。 1000道 互联网大厂Java工程师 精选面试题-Java资源分…

显示 Windows 任务栏

显示 Windows 任务栏 1. 取消勾选自动隐藏任务栏2. 重启 Windows 资源管理器References 1. 取消勾选自动隐藏任务栏 Windows 任务栏具有自动隐藏功能&#xff0c;不使用时自动隐藏&#xff0c;使用时显示。 鼠标右键单击桌面上的空白区域&#xff0c;个性化 -> 任务栏。不…

c# RSA加解密工具,.netRSA加解密工具

软件介绍 名称: c# RSA加解密工具,.netRSA加解密工具依赖.net版本: .net 8.0工具类型: WinForm源码下载 c# RSA加解密工具,.netRSA加解密工具 依赖项 WinFormsRSA.csproj <Project

STM32-笔记17-PWM波型

一、介绍 PWM波形&#xff08;Pulse Width Modulation&#xff0c;脉冲宽度调制波形&#xff09;是一种占空比可变的脉冲波形。这种调制方式通过改变脉冲的宽度来控制电路中的信号强度和频率。具体来说&#xff0c;PWM波形中的高电平持续时间和低电平持续时间可以根据需要进行调…

【java面向对象编程】第九弹----抽象类、接口、内部类

笔上得来终觉浅,绝知此事要躬行 &#x1f525; 个人主页&#xff1a;星云爱编程 &#x1f525; 所属专栏&#xff1a;javase &#x1f337;追光的人&#xff0c;终会万丈光芒 &#x1f389;欢迎大家点赞&#x1f44d;评论&#x1f4dd;收藏⭐文章 一、抽象类 1.1基本介绍 &…

重温设计模式--迭代器模式

文章目录 迭代器模式&#xff08;Iterator Pattern&#xff09;概述迭代器模式的结构迭代器模式UML图C 代码示例应用场景 迭代器模式&#xff08;Iterator Pattern&#xff09;概述 定义&#xff1a; 迭代器模式是一种行为型设计模式&#xff0c;它提供了一种方法来顺序访问一个…