LINQ 可枚举线程

Question

我试图了解 LINQ 如何处理线程。以下代码生成 ThreadStateException“线程尚未启动”。为什么会出现这种情况？

        var threads = Enumerable.Range(0, 50).Select(x =>
                                                         {
                                                             Thread thread = new Thread(Method);
                                                             thread.Name = x.ToString();
                                                             return thread;
                                                         });


        foreach (var thread in threads)
        {
            thread.Start();
        }

        foreach (var thread in threads)
        {
            thread.Join();
        }

        Console.WriteLine(j);

Answer 1

您的问题与线程无关。当第二次枚举threads时，您的查询将被第二次执行并创建第二组线程。

因此，您.Start一组线程，然后.Join另一组线程。您需要急切地评估查询一次，然后缓存结果。

IEnumerable<Thread> lazyThreads = Enumerable.Range(...
Thread[] threads=lazyThreads.ToArray();//Evaluate and store in an array

您也可以将其写为单个语句：

var threads = Enumerable.Range(1,50).Select(...).ToArray();

Answer 2

threads 变量是一个查询，而不是线程列表。每次迭代它时，都会再次执行查询，因此在第二种情况下，您将调用 Join() 而无需调用 Start()。

您可以在查询末尾添加 ToList() 以使其成为列表：

 var threads = Enumerable.Range(0, 50).Select(x =>{ ... }).ToList();

Answer 3

您将 lambda 表达式枚举两次（惰性枚举） - 因此，您的第二个 foreach 将迭代与第一个线程不同的线程。

尝试

var threads = Enumerable.Range(0, 50).Select( ... ).ToList();

foreach(var thread in threads)
...

调用 ToList() 将创建一个包含线程的列表，您可以随后多次枚举该列表。

Answer 4

在这种情况下，您并没有真正探索 LINQ 如何处理线程。相反，您可以使用链接来节省几行代码，同时自己处理线程。

从 .Net 4.0 开始，LINQ 提供了一些开箱即用的简洁线程帮助。研究并行 LINQ。另请查看并行扩展。

至于您碰巧使用 LINQ 的老式线程处理，您的问题实际上是由于您使用 LINQ 造成的。您的问题与 延迟有关执行。在调试模式下，在该行完成后将鼠标悬停在 threads 变量上。您会看到它是一个查询，而不是一个简单的集合。每次访问该变量时，它都会重新获取它的值。

修复方法很简单也很常见：只需在第一行末尾添加 .ToList() 即可。然后，您的隐式类型 threads 变量将是一个简单的列表，并按照您的预期运行。

var threads = Enumerable.Range(0, 50).Select(x =>
                                 {
                                     Thread thread = new Thread(Method);
                                     thread.Name = x.ToString();
                                     return thread;
                                 }).ToList();