Scott Harrison - The golden apples
Henry Parker's Robot Wars

ASP.Net, ADO, MS Access
C# How to use Parallel.Invoke and Parallel.Foreach

C# How to use Parallel.Invoke and Parallel.Foreach

(27 hits)
Overview: Hits=25 This code snippet demonstrates the Parrallel.invoke and the Parrallel.foreach. Parallel.foreach partions the reading of a collection into sections giving each thread a section of the whole collection. The Parallel.foreach can be canceled by the user.
   
   private void DoSomething1(int iterations)
        {
            for(int i=0; i<iterations;i++)
            {
                Console.WriteLine("Do Something one");
                Thread.Sleep(1000);
            }
         
        }
        private void DoSomething2(int iterations)
        {
            for (int i = 0; i < iterations; i++)
            {
                Console.WriteLine("Do Something two");
                Thread.Sleep(2000);
            }
        }

           //The state.Break() exist out of the Parallel.ForEach loop when the 
        //application sets the cancelForEach boolean flag.
        private void ProcessUsingParallelForEach(List<string> intCollection)
        {
          
            Parallel.ForEach(intCollection, (integer,state) =>
            {
                Console.WriteLine($"Parallel.Foreach={integer}");
                if (cancelForEach==true) {
                    Console.WriteLine($"Exit Parallel.ForEach {integer}");
                    state.Break();
                    
                }
          
            });

        }
        private bool cancelForEach = false;
        [TestMethod]
        public void TestThreadPooling()
        {
            int numberOfProcessors = Environment.ProcessorCount;

            Parallel.Invoke(() => DoSomething1(5)
                        ,()=>DoSomething2(10));

            List<string> intCollection = new List<string>();

            for (int i = 0; i < 500; i++)
            {
                intCollection.Add(i.ToString());
            }

            var TaskForEach=Task.Run(()=> ProcessUsingParallelForEach(intCollection));

            Thread.Sleep(500);
            cancelForEach = true;

            Task.WaitAll(TaskForEach);

        }


 
....

...<<<Register to correspond>>> ...

Members : 152
Name:
Email:

Register to View

Help