探究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类,多快好省地开发并行计算应用程序。