C#多线程之线程通讯(AutoResetEvent)
一、简介
我们在线程编程的时候往往会涉及到线程的通信，通过信号的接受来进行线程是否阻塞的操作。
AutoResetEvent 允许线程通过发信号互相通信。通常，此通信涉及线程需要独占访问的资源。具体方法和扩展方法请详见AutoResetEvent类，最常用方法中就有Set()和WaitOne()。
线程通过调用 AutoResetEvent 上的 WaitOne 来等待信号。如果 AutoResetEvent 处于非终止状态，则该线程阻塞，并等待当前控制资源的线程通过调用 Set 发出资源可用的信号。AutoResetEvent 的非终止状态可以通过构造函数在设置。
通俗的来讲只有等myResetEven.Set()成功运行后,myResetEven.WaitOne()才能够获得运行机会;Set是发信号，WaitOne是等待信号，只有发了信号，
等待的才会执行。如果不发的话，WaitOne后面的程序就永远不会执行。
AutoResetEvent myEvent = new AutoResetEvent(false);
这里构造函数中的参数false就代表该状态为非终止状态，相反若为true则为终止状态。
二、代码
案例一：
public class Program
{
const int cycleNum = 10;static void Main(string[] args)
{
// 参数:
// workerThreads:
// 要由线程池根据需要创建的新的最小工作程序线程数。
// completionPortThreads:
// 要由线程池根据需要创建的新的最小空闲异步 I/O 线程数。
// 返回结果:如果更改成功，则为 true；否则为 false。
//public static bool SetMinThreads(int workerThreads, int completionPortThreads);
ThreadPool.SetMinThreads(1, 1);
// 参数:
// workerThreads:
// 线程池中辅助线程的最大数目。
// completionPortThreads:
// 线程池中异步 I/O 线程的最大数目。
// 返回结果:如果更改成功，则为 true；否则为 false。
//public static bool SetMaxThreads(int workerThreads, int completionPortThreads);
ThreadPool.SetMaxThreads(5, 5);
for (int i = 1; i <= cycleNum; i++)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(testFun), i.ToString());
}
Console.WriteLine("主線程執行！");
Console.WriteLine("主線程終止！");
Console.WriteLine("線程池終止！");
Console.ReadKey();
}
public static void testFun(object obj)
{
Console.WriteLine(string.Format("{0}:第{1}個線程", DateTime.Now.ToString(), obj.ToString()));
Thread.Sleep(5000);
}
}运行结果：
这里可以看出，线程池里线程的执行不影响主线程的运行，线程池虽然可以管理多线程的执行，但是却无法知道它什么时候终止。
案例二：
public class Program
{
const int cycleNum = 10;
static int cnt = 10;
static AutoResetEvent myEvent = new AutoResetEvent(false);
static void Main(string[] args)
{
// 参数:
// workerThreads:
// 要由线程池根据需要创建的新的最小工作程序线程数。
// completionPortThreads:
// 要由线程池根据需要创建的新的最小空闲异步 I/O 线程数。
// 返回结果:如果更改成功，则为 true；否则为 false。
//public static bool SetMinThreads(int workerThreads, int completionPortThreads);
ThreadPool.SetMinThreads(1, 1);
// 参数:
// workerThreads:
// 线程池中辅助线程的最大数目。
// completionPortThreads:
// 线程池中异步 I/O 线程的最大数目。
// 返回结果:如果更改成功，则为 true；否则为 false。
//public static bool SetMaxThreads(int workerThreads, int completionPortThreads);
ThreadPool.SetMaxThreads(5, 5);
for (int i = 1; i <= cycleNum; i++)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(testFun), i.ToString());
}
Console.WriteLine("主線程執行！");
Console.WriteLine("主線程終止！");
myEvent.WaitOne();
Console.WriteLine("線程池終止！");
Console.ReadKey();
}
public static void testFun(object obj)
{
cnt -= 1;//信號量自減
Console.WriteLine(string.Format("{0}:第{1}個線程", DateTime.Now.ToString(), obj.ToString()));
Thread.Sleep(5000);
if (cnt == 0)
{
myEvent.Set();
}
}
}运行结果：
上面例子中一开始非终止状态，当遇到WaitOne()方法时则会阻塞线程，在没有set()时将一直处于阻塞状态.
三、总结
既然说到了AutoResetEvent，就不得不说ManualResetEvent，这两个方法几乎相同，不同的地方就在于AutoResetEvent的WaitOne()方法执行后会自动又将信号置为不发送状态也就是阻塞状态，当再次遇到WaitOne()方法是又会被阻塞，而ManualResetEvent则不会，只要线程处于非阻塞状态则无论遇到多少次WaitOne()方法都不会被阻塞，除非调用ReSet()方法来手动阻塞线程。
到此这篇关于C#多线程之线程通讯(AutoResetEvent)的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
现在很多B/S系统的开发都是通过API方式来进行的，一般服务端会开放一个API接口，客户端调用API接口来实现图片或文件上传的功能，感兴趣的可以了解一下2021-05-05
同为微软的产品，本文将讨论的是C#如何创建Access数据库，同时创建数据库密码与相关操作，希望对大家有所帮助。2015-09-09
这篇文章主要为大家详细介绍了如何使用C#实现网页内容保存为图片并生成压缩包,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下2024-02-02
在C#Windows窗体应用中,我们经常遇到这样的问题,当我们触发一个窗口命令时,我连续点击其中一个命令,会出现多个同样的窗口,但我们是不管点击多少次,都只出现一次,所以本文给大家介绍了C#中窗体重复创建问题的解决方法,需要的朋友可以参考下2024-04-04
这篇文章介绍了C# 打开电子邮件软件的具体方法，有需要的朋友可以参考一下2013-11-11
使用C# 调用deepseek api接口实现正常访问的过程
本文介绍了使用C#调用deepseek API接口实现正常访问的方法,包括解决SSL/TLS安全通道问题和切换模型等常见问题,并提供了默认使用的reasoner模型和账户余额信息,感兴趣的朋友一起看看吧2025-02-02
ado.net提供了丰富的数据库操作,下面这篇文章主要给大家介绍了关于如何利用C#通过sql语句操作Sqlserver数据库教程的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2022-10-10
这篇文章主要介绍了C#文件和字节流的转换方法,涉及C#将文件以字节流形式读取及将字节流写入文件的相关技巧,需要的朋友可以参考下2015-05-05
TreeView 控件在 C# 中主要用于显示分层结构的数据,这通常是一个文件系统的表示,但也可以是任何具有父子关系的数据集合,本文给大家介绍了C#使用TreeView控件实现的二叉树泛型节点类及其方法,需要的朋友可以参考下2024-03-03
本篇文章主要是对C#中调用Windows API的技术要点进行了详细的介绍，需要的朋友可以过来参考下，希望对大家有所帮助2014-01-01
最新评论