C#之使用AutoResetEvent实现线程的顺序执行

前几天一朋友问我如何实现线程的顺序执行,说真的,虽然看过CLR这本书,也把线程部分拜读了两遍,但是这个问题出来之后还是没有一个思路。今天在搜索资料的时候无意中再次看到AutoResetEvent这个东西,当然我知道它是和线程有关,用于处理线程切换之类的(可能在测试Demo之前理解有误),于是决定用AutoResetEvent来处理上面的问题。

这里以园区一个园友的例子来说明,这个例子就是 买书--》付款--》拿书这个过程,该过程会持续n(通过变量设置)次,并且每一次都要按照顺序执行,有可能有同学会疑问,直接Sleep不就好了,干嘛非要多个线程,如果处理某一个环节的时间过久或者是业务复杂,那么整个程序就直接未响应了,所以这里加入多线程来保证程序的响应。

class Program
    {
        //循环次数
        const int numIterations = 10;
        //买书
        static AutoResetEvent buyResetEvent = new AutoResetEvent(false);
        //付款
        static AutoResetEvent payResetEvent = new AutoResetEvent(false);
        //取书
        static AutoResetEvent getBookEvent = new AutoResetEvent(false);
       //循环的次数
        static int number;
        static void Main(string[] args)
        {
            //付款线程
            Thread payMoneyThread = new Thread(new ThreadStart(PayMoneyProc));
            payMoneyThread.Name = "付钱线程";

            //取书线程
            Thread getBookThread = new Thread(new ThreadStart(GetBookProc));
            getBookThread.Name = "取书线程";

            payMoneyThread.Start();
            getBookThread.Start();

            for (int i = 1; i <= numIterations; i++)
            {
                Console.WriteLine("买书线程:数量{0}", i);
                number = i;
                //允许付款线程等待
                payResetEvent.Set();
                //禁止买书线程等待
                buyResetEvent.WaitOne();
            }
            Console.Read();
        }

        static void PayMoneyProc()
        {
            while (true)
            {
                //等待付款
                payResetEvent.WaitOne();
                Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);
                //允许取书线程等待
                getBookEvent.Set();
            }
        }
        static void GetBookProc()
        {
            while (true)
            {
                //等待付款
                getBookEvent.WaitOne();
                Console.WriteLine("{0}:数量{1}", Thread.CurrentThread.Name, number);
                Console.WriteLine("------------------------------------------");
                //允许买书线程等待(到这一步一个完整的买书流程就执行结束了,完全按照买书--》付款--》取书的流程)
                buyResetEvent.Set();
            }
        }
    }

上述代码不复杂,但是有几个关键的对象和方法,接下来详细进行说明。

1.分别定义了买书、付款、拿书三个AutoResetEvent,注意定义的时候传入了false,这也AutoSet默认是不可用的,需要手动调用Set方法才可以呢。该对象是决定是否能WaitOne一个请求的关键,当AutoResetEvent.Set执行则可以使用AutoResetEvent.WaitOne进行一个等待请求,如果再有WaitOne请求,则要继续等待Set的执行;

2.先看for循环,在循环中我们使用payResetEvent.Set()这句代码,这也PayThread中的WaitOne请求就可以获得批准(下文有介绍),同时我们又加上了buyResetEvent.WaitOne()(这样在上一次购买流程结束之前,新的一次流程是不可以执行的,这也就是我们的最大问题,保证线程按照顺序执行);

3.定义了付款和拿书的Thread,并且在方法内都是While循环,该循环主要是为了可以将我们的过程进行多次,毕竟线程只会执行一遍嘛。当然这个不是重点,重点是While中我们的操作,先看PayThrea的操作,先调用payResetEvent.WaitOne()请求一个等待操作,当然可以立马执行,因为在 2 中我们说了for中是调用了payResetEvent.Set()操作,这样就可以直接得到一个请求响应,输出关键信息,然后又到了重点,我们调用了getBookEvent.Set(),这是为什么呢,因为付款不成功是不可以拿书走的啊,那样就是偷盗了。注意、注意、注意,重要的话说三遍,GetBookThread操作中也有一个waitOne请求,可是为什么不会执行呢,因为没有Set呢,我们初始化AutoResetEvent的时候我们设置的是false,这样默认就不可以得到一个请求,必须手动调用Set才可以,由于在PayMoneyThread的最后一行代码中我们调用了getBookEvent.Set(),这样getBookEvent.WaitOne就可用了。在GetBookThread中依次输出关键信息,最后一行代码又来了,再次调用了一个AutoResetEvent.Set(),没错就是买书的对象,因为到了这一步完整的买书流程就结束了,可以再次买书了啊啊啊啊啊啊,可以买书了,好开心啊。然后再次回到for循环中的最后一行代码,buyResetEvent.Wait()此时就复活了,开始第好几次的买书流程。

