I need help to get execute multi threading in windows service

Question

0.00/5 (No votes)

See more:

I am trying to execute same class in windows service using Multi threading.
I have bunch of records and its executed by service multiple times.
I trying various methods but only last thread get executed.

1. Threading
2. parallel Programming
3. var manualResetEventSlim = new ManualResetEventSlim()
4. threads.ForEach(t => t.Start());
5. threads.ForEach(t => t.Join());

only Last thread get executed.
Please help me to sort out the issue.
Thank you in Advance

What I have tried:

C#

List<Thread> threads = new List<Thread>();
foreach (tblFrequencyPeriod Frequency in GetAllProcessing.ToList())
{
    var manualResetEventSlim = new ManualResetEventSlim();
    
    cnt += 1;
    int tmp = cnt; // copy value for closure
    Thread t = new Thread(() =>
    {
        ProcessEngine.ProcessEngine objServerLevelProcessing = new ProcessEngine.ProcessEngine();
        objServerLevelProcessing = new SalaryProcessEngine.SalaryProcessEngine(null, "", FrequencyPeriod);
        manualResetEventSlim.Wait();
        objServerLevelProcessing.Execute();
    });
    t.Start();
    threads.Add(t);
    //Thread.Sleep(1000);
    threads.ForEach(t => t.Start());
    threads.ForEach(t => t.Join());
}

Posted 20-Feb-20 22:45pm

Chaitanya Kulkarni

Updated 21-Feb-20 1:33am

Richard Deeming

v4

Add a Solution

1 solution

Add a Solution

Add your solution here

Treat my content as plain text, not as HTML

Preview 0

…

Existing Members

Sign in to your account

...or Join us

Download, Vote, Comment, Publish.

Your Email
Password
Forgot your password?

Your Email
This email is in use. Do you need your password?
Optional Password

I have read and agree to the Terms of Service and Privacy Policy
Please subscribe me to the CodeProject newsletters

When answering a question please:

Read the question carefully.
Understand that English isn't everyone's first language so be lenient of bad spelling and grammar.
If a question is poorly phrased then either ask for clarification, ignore it, or edit the question and fix the problem. Insults are not welcome.
Don't tell someone to read the manual. Chances are they have and don't get it. Provide an answer or move on to the next question.

Let's work to help developers, not make them feel stupid.

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

Richard Deeming · Answer 1 · 2020-02-21T01:34:00

Your code seems to be rather confused. It refers to a variable which doesn't exist (FrequencyPeriod). It doesn't use the loop variable (Frequency). It takes a copy of another variable "for closure", but never uses that copy. Each thread waits for a manual reset event which is never set. On each iteration of the loop, you start the current thread, then start all of the threads, then wait for all of the threads to finish.

Try using Parallel.ForEach instead:

C#

Parallel.ForEach(GetAllProcessing.ToList(), frequency =>
{
    ProcessEngine.ProcessEngine objServerLevelProcessing = new SalaryProcessEngine.SalaryProcessEngine(null, "", frequency);
    objServerLevelProcessing.Execute();
});

Parallel.ForEach Method (System.Threading.Tasks) | Microsoft Docs[^]
Write a simple parallel program using Parallel.ForEach | Microsoft Docs[^]