探究Visual Studio 2010中Parallel的使用(4) 软件测试
更复杂的任务之间的同步
我们在使用Barrier进行并行任务之间的同步时，有这样一个缺陷，我们需要预先知道所有需要同步的并行任务的数目，如果这个数目是随机的，就无法使用Barrier进行任务之间的同步了。并行任务数目不定这种情况很常见。我们还是来看上文中看电影的例子，每场进电影院看电影的观众数目是不固定的，那么退场的观众也是不固定的，甚至还有中途退场的。当所有观众都退场后，我们需要打扫电影院的卫生。这里需要的同步的就是所有观众都退场。针对这种数目不定的多个并行任务，.NET Framework提供了CountdownEvent这个类来进行任务之间的同步。
就像它的名字一样，CountdownEvent基于这样一个简单的规则：当有新的需要同步的任务产生时，就调用AddCount增加它的计数，当有任务到达同步点是，就调用Signal函数减小它的计数，当CountdownEvent的计数为零时，就表示所有需要同步的任务已经完成，可以开始下一步任务了。下面我们利用CountdownEvent来模拟一下观众进场立场的情景。
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace CountdownEventDemo { // 观众类，用来表示一位观众 class Customer { public Customer(int nID) { m_nID = nID; } // 观众的ID public int m_nID; } class Program { static void Main(string[] args) { // 创建CountdownEvent同步对象 using (var countdown = new CountdownEvent(1)) { // 产生一个随机数，表示观众的数目 Random countRandom = new Random(DateTime.Now.Millisecond); int nCount = countRandom.Next(10); // 构造每一位观众看电影的任务 Action[] seeafilm = new Action[ nCount ]; for (int i = 0; i < nCount; i++) { // 构造Customer对象，表示观众 Customer currentCustomer = new Customer( i+1 ); seeafilm[i] = () => { // 观众进场 countdown.AddCount(); Console.WriteLine("观众 {0} 进场。", currentCustomer.m_nID); // 模拟看电影的时间 Thread.Sleep(countRandom.Next(3000,6000)); // 观众退场 countdown.Signal(); Console.WriteLine("观众 {0} 退场。", currentCustomer.m_nID); }; } //并行执行任务 Parallel.Invoke( seeafilm ); // 在此同步，最后CountdownEvent的计数变为零 countdown.Signal(); countdown.Wait(); } Console.WriteLine("所有观众退场，开始打扫卫生。"); Console.ReadKey(); }
在这段代码中，我们使用CountdownEvent进行随机个数任务之间的同步。最后，我们可以得到这样的输出。
图3 使用CountdownEvent进行同步
通过Parallel.Invoke函数，我们可以轻松地将相互独立的任务并行执行，同时通过Barrier和CountdownEvent类进行任务之间的同步。这种并行计算的开发方式，比以前那种基于线程的并行计算开发方式简便很多，解放了程序员的脑袋，让他们可以把更多的脑力放到业务逻辑问题的解决之上。使用Parallel类，多快好省地开发并行计算应用程序。
文章来源于领测软件测试网 https://www.ltesting.net/
