首页 > 编程语言> > C#读写者线程（用AutoResetEvent实现同步）

C#读写者线程（用AutoResetEvent实现同步）

2020-08-24 05:31:23 作者：互联网

（三二一、小鱼）相关研究、学习内容所做的笔记，欢迎广大朋友指正！
　　
　　C#读写者线程（用AutoResetEvent实现同步）
　　
　　1. AutoResetEvent简介
　　
　　通知正在等待的线程已发生事件。无法继承此类。
　　
　　常用方法简介：
　　
　　AutoResetEvent(bool initialState)：构造函数，用一个指示是否将初始状态设置为终止的布尔值初始化该类的新实例。
　　
　　false：无信号，子线程的WaitOne方法不会被自动调用 true：有信号，子线程的WaitOne方法会被自动调用
　　
　　public bool Reset ()：将事件状态设置为非终止状态，导致线程阻止；如果该操作成功，则返回true；否则，返回false。
　　
　　public bool Set ()：将事件状态设置为终止状态，允许一个或多个等待线程继续；如果该操作成功，则返回true；否则，返回false。
　　
　　对于具有 EventResetMode.AutoReset（包括 AutoResetEvent）的 EventWaitHandle，Set 方法释放单个线程。如果没有等待线程，等待句柄将一直保持终止状态，直到某个线程尝试等待它，或者直到它的 Reset 方法被调用。
　　
　　对于具有 EventResetMode.ManualReset（包括 ManualResetEvent）的 EventWaitHandle，调用Set 方法将使等待句柄一直保持终止状态，直到它的 Reset 方法被调用。
　　
　　WaitOne方法
　　
　　当在派生类中重写时，阻止当前线程，直到当前的 WaitHandle 收到信号。
　　
　　WaitHandle.WaitOne () 当在派生类中重写时，阻止当前线程，直到当前的 WaitHandle 收到信号。由.NET Compact Framework 支持。
　　
　　WaitHandle.WaitOne(Int32, Boolean) 在派生类中被重写时，阻止当前线程，直到当前的WaitHandle 收到信号，使用 32 位有符号整数度量时间间隔并指定是否在等待之前退出同步域。由 .NET Compact Framework 支持。
　　
　　WaitHandle.WaitOne(TimeSpan, Boolean) 在派生类中被重写时，阻止当前线程，直到当前实例收到信号，使用 TimeSpan 度量时间间隔并指定是否在等待之前退出同步域。
　　
　　2. 读写者线程例子
　　
　　本例子中，主线程作为写线程，要对某个数据（本例中是个变量）赋值（即写动作），而读线程则等待写线程每次写完数据发出通知，待读线程收到通知后，将数据读出并显示。
　　
　　[Csharp] view plaincopyprint?
　　
　　using System;
　　
　　using System.Collections.Generic;
　　
　　using System.Text;
　　
　　using System.Threading;
　　
　　namespace TestAutoResetEvent
　　
　　{
　　
　　///

　　
　　/// 读写者线程
　　
　　/// 主线程写，子线程读，且只有将数据写入后，读线程才能将其读出
　　
　　///

　　
　　class Program
　　
　　{
　　
　　//写线程将数据写入myData
　　
　　staticint myData = 100;
　　
　　//读写次数
　　
　　constint readWriteCount = 10;
　　
　　//false:初始时没有信号
　　
　　static AutoResetEvent autoResetEvent = new AutoResetEvent(false);
　　
　　staticvoid Main(string[] args)
　　
　　{
　　
　　//开启一个读线程(子线程)
　　
　　Thread readerThread = new Thread(new ThreadStart(ReadThreadProc));
　　
　　readerThread.Name = "ReaderThread";
　　
　　readerThread.Start();
　　
　　for (int i = 1; i <= readWriteCount; i++)
　　
　　{
　　
　　Console.WriteLine("MainThread writing : {0}", i);
　　
　　//主(写)线程将数据写入
　　
　　myData = i;
　　
　　//主(写)线程发信号，说明值已写过了
　　
　　//即通知正在等待的线程有事件发生
　　
　　autoResetEvent.Set();
　　
　　Thread.Sleep(1);
　　
　　}
　　
　　//终止线程
　　
　　readerThread.Abort();
　　
　　}
　　
　　staticvoid ReadThreadProc()
　　
　　{
　　
　　while (true)
　　
　　{
　　
　　//在数据被写入前，读线程等待（实际上是等待写线程发出数据写完的信号）
　　
　　autoResetEvent.WaitOne();
　　
　　Console.WriteLine("{0} reading : {1}", Thread.CurrentThread.Name, myData);
　　
　　}
　　
　　}
　　
　　}
　　
　　}
　　
　　using System;
　　
　　using System.Collections.Generic;
　　
　　using System.Text;
　　
　　using System.Threading;
　　
　　namespace TestAutoResetEvent
　　
　　{
　　
　　///
　　
　　/// 读写者线程
　　
　　/// 主线程写，子线程读，且只有将数据写入后，读线程才能将其读出
　　
　　///
　　
　　class Program
　　
　　{
　　
　　//写线程将数据写入myData
　　
　　static int myData = 100;
　　
　　//读写次数
　　
　　const int readWriteCount = 10;
　　
　　//false:初始时没有信号
　　
　　static AutoResetEvent autoResetEvent = new AutoResetEvent(false);
　　
　　static void Main(string[] args)
　　
　　{
　　
　　//开启一个读线程(子线程)
　　
　　Thread readerThread = new Thread(new ThreadStart(ReadThreadProc));
　　
　　readerThread.Name = "ReaderThread";
　　
　　readerThread.Start();
　　
　　for (int i = 1; i <= readWriteCount; i++)
　　
　　{
　　
　　Console.WriteLine("MainThread writing : {0}", i);
　　
　　//主(写)线程将数据写入
　　
　　myData = i;
　　
　　//主(写)线程发信号，说明值已写过了
　　
　　//即通知正在等待的线程有事件发生
　　
　　autoResetEvent.Set();
　　
　　Thread.Sleep(1);
　　
　　}
　　
　　//终止线程
　　
　　readerThread.Abort();
　　
　　}
　　
　　static void ReadThreadProc()
　　
　　{
　　
　　while (true)
　　
　　{
　　
　　//在数据被写入前，读线程等待（实际上是等待写线程发出数据写完的信号）
　　
　　autoResetEvent.WaitOne();
　　
　　Console.WriteLine("{0} reading : {1}", Thread.CurrentThread.Name, myData);
　　
　　}
　　
　　}
　　
　　}
　　
　　}
　　
　　运行结果如下：
　　
　　bubuko.com,布布扣
　　
　　有结果可知，当主线程睡眠时间大于0值时，读线程即有足够的时间读取写线程写入的数据。这个睡眠时间的长短可以根据实际应用中子线程的计算量设定。
　　
　　4. 对1再进行修改
　　
　　主线程在写完数据后根本不睡吗呢？这个时候会发生什么事情？
　　
　　[Csharp] view plaincopyprint?
　　
　　using System;
　　
　　using System.Collections.Generic;
　　
　　using System.Text;
　　
　　using System.Threading;
　　
　　namespace TestAutoResetEvent
　　
　　{
　　
　　///

　　
　　/// 读写者线程
　　
　　/// 主线程写，子线程读，且只有将数据写入后，读线程才能将其读出
　　
　　///

标签：search,manhua,keyword,Q631067,C#,AutoResetEvent,线程,https,com
来源： https://www.cnblogs.com/ilpr/p/13551760.html