Products

Data Converter Cleaner TUC - Unit Converter Import Export Survey Manager Tweet Controller

Developer

Article Blog Forum Interview Beginner News Startup Quiz

Users

Career

Apply Job Internship

Pricing

Login Sign Up Get a Quote

How to use thread pool for some repetitive task in c# ?

Anupam Mishra 2655 07 Jan 2016

I want to write Thread Pool using C# for some repetitive task which is controlled through thread Scheduler.thread Scheduler will run after interval of 2 minutes.Can you please provide me few guidelines regarding how to write thread pool in C#.?

Anupam Mishra

Other

1 Answers

Anupam Mishra 08 Jan 2016

In this scenario, we executes 10 times to open a Notepad using Thread Pool. Thread scheduler will run after interval of 2 minutes to open is new one.

So, we using thread pool such like this:

using System.Threading;
using System.Diagnostics;
using System;
namespace PoolThread
{
   
class MyProcess
   
{
       
// for doing this create an event
       public ManualResetEvent doneEvent;
        // Constructors
       
public MyProcess(ManualResetEvent sendEvent)
       
{
           
         // Assign notify event from Thread Pool
            this.doneEvent = sendEvent;
       
}
       // Initialising 
       
public void MyProcessThreadPoolCallback(Object index)
       
{
            int threadIndex = (int)index;
            Console.WriteLine("thread {0} is now started...", threadIndex);
            // Call the process for every thread
            StartProcess();
   
        Console.WriteLine("thread {0}  is now ended...", threadIndex);
          // check that process has been completed 
            this.doneEvent.Set();
       
}
       // start any process
       
public void StartProcess()
       
{
            Process.Start("Notepad.exe");
       
}
   
}
   
public class ThreadPoolEx
   
{
       
static void Main()
       
{
            const int total = 10;
            // Create ManualResetEvent array to assign with process
            ManualResetEvent[] sendEvents = new ManualResetEvent[total];
            MyProcess[] MyProcessArray = new MyProcess[total];
            Console.WriteLine("Starting thread...");
            for (int i = 0; i < total; i++)
            {
                sendEvents[i] = new ManualResetEvent(false);
                MyProcess p = new MyProcess(sendEvents[i]);
                MyProcessArray[i] = p;
                  // QueueUserWorkItem () method to execute when thread pool having thread
                ThreadPool.QueueUserWorkItem(p.MyProcessThreadPoolCallback,
i);
                //It goes to sleep mode for 2 second
                Thread.Sleep(2000);
            }
           // Wait for all thread for completion
            WaitHandle.WaitAll(sendEvents);
            Console.WriteLine("All Notepad window are opened .");
            Console.ReadKey();
       
}
   
}
}

MindStick Training