array of threads c#

Question

i have this code:

    Thread[] threadsArray = new Thread[4];
        for (int i = 0; i < 4; i++)
        {
            threadsArray[i] = new Thread(() => c1.k(i));
        }
        for (int i = 0; i < 4; i++)
        {
            threadsArray[i].Start();
        }
        for (int i = 0; i < 4; i++)
        {
            threadsArray[i].Join();
        }

the function k is this:

void k(int i)
{
    while(true)
      Console.WriteLine(i);
}

for some reason just the last thread is running and printing 4444444.... why aren't all the threads running?

This has to be the most oddball variant of the standard closing-over-the-loop-variable question I've ever seen. — Adam Robinson
– Adam Robinson, Commented Jul 19, 2010 at 20:51
This one is even more similar: stackoverflow.com/questions/1930133/… — Mark Byers
– Mark Byers, Commented Jul 19, 2010 at 21:06
Related: "Closing over the loop variable considered harmful" by Eric Lippert. blogs.msdn.com/b/ericlippert/archive/2009/11/12/… — Mark Byers
– Mark Byers, Commented Jul 20, 2010 at 7:56
i is a captured outer variable in this context. See en.csharp-online.net/… — VVS
– VVS, Commented Jul 20, 2010 at 13:43

SLaks · Accepted Answer · 2010-07-19 20:49:36Z

30

All of the threads are printing the same variable.

Your lambda expression (() => c1.k(i)) captures the i variable by reference.
Therefore, when the lambda expression runs after i++, it picks up the new value of i.

To fix this, you need to declare a separate variable inside the loop so that each lambda gets its own variable, like this:

    for (int i = 0; i < 4; i++)
    {
        int localNum = i;
        threadsArray[i] = new Thread(() => c1.k(localNum));
    }

answered Jul 19, 2010 at 20:49

SLaks

891k182 gold badges1.9k silver badges2k bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

schnaader Over a year ago

+1 for this answer. It's basically the same as Winston's, but the explanation is more detailed.

gradbot Over a year ago

On a side note: some languages like F# won't compile if you try to capture a mutable variable in a closure.

Winston Smith · Accepted Answer · 2010-07-19 20:51:27Z

4

You are closing over the i variable.

Try this instead

for (int i = 0; i < 4; i++)
{
    int x = i;
    threadsArray[i] = new Thread(() => c1.k(x));
}

answered Jul 19, 2010 at 20:51

Winston Smith

22k10 gold badges63 silver badges75 bronze badges

Comments

KUL · Accepted Answer · 2020-07-11 13:54:56Z

0

Thread[] threadsArray = new Thread[4];
for (int i = 0; i < 4; i++)
{
    //better use ParameterizedThreadStart Delegate
    threadsArray[i] = new Thread(k);
}
for (int i = 0; i < 4; i++)
{
    //passing the value to the function
    threadsArray[i].Start(i);
}
for (int i = 0; i < 4; i++)
{
    threadsArray[i].Join();
}

//changing the input data type
void k(object i)
{
    while (true)
        Console.WriteLine((int)i);
}

answered Jul 11, 2020 at 13:54

KUL

5315 silver badges17 bronze badges

Collectives™ on Stack Overflow

array of threads c#

3 Answers 3

2 Comments

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

2 Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related