线程同步的机制有哪些?区别是什么

AutoResetEvent、ManualResetEvent、EventWaitHandle 以及 lock 都是 C# 中用于线程同步的机制,但它们在使用方式和功能上有所不同。

AutoResetEvent

功能:允许一个线程将事件的状态设置为有信号状态,从而允许一个正在等待该事件的线程继续执行。一旦有线程响应了信号,AutoResetEvent 会自动将信号重置为非信号状态,等待下一个线程再次发出信号。
使用场景:通常用于生产者-消费者模型中,其中一个线程(生产者)生成数据并发出信号,而其他线程(消费者)在等待信号的状态下执行任务。
举例如下:

using System;  
using System.Threading;  class Program  
{  // 创建一个AutoResetEvent对象,初始状态为非信号状态(false)  static AutoResetEvent autoEvent = new AutoResetEvent(false);  // 共享缓冲区,用于存放生产者生成的数据  static int sharedBuffer = 0;  // 用于控制生产者和消费者是否继续运行的标志  static bool running = true;  static void Main()  {  // 启动生产者和消费者线程  Thread producer = new Thread(Produce);  Thread consumer = new Thread(Consume);  producer.Start();  consumer.Start();  // 主线程等待一段时间后停止生产者和消费者  Thread.Sleep(5000); // 模拟主线程执行其他任务  running = false;  autoEvent.Set(); // 唤醒可能正在等待的消费者线程,以确保其能够退出循环  // 等待生产者和消费者线程完成  producer.Join();  consumer.Join();  Console.WriteLine("Producer and consumer threads have finished.");  }  static void Produce()  {  int localBuffer = 0;  while (running)  {  // 模拟数据生产  localBuffer++;  Console.WriteLine("Produced: " + localBuffer);  // 将数据放入共享缓冲区(此处仅为示例,实际中可能需要更复杂的逻辑)  sharedBuffer = localBuffer;  // 发出信号,唤醒等待的消费者线程  autoEvent.Set();  // 模拟生产间隔  Thread.Sleep(1000); // 1秒  }  }  static void Consume()  {  while (running || sharedBuffer != 0) // 确保消费完所有生产的数据  {  // 等待生产者发出信号  autoEvent.WaitOne();  // 从共享缓冲区中取出数据(此处仅为示例,实际中可能需要更复杂的逻辑)  int data = sharedBuffer;  // 模拟数据处理  Console.WriteLine("Consumed: " + data);  // 重置共享缓冲区(此处为了简化示例,实际中可能不需要)  sharedBuffer = 0;  }  }  
}

ManualResetEvent

功能:与 AutoResetEvent 类似,但不同之处在于,当 ManualResetEvent 被设置为有信号状态时,它会保持该状态,直到显式地调用 Reset 方法将其重置为无信号状态。
使用场景:适用于需要允许多个线程在事件被设置后继续执行的情况。例如,当有多个线程等待同一个资源,而该资源在某一时刻变得可用时。

