Use Barrier to control the thread synchronization example

  • 2020-06-19 11:32:50
  • OfStack

Possible outputs:


Working on Thread A
Working on Thread B
Thread B will sleep for 10 seconds.
Thread A will sleep for 847 seconds.
Working on Thread C
Thread C will sleep for 26 seconds.
Working on Thread D
Thread D will sleep for 351 seconds.
Working on Thread E
Thread E will sleep for 249 seconds.
All jobs have been done.

Code:


using System;
using System.Threading;
class BarrierDemo
{
    static Barrier _barrier = new Barrier (5, barrier => {
            Console.WriteLine();
            Console.WriteLine("All jobs have been done.");
        });
    static void Main()
    {
        Random r = new Random();
        new Thread(Work).Start(new MyThreadArgs { ThreadId = "A", 
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "B",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "C",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "D",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "E",
            WaitTimeCount = r.Next(1000) });
    }
    static void Work(object obj)
    {
        MyThreadArgs args = (MyThreadArgs) obj;

        Console.WriteLine("Working on Thread " + args.ThreadId);
        Console.WriteLine("Thread " + args.ThreadId +
            " will sleep for " + args.WaitTimeCount + " seconds.");
        Thread.Sleep(waitTime);
        _barrier.SignalAndWait();
    }
    class MyThreadArgs
    {
        public string ThreadId { get; set; }
        public int WaitTimeCount { get; set; }
    }
}


Related articles: