C#ThreadBarrier任务并行

Posted 2020-08-25 梦琪小生

Barrier  是一个对象，它可以在并行操作中的所有任务都达到相应的关卡之前，阻止各个任务继续执行。 如果并行操作是分阶段执行的，并且每一阶段要求各任务之间进行同步，则可以使用该对象。 ——MSDN

        private void BarrierTest()
        {
            Barrier bar = new Barrier(4);
            Task[] task = new Task[4];
            Action act = () =>
            {
                MessageBox.Show("start");
                bar.SignalAndWait();
                MessageBox.Show("minddle");
                bar.SignalAndWait();
                MessageBox.Show("end");
            };
            for (int i = 0; i < task.Length; ++i)
            {
                task[i] = new Task(act);
                task[i].Start();
            }
        }        

简单理解就是:

设定一个量，每个线程运行到这停止，等其他所有线程都到达这个点，然后继续运行。

上述例子可以看出：

设定了 4 这个数量，然后4个线程同时运行，先弹出4个start，然后一个一个点掉，当最后一个点击掉之后一起弹出4个middle.....

也就是说不会因为第一个start点掉了，马上就弹出一个middle，要等4个都点掉....

 Barrier 和 CountdownEvent非常接近类似