【问题标题】:Pass each list item to a new thread one by one [duplicate]将每个列表项一个一个地传递给一个新线程[重复]
【发布时间】:2013-12-10 19:48:15
【问题描述】:

我想做的很简单,
我扫描一个字符串列表,然后将每个字符串传递给一个新线程进行打印。

using System;
using System.Collections.Generic;
using System.Threading;

namespace MultithreadingSynchronization
{
    class Program
    {
        static void Main(string[] args)
        {
            List<string> stringList = new List<string> { "server1", "server2", "server3", "server4", "server5", "server6", "server7", "server8", "server9"};

            foreach (string server in stringList)
            {
                ThreadStart work = delegate { Threadjob(server); };
                new Thread(work).Start();
                //Thread.Sleep(10); // 10 ms delay of main thread
            }
        }

        public static void Threadjob(object server)
        {
            Console.WriteLine(server);
        }
    }
}

由于某些原因,有线程接收到错误的值,因此,输出会出现一些重复的字符串,并且还会丢失一些字符串。
我期待这个输出(顺序并不重要):

server1
server2
server3
server4
server5
server6
server7
server8
server9

但是,有时我会明白:

server3
server2
server5
server5
server7
server4
server8
server9
server9

有时我会明白:

server2
server2
server4
server3
server6
server7
server7
server8
server9

等等

确实,如果我在每个线程创建后延迟,我会得到我期望得到的结果。

有什么想法吗?

【问题讨论】:

  • 我已经尝试过您的代码(vs2012 C# 控制台应用程序默认设置,win8.0 64) - 我从来没有重复的数字。 - 我确实按照多线程的预期将它们弄乱了,但不会重复。
  • 您不希望您的 ThreadJob 方法成为实例方法吗?它似乎不是线程安全的
  • 这是因为循环变量。 Closing over the loop variable considered harmful。按照 Oakio 的建议,更改为 for 循环或使用本地 foreach 变量。
  • @WarpWars.Net,我使用的是 VS2010(在 Win 7 上),有区别吗?
  • @elady 是的:这种行为在 c# 5 中已修复,因为它混淆了太多人

标签: c# multithreading synchronization


【解决方案1】:

您应该制作变量的本地副本。 试试这个:

    foreach (string server in stringList)
    {
        string local = server;
        ThreadStart work = delegate { Threadjob(local); };
        new Thread(work).Start();
        //Thread.Sleep(10); // 10 ms delay of main thread
    }

更多信息在这里:Captured variable in a loop in C#

【讨论】:

  • 如果您发现一个重复的问题,您应该投票/标记以将其作为重复项关闭,而不是发布答案。
  • 非常感谢!它解决了我的问题!
【解决方案2】:
new Thread(Threadjob).Start(server);

完成!但是,使用任务而不是线程可能更可取 - 或者至少使用 ThreadPool。

【讨论】:

  • 它也解决了我的问题,谢谢!
【解决方案3】:

好的,我想我明白了。
Froeach 循环持有一个指针,并在每次迭代时更改它。 有时,线程已创建,但仍未运行。 同时,循环在下一次迭代中改变指针,当线程开始工作时,它获取当前指针的值(后续字符串)。

顺便说一句,我找到了另一个解决方案here,如何将参数传递给线程的主函数,所以我修复了我的循环,它现在可以正常工作了

foreach (string server in stringList)
{
    Thread thread1 = new Thread(new ParameterizedThreadStart(Threadjob));
    thread1.Start(server); 
}

【讨论】:

    猜你喜欢
    • 2017-01-27
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2013-04-18
    相关资源
    最近更新 更多