线程 ManualResetEvent 类「建议收藏」

全栈程序员站长

发布于 2022-09-14 10:18:09

4400

发布于 2022-09-14 10:18:09

大家好，又见面了，我是你们的朋友全栈君。 Reset(): 当一个线程开始一个活动（此活动必须完成后，其他线程才能开始）时，它调用 Reset 以将 ManualResetEvent 置于非终止状态。此线程可被视为控制 ManualResetEvent。

为了把状态修改为无信号的，必须调用ReSet()方法。

WaitOne(): 调用ManualResetEvent 上的 WaitOne 的线程将阻止，并等待信号。

Set ()当控制线程完成活动时，它调用 Set 以发出等待线程可以继续进行的信号。并释放所有等待线程。Set将事件状态设置为终止状态，允许一个或多个等待线程继续。

为了把状态修改为有信号的，必须调用Set()方法。

ManualResetEvent对象只能拥有两种状态之一：有信号(True)或无信号(false)。ManualResetEvent类继承于WaitHandle类，其构造函数的参数可确定对象的初始状态。

Set()和Reset()方法返回一个布尔值，表示是否进行了成功的修改。

using System;

using System.Collections.Generic;

using System.Text;

using System.Threading;

namespace ManualResetshiyan

{

class Program

{

static void Main(string[] args)

{

ManualResetEvent mansig;

mansig = new ManualResetEvent(false);

Console.WriteLine(“ManualResetEvent Before WaitOne”);

bool b = mansig.WaitOne(1000, true);

Console.WriteLine(“ManualResetEvent After WaitOne” + b);

Console.ReadLine();

}

上面的例子中，构造了false值的ManualResetEvent对象，布尔值False把ManualResetEvent对象的初始状态设置为无信号。接着调用基类WaigHandle的WaitOne()方法。程序块在WaitOne()方法中暂停一秒，然后因为超时而退出。ManualResetEvent的状态仍然是False,因而WaitOne()返回的布尔值b是False。

下面的例子把有信号改为无信号，调用ReSet()方法,Set()方法。

[csharp] view plain copy

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace 同步
{
class Program
{
static void Main(string[] args)
{
ManualResetEvent mansig;
mansig = new ManualResetEvent(true);
bool state = mansig.WaitOne(9000, true);
Console.WriteLine(“ManualResetEvent After WaitOne” + state);
mansig.Reset();
state = mansig.WaitOne(9000, true);
Console.WriteLine(“ManualResetEvent After WaitOne” + state);
mansig.Set();
state = mansig.WaitOne(9000, true);
Console.WriteLine(“ManualResetEvent After WaitOne” + state);
}
}
}

在ManualReset中，MnualTResetEvent对象的构造函数将其状态设置为有信号(true)，结果，线程不在第一个

WaitOne()方法中等待，并返回True值。接着，ManualResetEvent对象的状态重新设置为无信号的(false),于是线程在超时之前必须等待5秒,调用Set()方法后也不用等待。

下面在看一个程序：

[csharp] view plain copy

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace 同步实验
{
class Program
{ ///
/// ManualResetEvent建立时是把false作为start的初始状态，这个类用于通知另一个线程，让它等待一个或多个线程。
/// 如这个例子中，等待线程thread1线程调用mre.WaitOne(), 用于发信号的线程调用mre.Set().
///
public static ManualResetEvent mre = new ManualResetEvent(false);
public static void trmain()
{
Thread tr = Thread.CurrentThread;
Console.WriteLine(tr.Name + ” 开始第一波等待”);
mre.WaitOne(); //等到什么时候呢？等到mre.Set()被调用
Console.WriteLine(tr.Name + ” 第一波启动t”);
mre.Reset(); //再次重置
Console.WriteLine(tr.Name + ” 开始第二波等待”);
mre.WaitOne(); //再次等待
Console.WriteLine(tr.Name + ” 第二波启动”);
for (int x = 0; x < 10; x++)
{
Thread.Sleep(1000);
Console.WriteLine(tr.Name + “: ” + x);
}
}
static void Main(string[] args)
{
Thread thrd1 = new Thread(new ThreadStart(trmain));
thrd1.Name = “thread1”;
thrd1.Start();
Thread thrd2 = new Thread(new ThreadStart(trmain));
thrd2.Name = “thread2”;
thrd2.Start();
for (int x = 0; x < 10; x++)
{
Thread.Sleep(900);
Console.WriteLine(“Main :” + x);
if (5 == x)
{
mre.Set(); //子线程的mre.WaitOne()可以执行了。第一次等待进程
//; //如果什么都不做呢，mre.Wait()那个线程就一直等在那里了？
}
}
while (thrd1.IsAlive)
{
Thread.Sleep(1000);
Console.WriteLine(“Main: waiting for thread to stop…”);
mre.Set(); //第二次通知等待进程
}
}
}
}

下面在看一个关于ManualResetEvent　waitany的程序：

waitany一直等到有信号　才开始执行下面的语句．

[csharp] view plain copy

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace 同步实验
{
class Program
{
public static ManualResetEvent m_eventTemporaryTrigger;
public static ManualResetEvent m_eventQuitTemporary;
private static string m_triggerParam;
public static void TemporaryConnThreadTrigger(String param)
{
m_triggerParam = param;
m_eventTemporaryTrigger.Set();
}
static void Main(string[] args)
{
m_eventTemporaryTrigger =new ManualResetEvent(true);
m_eventQuitTemporary = new ManualResetEvent(true);
//m_eventQuitTemporary = new ManualResetEvent(false);
m_eventTemporaryTrigger.Reset(); //临时线程处于工作之中时，m_eventTemporaryTrigger始终处于被触发状态
// Trigger.strmain();
WaitHandle[] events = new WaitHandle[2];
events[0] = m_eventQuitTemporary;
events[1] = m_eventTemporaryTrigger;
//等待退出信号事件或触发事件
// 返回结果:
// 满足等待的对象的数组索引。
int index = WaitHandle.WaitAny(events);
Console.WriteLine(“run no wait”);
if (index == 0)
{ //如果是将Main（），第三行置为false则不执行下面语句
Console.WriteLine(“m_eventQuitTemporary run”);
Console.WriteLine(m_triggerParam);
}
}
}
public class Trigger
{
public static void strmain()
{
Program.TemporaryConnThreadTrigger(“m_eventQuitTemporary run show”);
}
}
}

要注意的是ManualResetEvent和AutoResetEvent 的构造函数都有一个bool的参数，用这个参数可以指定初始情况下，同步对象的处于阻塞（设置为false）还是非阻塞（设置为true）的状态。另外WaitOne方法也可以带两个参数： WaitOne (int millisecondsTimeout,bool exitContext) millisecondsTimeout：等待的毫秒数，或为 Timeout.Infinite (-1)，表示无限期等待。 exitContext：为 true，则等待之前先退出上下文的同步域（如果在同步上下文中），然后在稍后重新获取它；否则为false。就是说，等待是可以加上一个期限的，如果等待的同步对象一直都不Set()的话，那么程序就会卡死，所以在WaitOne方法里面可以放置一个时间期限，单位是毫秒。

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/158637.html原文链接：https://javaforall.cn

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022年7月1，如有侵权请联系 cloudcommunity@tencent.com 删除

c++