运行截图如下(绝对真实,毫无PS):

好了,退朝,有事改天上朝再议。

时间: 2024-10-14 20:20:12

C#之使用AutoResetEvent实现线程的顺序执行的相关文章

如何保证线程按顺序执行

Thread类构造方法:1.Thread():2.Thread(String name):3.Thread(Runable r):4.Thread(Runable r, String name): thread类常用方法:start();//启动线程getId();//获得线程IDgetName();//获得线程名字getPriority();//获得优先权isAlive();//判断线程是否活动isDaemon();//判断是否守护线程getState();//获得线程状态sleep(long

让线程按顺序执行8种方法

实现我们下面需要完成这样一个应用场景: 1.早上:2.测试人员.产品经理.开发人员陆续的来公司上班:3.产品经理规划新需求:4.开发人员开发新需求功能:5.测试人员测试新功能. 规划需求,开发需求新功能,测试新功能是一个有顺序的,我们把thread1看做产品经理,thread2看做开发人员,thread3看做测试人员. 1.使用线程的join方法 join():是Theard的方法,作用是调用线程需等待该join()线程执行完成后,才能继续用下运行. 如果想学习Java工程化.高性能及分布式.深

async 与 await 线程调用顺序

用async做一个多线程下载并在datagridview中即时更新,运行时在达到4个线程同时下载时界面卡顿,多次尝试后是不知道async与await线程调用顺序造成. 进入async方法后在调用await之前代码都在主线程(调用线程)中运行,调用await时及之后的async方法代码将另起线程运行该部分代码,而主线程在遇到await后回到主线程继续执行async后的代码. 将async方法通过声明委托后用begininvoke调用后解决.

利用C# AutoResetEvent进行线程同步

AutoResetEvent 允许线程通过发信号互相通信. 通常,当线程需要独占访问资源时使用该类. 线程通过调用 AutoResetEvent 上的 WaitOne 来等待信号. 如果 AutoResetEvent 为非终止状态,则线程会被阻止,并等待当前控制资源的线程通过调用 Set 来通知资源可用. 调用 Set 向 AutoResetEvent 发信号以释放等待线程. AutoResetEvent 将保持终止状态,直到一个正在等待的线程被释放,然后自动返回非终止状态. 如果没有任何线程在

Java中线程顺序执行

现有线程threadone.threadtwo和threadthree,想要的运行顺序为threadone->threadtwo->threadthree,应该如何处理?这里需要用到一个简单的线程方法join(). join()方法的说明:join方法挂起当前调用线程,直到被调用线程完成后在继续执行(join() method suspends the execution of the calling thread until the object called finishes its ex

Java 线程同步执行(顺序执行)

关于线程,有两种实现方法, 一种是通过继承Runnable接口,另外一种通过扩展Thread类,两者的具体差别,可参考我找的这篇文章 http://www.cnblogs.com/rollenholt/archive/2011/08/28/2156357.html .本主主要是讲 线程的同步执行问题.. 如果程序是通过扩展Thread类的,网上的资料说可以通过 join()函数实现,但本人亲测,此法无法通过.程序如下: public class test1 extends Thread { pu

多个线程实现顺序打印数据,(可自定义线程一次打印数量和总数量)

最近看到一道面试题:让3个线程顺序打印数字,如线程1打印1-5,线程2打印6-10,线程3打印11-15,然后是线程1打印16-20...一直打印到75结束. 这到题主要问题有两点: 第一点是不能让线程打印的过程中出现其他线程 第二点是要实现线程进入的过程是有序的,如上123123..这样. 我先是把基本的功能实现了,后来发现可以改造一下,做成可扩展的,即每次打印的数量可自定义,总的数量可自定义,并且保证线程的顺序是有序的,下面是具体代码: PrintQueue.java 文件,同步线程,控制打

有三个线程,怎么让他们按顺序执行?

场景:有三个线程t1.t2.t3.确保三个线程t1执行完后t2执行,t2执行完成后t3执行. 方法1:thread.Join把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程.比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B. package com.gs.demo1; public class ThreadTest1 { public static void main(String[] args) { Thread t1 = new

JAVA多线程按指定顺序执行线程 Condition应用

package concurrent; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.ReentrantLock; /** * Auth: zhouhongliang * Date:2019/8/1 * 线程等待与唤醒机制 Condition * 按指定顺序执行线程 */ public class ConditionDemo { public static void main(Stri