C#中ManualResetEvent 和 ManualResetEventSlim的使用

2023-10-24 01:45

本文主要是介绍C#中ManualResetEvent 和 ManualResetEventSlim的使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

从 .NET Framework 版本2.0 开始, ManualResetEvent 派生自 EventWaitHandle 类。 在 ManualResetEvent 功能上等效于EventWaitHandle 使用创建的EventResetMode.ManualReset。ManualResetEventSlim用于实现更好的性能 ManualResetEvent。以下介绍.NET(C#)中ManualResetEvent 和 ManualResetEventSlim的使用总结。

 

1、ManualResetEvent 和 ManualResetEventSlim

ManualResetEvent表示线程同步事件,收到信号时,必须手动重置该事件。 此类不能被继承。ManualResetEventSlim于实现更好的性能 ManualResetEvent ,而不是等待时间预计非常短,事件不会跨越进程边界。 等待事件收到信号期间,ManualResetEventSlim 会短暂使用忙碌旋转。 等待时间较短时,旋转的开销相对于使用等待句柄来进行等待的开销会少很多。 不过,如果在特定时间段内事件没有收到信号,ManualResetEventSlim 会求助于常规的事件句柄等待。从 .NET Framework 版本4.0 开始, System.Threading.ManualResetEventSlim 类是的轻型替代ManualResetEvent

2、ManualResetEvent的使用

参考文档:ManualResetEvent 类 (System.Threading) | Microsoft Learn

new ManualResetEvent(false)为创建在无信号状态。WaitOne()方法会阻塞,调用Set()方法设置为有信号状态,WaitOne()方法不会阻塞,需要调用Reset()方法变为无信号状态,WaitOne()方法将会阻塞。new ManualResetEvent(true)为创建在有信号状态。WaitOne()方法不会阻塞,需要调用Reset()方法变为无信号状态,WaitOne()方法将会阻塞。

例如,

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace ConsoleApplication
{class Program{mre用于手动阻塞和释放线程。false是创建在无信号状态。private static ManualResetEvent mre = new ManualResetEvent(false);static void Main(){Console.WriteLine("启动 3个在ManualResetEvent上阻塞的命名线程");for (int i = 0; i <= 2; i++){Thread t = new Thread(ThreadProc);t.Name = "Thread_" + i;t.Start();}Thread.Sleep(500);Console.WriteLine("按回车键,当三个线程都启动后,调用Set()释放所有线程。");Console.ReadLine();mre.Set();Thread.Sleep(500);Console.WriteLine("按回车键,当ManualResetEvent有信号时,调用WaitOne()的线程不会阻塞。");Console.ReadLine();for (int i = 3; i <= 4; i++){Thread t = new Thread(ThreadProc);t.Name = "Thread_" + i;t.Start();}Thread.Sleep(500);Console.WriteLine("按回车键,调用Reset(),这样线程在调用WaitOne()时就会再次阻塞。");Console.ReadLine();mre.Reset();// Start a thread that waits on the ManualResetEvent.Thread t5 = new Thread(ThreadProc);t5.Name = "Thread_5";t5.Start();Thread.Sleep(500);Console.WriteLine("按回车键,调用Set()并结束运行。");Console.ReadLine();mre.Set();// 如在Visual Studio中运行这个例子,取消下面这行注释://Console.ReadLine();}private static void ThreadProc(){string name = Thread.CurrentThread.Name;Console.WriteLine(name + " 调用 mre.WaitOne()");mre.WaitOne();Console.WriteLine(name + " 结束");}}
}

 

3、ManualResetEventSlim的使用

参考文档:ManualResetEventSlim 类 (System.Threading) | Microsoft Learn

new ManualResetEventSlim(false)为创建在无信号状态。Wait()方法会阻塞,调用Set()方法设置为有信号状态,Wait()方法不会阻塞,需要调用Reset()方法变为无信号状态,Wait()方法将会阻塞。new ManualResetEventSlim(true)为创建在有信号状态。Wait()方法不会阻塞,需要调用Reset()方法变为无信号状态,Wait()方法将会阻塞。

例如,

using System;
using System.Threading;
using System.Threading.Tasks;
namespace ConsoleApplication
{class Program{static void Main(){MRES_SetWaitReset();MRES_SpinCountWaitHandle();}// //      ManualResetEventSlim construction//      ManualResetEventSlim.Wait()//      ManualResetEventSlim.Set()//      ManualResetEventSlim.Reset()//      ManualResetEventSlim.IsSetstatic void MRES_SetWaitReset(){ManualResetEventSlim mres1 = new ManualResetEventSlim(false); // 初始创建为无信号状态ManualResetEventSlim mres2 = new ManualResetEventSlim(false); // 初始创建为无信号状态ManualResetEventSlim mres3 = new ManualResetEventSlim(true);  // 初始创建为有信号状态// 启动一个操作mres3和mres2的异步任务var observer = Task.Factory.StartNew(() =>{mres1.Wait();Console.WriteLine("observer mres1 信号");Console.WriteLine("observer Reset mres3 信号");mres3.Reset(); // mres3 应该无信号Console.WriteLine("observer Set mres2");mres2.Set();});Console.WriteLine("主线程: mres3.IsSet = {0} (应该为true)", mres3.IsSet);Console.WriteLine("主线程 Set mres1");mres1.Set(); // 将会执行 observer Taskmres2.Wait(); // observer Task完成Reset mres3,Set mres2Console.WriteLine("主线程 mres2 有信号");Console.WriteLine("主线程: mres3.IsSet = {0} (应该为false)", mres3.IsSet);// 用完ManualResetEventSlim时,Dispose()一个ManualResetEventSlim释放资源observer.Wait(); // 确保observer执行完成mres1.Dispose();mres2.Dispose();mres3.Dispose();// 如在Visual Studio中运行这个例子,取消下面这行注释:Console.ReadLine();}// ://      ManualResetEventSlim construction w/ SpinCount//      ManualResetEventSlim.WaitHandlestatic void MRES_SpinCountWaitHandle(){// 构造一个SpinCount为1000的ManualResetEventSlimManualResetEventSlim mres1 = new ManualResetEventSlim(false, 1000);ManualResetEventSlim mres2 = new ManualResetEventSlim(false, 1000);Task bgTask = Task.Factory.StartNew(() =>{// Just wait a littleThread.Sleep(100);// 给两个MRESes发信号Console.WriteLine("mres1.Set() mres2.Set()");mres1.Set();mres2.Set();});//等待指定数组中的所有元素都收到信号。WaitHandle.WaitAll(new WaitHandle[] { mres1.WaitHandle, mres2.WaitHandle });Console.WriteLine("WaitHandle.WaitAll(mres1.WaitHandle, mres2.WaitHandle) completed.");// Clean upbgTask.Wait();mres1.Dispose();mres2.Dispose();}}
}

 

这篇关于C#中ManualResetEvent 和 ManualResetEventSlim的使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/271886

相关文章

Go语言使用sync.Mutex实现资源加锁

《Go语言使用sync.Mutex实现资源加锁》数据共享是一把双刃剑,Go语言为我们提供了sync.Mutex,一种最基础也是最常用的加锁方式,用于保证在任意时刻只有一个goroutine能访问共享... 目录一、什么是 Mutex二、为什么需要加锁三、实战案例:并发安全的计数器1. 未加锁示例(存在竞态)

C# async await 异步编程实现机制详解

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机(StateMachine)**模式实现,将异步方法转换为编译器生成的状态机类,本... 目录一、async/await 异步编程实现机制1.1 核心概念1.2 编译器转换过程1.3 关键组件解析

setsid 命令工作原理和使用案例介绍

《setsid命令工作原理和使用案例介绍》setsid命令在Linux中创建独立会话,使进程脱离终端运行,适用于守护进程和后台任务,通过重定向输出和确保权限,可有效管理长时间运行的进程,本文给大家介... 目录setsid 命令介绍和使用案例基本介绍基本语法主要特点命令参数使用案例1. 在后台运行命令2.

使用Redis快速实现共享Session登录的详细步骤

《使用Redis快速实现共享Session登录的详细步骤》在Web开发中,Session通常用于存储用户的会话信息,允许用户在多个页面之间保持登录状态,Redis是一个开源的高性能键值数据库,广泛用于... 目录前言实现原理:步骤:使用Redis实现共享Session登录1. 引入Redis依赖2. 配置R

使用Python的requests库调用API接口的详细步骤

《使用Python的requests库调用API接口的详细步骤》使用Python的requests库调用API接口是开发中最常用的方式之一,它简化了HTTP请求的处理流程,以下是详细步骤和实战示例,涵... 目录一、准备工作:安装 requests 库二、基本调用流程(以 RESTful API 为例)1.

使用Python开发一个Ditto剪贴板数据导出工具

《使用Python开发一个Ditto剪贴板数据导出工具》在日常工作中,我们经常需要处理大量的剪贴板数据,下面将介绍如何使用Python的wxPython库开发一个图形化工具,实现从Ditto数据库中读... 目录前言运行结果项目需求分析技术选型核心功能实现1. Ditto数据库结构分析2. 数据库自动定位3

Python yield与yield from的简单使用方式

《Pythonyield与yieldfrom的简单使用方式》生成器通过yield定义,可在处理I/O时暂停执行并返回部分结果,待其他任务完成后继续,yieldfrom用于将一个生成器的值传递给另一... 目录python yield与yield from的使用代码结构总结Python yield与yield

Go语言使用select监听多个channel的示例详解

《Go语言使用select监听多个channel的示例详解》本文将聚焦Go并发中的一个强力工具,select,这篇文章将通过实际案例学习如何优雅地监听多个Channel,实现多任务处理、超时控制和非阻... 目录一、前言:为什么要使用select二、实战目标三、案例代码:监听两个任务结果和超时四、运行示例五

python使用Akshare与Streamlit实现股票估值分析教程(图文代码)

《python使用Akshare与Streamlit实现股票估值分析教程(图文代码)》入职测试中的一道题,要求:从Akshare下载某一个股票近十年的财务报表包括,资产负债表,利润表,现金流量表,保存... 目录一、前言二、核心知识点梳理1、Akshare数据获取2、Pandas数据处理3、Matplotl

Java使用Thumbnailator库实现图片处理与压缩功能

《Java使用Thumbnailator库实现图片处理与压缩功能》Thumbnailator是高性能Java图像处理库,支持缩放、旋转、水印添加、裁剪及格式转换,提供易用API和性能优化,适合Web应... 目录1. 图片处理库Thumbnailator介绍2. 基本和指定大小图片缩放功能2.1 图片缩放的