C#线程同步Barrier

MaybeHC

发布于 2024-04-23 19:09:17

4090

Barrier中提供了一个回调函数，每个线程调用SignalAndWait方法后该回调函数会被执行。 eg：

static Barrier _barrier = new Barrier(3, b => Console.WriteLine("1"));

在上面我们初始化了一个Barrier，并在构造中设置为将等待的信号数量为3，这就意味着如何想好执行回调函数Console.WriteLine("1")，则需要在线程中执行三次_barrier.SignalAndWait();这样才能释放线程并执行回调函数下面举个例子

 static Barrier _barrier = new Barrier(2, b => Console.WriteLine("End of phase {0}", b.CurrentPhaseNumber + 1));
        static void PlayMusic(string name ,int seconds)
        {
            for(int i = 1; i < 3; i++)
            {
                Console.WriteLine("--------------------");
                Thread.Sleep(TimeSpan.FromSeconds(seconds));
                Console.WriteLine("{0}线程启动",name);
                Thread.Sleep(TimeSpan.FromSeconds(seconds));
                Console.WriteLine("{0}线程完成",name);
                _barrier.SignalAndWait();
            }
        }
        static void Main(string[] args)
        {
            var t1 = new Thread(() => PlayMusic("a", 5));
            var t2 = new Thread(() => PlayMusic("b", 2));
            t1.Start();
            t2.Start();

            Console.ReadKey();
        }

我们直接来看看运行的情况