多线程中的ManualResetEvent

先来看一下简单的多线程控制台程序:

using System;
using System.Threading;

namespace ManualResetEventStudy
{

    class ThreadClass
    {
        static void t1()
        {
            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("t1的x:" + x);
            }
        }

        static void t2()
        {
            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("t2的x:" + x);
            }
        }

        static void Main(string[] args)
        {
            Thread thrd1 = new Thread(t1);
            thrd1.Start();

            Thread thrd2 = new Thread(t2);
            thrd2.Start();

            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("主线程中的x:" + x);
            }

            Console.Read();
        }       
    }
}

 入口方法Main里,创建了二个线程,分别调用方法t1与t2,再加上主线程本身,一并有三个线程,运行后,三个线程都在计数输出,结果类似如下:

t2的x:1
t1的x:1
主线程中的x:1
t2的x:2
t1的x:2
主线程中的x:2
t2的x:3
t1的x:3
主线程中的x:3
t2的x:4
t1的x:4
主线程中的x:4
t2的x:5
t1的x:5
主线程中的x:5

 

三个线程的顺序,在这段代码中我们是无法控制的,天知道谁先开始/谁先结束,反正都是"并行"处理,完全看CPU当时的心情  :)

问题:如果需求有变化,比如要求在主线程执行到某个特定的位置(或时间点)时,才让其它线程开始介入,该怎么做呢?(这种情况实际中很常见,比如某一项计算的入口参数依赖于另一项计算的结果,再比如我们计算月工资前,得先统计出员工当月考勤情况)

System.Threading命名空间下有一个ManualResetEvent类,可以做到这一点:

using System;
using System.Threading;

namespace ManualResetEventStudy
{

    class ThreadClass
    {       

        static ManualResetEvent mre = new ManualResetEvent(false);

        static void t1()
        {
            mre.WaitOne(1000);//等待1秒后,自行启动
            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("t1的x:" + x);
            }
        }

        static void t2()
        {
            mre.WaitOne();//一直等待下去,直到有"人"调用mre.set()发出信号为止
            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("t2的x:" + x);
            }
        }

        static void Main(string[] args)
        {
            Thread thrd1 = new Thread(t1);
            thrd1.Start();

            Thread thrd2 = new Thread(t2);
            thrd2.Start();

            for (int x = 1; x <= 5; x++)
            {
                Thread.Sleep(500);
                Console.WriteLine("主线程中的x:" + x);

                if (x == 3) 
                {
                    mre.Set();//通知所有等待的线程:“同志们,可以动啦”:)
                }
            }

            Console.Read();
        }        

    }
}

 t1方法中,我们用 mre.WaitOne(1000);让调用该方法的线程先等候1秒,t2方法中,我们用mre.WaitOne()无限等候,然后主线程中计数到3的时候,手动调用mre.Set()方法唤醒所有等候中的线程,运行结果类似下面这样:

主线程中的x:1
主线程中的x:2
t1的x:1
主线程中的x:3
t1的x:2
t2的x:1
主线程中的x:4
t1的x:3
主线程中的x:5
t2的x:2
t1的x:4
t2的x:3
t1的x:5
t2的x:4
t2的x:5

 

 

 

时间: 2024-10-21 17:23:37

多线程中的ManualResetEvent的相关文章

(单例设计模式中)懒汉式与饿汉式在多线程中的不同

