探究Visual Studio 2010中Parallel的使用(3)

　　探究Visual Studio 2010中Parallel的使用(3)  軟件測試

　　并行任務之間的同步

　　有時候我們在處理并行任務的時候，各個任務之間需要同步，也就是同時執行的并行任務，需要在共同到達某一個狀態的后再一共繼續執行。我們可以舉一個現實生活中的例子。陳良喬，賈瑋和單春暉是好朋友，他們相約到電影院看《建國大業》。他們三個住在不同的地方，為了能一起買票進電影院，他們約好先在電影院門口的KFC會合，然后再一起進電影院。這其中就涉及到一個同步的問題：他們需要先在KFC會合。他們是從家里分別到KFC的，但是需要在KFC進行同步，等到三個人都到齊后在完成后后繼的動作，進電影院看電影。

　　為了完成并行任務之間的同步，.NET Framework中提供了一個類Barrier。顧名思義，Barrier就像一個關卡或者是剪票口一樣，通過Barrier類，我們可以管理并行任務的執行，完成他們之間的同步。Barrier類的使用非常簡單，我們只需要在主線程中聲明一個Barrier對象，同時指明需要同步的任務數。然后，在需要進行同步的地方調用Barrier類的SignalAndWait函數就可以了。 當一個并行任務到達SignalAndWait后，它會暫停執行，等待所有并行任務都到達同步點之后再繼續往下執行。下面我們以一個實際的例子，來看看如何利用Barrier類完成看電影的同步問題。

　　using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace ParallelBarrier { class Program { // 用于同步的Barrier對象 static Barrier sync; static void Main(string[] args) { // 創建Barrier對象，這里我們需要同步 // 任務有三個 sync = new Barrier(3); // 開始執行并行任務 var steps = new Action[] { () => gotothecinema("陳良喬", TimeSpan.FromSeconds(5) ), () => gotothecinema("賈瑋", TimeSpan.FromSeconds(2) ), () => gotothecinema("單春暉", TimeSpan.FromSeconds(4) )}; Parallel.Invoke(steps); Console.ReadKey(); } // 任務 static void gotothecinema(string strName, TimeSpan timeToKFC ) { Console.WriteLine("[{0}] 從家里出發。", strName); // 從家里到KFC Thread.Sleep(timeToKFC); Console.WriteLine("[{0}] 到達KFC。", strName); // 等待其他人到達 sync.SignalAndWait(); // 同步后，進行后繼動作 Console.WriteLine("[{0}] 買票進電影院。", strName); } } }

　　在這段代碼中，我們首先創建了Barrier對象，因為在這里需要同步的任務有三個，所以創建Barrier對象時是的參數是3。然后就是使用Parallel.Invoke執行并行任務。我們在并行任務gotothecinema中設置了一個同步點，在這里我們調用Barrier對象的SignalAndWait函數，它表示當前任務已經到達同步點并同時等待其他任務到達同步點。當所有任務都到達同步點之后，再繼續往下執行。運行上面的程序，我們可以獲得這樣的輸出：

　　圖2 使用Barrier進行同步

原文轉自：http://www.anti-gravitydesign.com