【C#】【Thread】Barrier任务并行

时间:2021-12-20 05:06:38

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非常接近类似