using System;  
using System.Threading;  class Program  
{  // 创建一个ManualResetEvent对象,初始状态为非信号状态(false)  static ManualResetEvent manualEvent = new ManualResetEvent(false);  // 模拟的资源,例如数据库连接的数量  static int availableResources = 0;  // 控制线程是否继续运行的标志  static bool running = true;  static void Main()  {  // 模拟资源在某个时刻变得可用  Thread resourceBecomesAvailable = new Thread(MakeResourceAvailable);  resourceBecomesAvailable.Start();  // 启动多个等待资源的线程  for (int i = 0; i < 5; i++)  {  Thread worker = new Thread(UseResource);  worker.Start(i);  }  // 主线程等待一段时间后停止所有线程  Thread.Sleep(3000); // 模拟主线程执行其他任务  running = false;  // 重置ManualResetEvent,确保没有线程在等待(虽然在这个例子中可能不是必需的,因为所有线程都可能已经完成了)  manualEvent.Reset();  // 等待所有线程完成(在实际应用中,可能需要更复杂的线程管理)  // 注意:这个示例中并没有实现真正的等待所有线程完成,因为线程可能在Reset之前就已经完成了。  // 在实际应用中,你可能需要使用如Thread.Join()、Task或其他并发集合来管理线程。  }  static void MakeResourceAvailable()  {  // 模拟资源准备的延迟  Thread.Sleep(1000); // 1秒  // 设置ManualResetEvent为有信号状态,允许等待的线程继续执行  Console.WriteLine("Resource is now available.");  manualEvent.Set();  // 模拟资源数量的增加(在这个例子中,我们仅设置一次信号,因此这个变量实际上没有用到)  // availableResources++;  }  static void UseResource(object threadId)  {  while (running || manualEvent.WaitOne(0)) // 使用0毫秒超时来检查事件状态,避免死锁  {  // 如果事件已经被设置(即有信号状态),则进入这个代码块  if (manualEvent.WaitOne(0)) // 注意:这里再次调用WaitOne是为了确保我们是在事件被设置后执行的  {  // 使用资源的代码  Console.WriteLine("Thread " + threadId + " is using the resource.");  // 模拟资源使用的延迟  Thread.Sleep(500); // 0.5秒  // 在这个例子中,我们不需要显式地减少资源数量,因为只设置了一次信号  // 但在实际应用中,你需要确保资源的正确分配和释放  }  else  {  // 如果事件没有被设置(即无信号状态),并且running为false,则退出循环  if (!running)  {  break;  }  // 否则,稍微等待一下再检查(在实际应用中,你可能需要更复杂的逻辑来处理这种情况)  Thread.Sleep(100); // 0.1秒  }  }  // 注意:在这个例子中,由于ManualResetEvent在资源可用时被设置一次,并且我们没有实现资源的“用完即止”逻辑,  // 因此所有线程都会尝试执行使用资源的代码。在实际应用中,你可能需要额外的同步机制来确保资源的正确分配和使用。  }  
}

这个示例有几个需要注意的地方:

1 资源分配:在这个示例中,availableResources 变量实际上没有被用到,因为 ManualResetEvent 只被设置了一次。在实际应用中,你需要实现更复杂的逻辑来确保资源的正确分配和使用。
2 线程退出:示例中使用了一个 running 标志来控制线程的退出。然而,由于 ManualResetEvent 的特性,所有线程都可能已经执行了使用资源的代码,并且在 Reset 被调用之前就已经完成了。因此,在实际应用中,你可能需要更复杂的线程管理策略。
3 死锁避免:在 UseResource 方法中,我们使用了 WaitOne(0) 来检查 ManualResetEvent 的状态,以避免死锁。这是因为如果线程在没有设置信号的情况下调用 WaitOne 而没有超时,它将无限期地等待下去。
4 代码优化:示例中的代码可能不是最优的,因为它在循环中多次调用了 WaitOne(0)。在实际应用中,你可能需要更高效的同步策略。
5 线程安全:虽然 ManualResetEvent 提供了线程间的信号同步,但示例中的资源使用逻辑(如果有的话)仍然需要额外的同步机制来确保线程安全。在这个简化的示例中,我们没有实现这样的同步。

EventWaitHandle

功能:是 AutoResetEvent 和 ManualResetEvent 的基类,提供了更灵活的线程同步机制。它可以被设置为自动重置或手动重置模式。
使用场景:适用于需要在不同线程间进行复杂同步操作的场景。EventWaitHandle 还可以是命名的,这意味着它可以跨进程使用。

