线程同步资源锁定(三)Event_CoundownEvent

雨点打透心脏的1/2处 2022-08-05 02:17 113阅读 0赞

Event  的CountdownEvetn类用于处理若干个线程都完成任务以后，统一处理的情况。也是发送完成信号的。不同点是它通过计数的方法来确定所有的任务都完成以后。再发送可处理的信号。

class Program  
    \{  
        static void Main(string\[\] args)  
        \{  
            int taskCount = 6;  
            Calculator\[\] tasks = new Calculator\[taskCount\];  
            CountdownEvent mEvents = new CountdownEvent(taskCount);//这里不是声明的一个数组。而是设置了一个最初构造数的构造函数.  
  
  
            for (int i = 0; i < taskCount; i++)  
            \{  
                int currentI = i;//需要在循环中取得i的值，因为当Task.Run运行时，在读取i的值的时候，有可能i已经超出了允许循环值，但程序会错误地将值赋予Task。  
                tasks\[i\] = new Calculator(mEvents);//将总的计数信号器传入.  
                Task.Run(() => tasks\[currentI\].Calculation(i + 1, i + 3));  
            \}  
            mEvents.Wait();  
            Console.WriteLine("Task is Completed");  
            for (int i = 0; i < taskCount; i++)  
            \{  
               Console.WriteLine("Task \{0\} is finisthed!,the reslut is \{1\}", i, tasks\[i\].result);  
            \}  
            Console.ReadKey();  
        \}  
        private static void TaskMain(SemaphoreSlim semaphore)  
        \{  
            bool isCompleted=false;  
            while (!isCompleted)  
       \{  
           if(semaphore.Wait(500))  
                \{  
                    try  
                    \{  
                        Console.WriteLine("Task \{0\} locked the semaphor", Task.CurrentId);  
                        Thread.Sleep(2000);  
                    \}  
                    finally  
                    \{  
                        Console.WriteLine("Task \{0\} releases the semaphor", Task.CurrentId);  
                        semaphore.Release();  
                        isCompleted = true;  
                    \}               
                \}  
                else  
                \{  
                    Console.WriteLine("Task \{0\} not locked  the semaphor,await again", Task.CurrentId);  
                \}  
       \}  
        \}  
  \}  
    /// <summary>  
    /// 设计一个类，使其计算的多线程都完成以后发出信号，逾期依赖的程序能够往下运行.  
    /// </summary>  
    class Calculator  
    \{  
        public int result \{ get; private set; \}  
  
  
        private CountdownEvent mEvent;  
  
  
        public Calculator(CountdownEvent ev)  
        \{  
            this.mEvent = ev;  
        \}  
  
  
        public void Calculation(int x, int y)  
        \{  
            Console.WriteLine("Task \{0\} is start calculation",Task.CurrentId);  
            Thread.Sleep(new Random().Next(3000));  
            this.result = x + y;  
            Console.WriteLine("Task \{0\} is ready",Task.CurrentId);  
            mEvent.Signal();//计算完成，发出信号，使其等待的程序能够运行.  
        \}  
    \}