/*  目的:分析一下单例设计模式中,懒汉式与饿汉式在多线程中的不同!  开发时我们一般选择饿汉式,因为它简单明了,多线程中不会出现安全问题!  而饿汉式需要我们自己处理程序中存在的安全隐患,但是饿汉式的程序技术含量更高! */ /* class SinglePerson implements Runnable{    private static SinglePerson ss = new SinglePerson("hjz", 22);//恶汉式    private int ag

关于java多线程中的join方法

问题描述 关于java多线程中的join方法 1.主线程可能在子线程结束之前 结束吗?如果可能的话 举一个例子 2.如何理解join方法, 结合实际应用. 非常感谢非常感谢!!! 解决方案 关于join,参考:http://www.blogjava.net/jnbzwm/articles/330549.html 解决方案二: 主线程可能在子线程结束之前 结束吗 一般来说不可以,但是也不一定,如果子线程在执行finally中的代码,应该会等它执行完了才退出. 晕,join方法和什么"让主线程等子线

Java多线程中的两个问题

多线程|问题 多线程中Thread.stop()被废弃的原因:当调用Thread.stop()方法时,该线程将释放先前其控制的所有资源,而在线程没有正常执行完毕之前强迫Stop之后,这些资源可能处在一种不一致的状态,而这些处于不一致的状态的资源被其他的线程所使用之后,就可能会发生一些意想不到的错误.实现时间差事件的解决办法:在主线程中设置一个状态变量,在响应线程执行时,先sleep()一个固定的时间段,之后检查主线程的这个状态,如果这个状态不同就执行不同的操作,或停止执行.可以通过回调机制来实现

[C#学习]在多线程中如何调用Winform

问题的产生: 我的WinForm程序中有一个用于更新主窗口的工作线程(worker thread),但文档中却提示我不能在多线程中调用这个form(为什么?),而事实上我在调用时程序常常会崩掉.请问如何从多线程中调用form中的方法呢? 解答: 每一个从Control类中派生出来的WinForm类(包括Control类)都是依靠底层Windows消息和一个消息泵循环(message pump loop)来执行的.消息循环都必须有一个相对应的线程,因为发送到一个window的消息实际上只会被发送到

多线程中递归锁的实现.

在上一篇文章中,我已经阐述了多线程中简单锁的实现,可在结束的时候,我就提了那么一个问题,那就是如果在一个链表中进行插入时,要进行查询的操作,如果只是简单的锁,是没法实现的.所以"递归锁"就浮现于世了. 可能有些人看到递归这两个字,有点傻了眼,其实也没什么的,简单的介绍,就是进行简单的计数而已.刚开始引用锁的时候,就产生它,当在锁没有解开的时候,还要继续用锁,就简单的加一,解开一把就减一,当计数为零时,就把锁销毁掉.下面用程序来简单的阐述一下,递归锁是怎么实现的: 1.递归锁接口的定义.

在多线程中使用静态方法是否有线程安全问题

   类的成员分为两类,静态成员(static member)和实例成员(instance member).静态成员属于类,实例成员则属于对象,即类的实例.     简单讨论一下在一个类中使用静态字段(static field)和静态方法(static method)是否会有线程安全问题.      我们在知道, 静态字段(static field)和静态方法(static method)的调用是通过类来调用.静态方法不对特定的实例操作,只能访问静态成员.实例方法可对特定的实例操作,既能访问静态

文件操作-多线程中对文件进行写操作

问题描述 多线程中对文件进行写操作 我的多线程部分程序是这样的: UINT ClientThread(LPVOID pParam) { EnterCriticalSection(&cs); Cw_dispctrlDlg dlg=(Cw_dispctrlDlg)pParam; while(true) { -- -- dlg->file_net.Open(dlg->str_file_netpath, CFile::modeCreate | CFile::modeNoTruncate | C

代码-关于datagridview在多线程中滚动条无法使用的问题

问题描述 关于datagridview在多线程中滚动条无法使用的问题 private delegate void InvokeHandler(); //子线程中 this.Invoke(new InvokeHandler(delegate() { dataGridView1.DataSource = null; dataGridView1.DataSource = dgv_dt; })); 在网上查的到是这么解决的,但是我不知道该把代码贴在哪里,已经把datasource换成了自己的datata

java join-java多线程中的join问题

问题描述 java多线程中的join问题 各位大神,本人java小菜鸟.学习java遇到一点问题,下面的代码中,已经使用了join方法,为什么显示的结果不是1000呢?请前辈指教! public class JoinThread extends Thread { public static volatile int n=0; public void run(){ for(int i=0;i<10;i++,n++){ try{ sleep(2); }catch(Exception e){} } }