using System;  
using System.Threading;  class ProgramA  
{  static void Main()  {  // 创建一个命名的EventWaitHandle,设置为初始状态非信号(false)  // 注意:这个名称是全局的,需要在系统中唯一  using (EventWaitHandle eventHandle = new EventWaitHandle(false, EventResetMode.ManualReset, "Global\\MyNamedEvent"))  {  // 模拟一些工作  Console.WriteLine("Process A is doing some work...");  Thread.Sleep(2000);  // 设置事件,允许等待它的进程继续执行  eventHandle.Set();  Console.WriteLine("Process A has set the event.");  // 为了演示,让进程A保持运行状态,以便我们可以观察进程B的行为  Console.WriteLine("Press any key to exit Process A...");  Console.ReadKey();  }  }  
}using System;  
using System.Threading;  class ProgramB  
{  static void Main()  {  // 打开一个已存在的命名的EventWaitHandle  // 注意:这个名称需要与进程A中创建的名称相匹配  using (EventWaitHandle eventHandle = EventWaitHandle.OpenExisting("Global\\MyNamedEvent"))  {  // 等待事件被设置  Console.WriteLine("Process B is waiting for the event...");  eventHandle.WaitOne();  Console.WriteLine("Process B has received the event.");  // 在这个例子中,我们假设事件被设置后进程B就没有更多工作了  // 但在实际应用中,进程B可能还需要执行一些清理工作或继续处理其他任务  }  // 进程B结束  Console.WriteLine("Press any key to exit Process B...");  Console.ReadKey();  }  
}

注意事项:

1 命名:跨进程同步的 EventWaitHandle 必须使用全局命名空间(前缀为 “Global\”)。这确保了名称在系统中的唯一性。
2 权限:打开已存在的 EventWaitHandle 可能需要适当的权限。如果进程B没有足够的权限,它将无法打开由进程A创建的 EventWaitHandle。
3 异常处理:在实际应用中,你应该添加适当的异常处理代码来处理可能出现的错误,例如 WaitHandleCannotBeOpenedException(当尝试打开一个不存在的或无法访问的 EventWaitHandle 时抛出)。
4 资源清理:使用 using 语句可以确保 EventWaitHandle 在不再需要时被正确释放。
同步模式:在这个例子中,我们使用了手动重置模式(EventResetMode.ManualReset)。这意味着进程A设置事件后,进程B和任何其他等待该事件的进程都可以继续执行,直到事件被显式重置。如果你希望每个等待的进程在事件被设置后只能继续执行一次(即自动重置模式),你应该将 EventResetMode 设置为 AutoReset。
5 跨进程通信的复杂性:虽然 EventWaitHandle 提供了跨进程同步的基本机制,但跨进程通信(IPC)通常涉及更复杂的场景,可能需要考虑数据交换、错误处理、安全性等多个方面。对于更复杂的IPC需求,你可能需要考虑使用其他IPC机制,如命名管道、内存映射文件或套接字。

lock(C#中的锁定语句)
功能:lock 关键字用于声明一个代码块,该代码块在同一时间内只能由一个线程执行。它提供了对共享资源的独占访问。
使用场景:通常用于保护代码块中的共享资源,防止多个线程同时访问导致的数据竞争和不一致性问题。

区别总结

信号状态重置:
AutoResetEvent:自动重置信号状态。
ManualResetEvent:需要手动重置信号状态。
EventWaitHandle:可以设置为自动重置或手动重置模式。
lock:不涉及信号状态的重置。
使用场景:
AutoResetEvent 和 ManualResetEvent:主要用于线程间的信号通知和同步。
EventWaitHandle:提供了更灵活的线程同步机制,适用于复杂场景。
lock:主要用于保护共享资源,防止数据竞争。
跨进程同步:
EventWaitHandle(命名时):可以跨进程使用。
AutoResetEvent、ManualResetEvent 和 lock:通常只能在同一进程内使用。
代码示例:
AutoResetEvent 和 ManualResetEvent 通常通过 WaitOne 方法等待信号,通过 Set 方法设置信号。
EventWaitHandle 提供了类似的 WaitOne、Set 和 Reset 方法。
lock 通常与 Monitor 类一起使用,但更常见的用法是直接使用 lock 关键字来声明一个锁定的代码块。

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

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

相关文章

Android Studio Koala Feature Drop 稳定版现已推出

作者 / Android Studio 产品经理 Sandhya Mohan Android Studio Koala Feature Drop (2024.1.2) 现已推出&#xff01;&#x1f428; &#x1f517; Android Studio https://developer.android.google.cn/studio 今年早些时候&#xff0c;我们宣布每个 Android Studio 动物版本…

vscode快速删除一行的快捷键不管用

vscode快速删除一行的快捷键 在vscode中&#xff0c;快速删除一行的快捷键是CtrlShiftk。 因为搜狗软键盘的快捷键和这个快捷键的按键是冲突了&#xff0c;所以快捷键被搜狗输入法给拦截了。把搜狗软键盘的快捷键关闭了或者修改成别的键就好了&#xff0c; 因为我不怎么用软键…

毕设分享 基于协同过滤的电影推荐系统

文章目录 0 简介1 设计概要2 课题背景和目的3 协同过滤算法原理3.1 基于用户的协同过滤推荐算法实现原理3.1.1 步骤13.1.2 步骤23.1.3 步骤33.1.4 步骤4 4 系统实现4.1 开发环境4.2 系统功能描述4.3 系统数据流程4.3.1 用户端数据流程4.3.2 管理员端数据流程 4.4 系统功能设计 …

[C#]使用纯opencvsharp部署yolov11-onnx图像分类模型

【官方框架地址】 https://github.com/ultralytics/ultralytics.git 【算法介绍】 使用纯OpenCvSharp部署YOLOv11-ONNX图像分类模型是一项复杂的任务&#xff0c;但可以通过以下步骤实现&#xff1a; 准备环境&#xff1a;首先&#xff0c;确保开发环境已安装OpenCvSharp和必…

40条经典ChatGPT论文指令,圈定选题和进行论文构思

目录 1、用ChatGPT圈定选题范围2、用ChatGPT生成研究方法和思路3、用ChatGPT扩展论文观点和论证4、用ChatGPT辅助论文结构设计5、如何直接使用ChatGPT4o、o1、OpenAI Canvas6、OpenAI Canvas增强了啥&#xff1f;7、编程功能增强 &#x1f447; ChatGPT o1网页入口在文末&#…

Python简介与入门

如果你要用计算机做很多工作&#xff0c;最后你会发现有一些任务你更希望用自动化的方式进行处理。比如&#xff0c;你想要在大量的文本文件中执行查找/替换&#xff0c;或者以复杂的方式对大量的图片进行重命名和整理。也许你想要编写一个小型的自定义数据库、一个特殊的 GUI …

双十一哪些东西会打折?快来看入手哪些东西

在当今数字化时代&#xff0c;数码产品已经成为了我们生活中不可或缺的一部分。无论是手机、电脑、相机等设备&#xff0c;还是智能家居、穿戴设备等新兴领域&#xff0c;数码产品的种类和功能都在不断丰富和拓展。而在即将到来的双十一购物狂欢节中&#xff0c;数码产品更是成…

红帽7—Mysql路由部署

MySQL Router 是一个对应用程序透明的InnoDB Cluster连接路由服务&#xff0c;提供负载均衡、应用连接故障转移和客户端路 由。 利用路由器的连接路由特性&#xff0c;用户可以编写应用程序来连接到路由器&#xff0c;并令路由器使用相应的路由策略 来处理连接&#xff0c;使其…

2024最新版:阿里内网大模型面试题首次公开,别流传出去了

随着人工智能技术的迅猛发展&#xff0c;计算机视觉&#xff08;CV&#xff09;、自然语言处理&#xff08;NLP&#xff09;、搜索、推荐、广告推送和风险控制等领域的岗位越来越受欢迎&#xff0c;而_对于大型模型技术的掌握成为了这些岗位的标配_。 但目前公开的大模型资源还…

如何在算家云搭建Omost(图像生成)

一、Omost介绍 GitHub - lllyasviel/Omost&#xff1a;你的图像快到了&#xff01; Omost 是一个将 LLM 的编码能力转换为图像生成&#xff08;或更准确地说&#xff0c;图像合成&#xff09;能力的项目。“O”代表“omni”多模态&#xff0c;象征着项目支持多种形式的输入与…

设计模式:单例

一.什么是单例模式 单例模式是一种设计模式&#xff0c;指在整个程序生命周期中有且仅有一个实例的类。可以分为懒汉式以及饿汉式。 懒汉式&#xff1a;只有在类的实例被使用时才生成唯一实例。但是存在线程安全以及内存泄露的问题。可以节省系统资源。 饿汉式&#xff1a;程序…

腾讯云SDK 选择指引

音视频终端 SDK&#xff08;腾讯云视立方&#xff09;提供多种音视频场景下的终端 SDK&#xff0c;用户可结合自身场景需要选择相应的 SDK 进行下载。 如果您无法通过应用场景确定您需要的 SDK&#xff0c;可以进入 自定义 SDK 下载页&#xff0c;勾选您需要的功能&#xff0c…

Redis-缓存过期淘汰策略

缓存淘汰策略 生产上redis内存设置为多少 设置为最大内存的 3/4 redis 会占用物理机多少内存 默认大小是 0&#xff0c;64 位系统下表示不限制内存大小&#xff0c;32位系统表示 3G 如何设置修改redis内存大小 config get maxmemory 查看修改方式 配置文件 单位是字节 2.…

(八)Protues仿真STM32单片机GPIO驱动数码管

1&#xff0c;参考上篇&#xff0c;将LED点阵屏更换成数码管如下图 2&#xff0c;修改驱动函数&#xff0c;数组seg[14]前10个是0-9数字的编码&#xff0c;后四个是空格&#xff0c;点&#xff0c;横线&#xff0c;下划线 char seg_decode(char num)//数字解码 {const char se…

vue3中使用live2D

概述 本文将介绍如何在vue3项目中使用Live2D。 Live2D 介绍 Live2D 是什么 Live2D 是一种用于将二维图像转化为可动画三维模型的技术&#xff0c;主要应用于游戏、虚拟角色和互动应用中。它允许开发者通过对静态图像进行分层和建模&#xff0c;使角色在不同角度下能够进行流…

【Linux系统编程】第二十八弹---构建基础文件操作库与理解标准错误流(stderr)在C与C++中的应用

✨个人主页&#xff1a; 熬夜学编程的小林 &#x1f497;系列专栏&#xff1a; 【C语言详解】 【数据结构详解】【C详解】【Linux系统编程】 目录 1、封装简单的库 1.1、定义文件结构 1.2、打开文件 1.3、刷新缓冲区 1.4、写文件 1.5、关闭文件 1.6、各文件代码 2、s…

【element-tiptap】如何增加一个扩展项,为文字渲染颜色?

源码地址&#xff1a; https://github.com/Leecason/element-tiptap 可以看到&#xff0c;当前这个页面的文字&#xff0c;都是黑色的&#xff08;除了链接&#xff09; 酱紫有些单调&#xff0c;我喜欢五颜六色的。那么这篇文章就来看下菜单项里面如何增加一个颜色的扩展&…

k8s微服务

一 、什么是微服务 用控制器来完成集群的工作负载&#xff0c;那么应用如何暴漏出去&#xff1f;需要通过微服务暴漏出去后才能被访问 Service是一组提供相同服务的Pod对外开放的接口。 借助Service&#xff0c;应用可以实现服务发现和负载均衡。 service默认只支持4层负载均…

Springboot 整合 logback 日志框架

文章目录 整合 Logback 日志框架第一步&#xff1a;导入依赖第二步&#xff1a;导入配置&#xff08;logback.xml&#xff09;详解 使用&#xff08;记录日志&#xff09; 遇到问题一解决方案 整合 Logback 日志框架 第一步&#xff1a;导入依赖 &#xff08;Springboot 会自己…

Squid + Stunnel 配置

环境&#xff1a; 亚马逊服务器一台&#xff1a;3.26.80.132 华为云服务器一台&#xff1a;122.59.52.68 客户机一台&#xff1a; Win11 实现的需求&#xff1a;客户机通过设置华为云代理&#xff0c;实现透过亚马逊服务器上网 一、亚马逊服务器 1、安装Squid https://bl…