多线程会话后线程不会恢复答案

【问题标题】：Thread won't resume after multithreaded session多线程会话后线程不会恢复
【发布时间】：2012-09-02 09:18:49
【问题描述】：

我有一个线程，称之为“解析线程”。

Thread parsingThread = new Thread(myMethod);

我在这个线程上执行了一些计算，其中最后一个涉及更多的并行计算。

    public void ReadCityFiles(BlockingCollection<GeonamesFileInfo> files)
    {
        Parallel.ForEach<GeonamesFileInfo>(
            files.GetConsumingPartitioner<GeonamesFileInfo>(),
            new ParallelOptions { MaxDegreeOfParallelism = _maxParallelism },
            (inputFile, args) =>
            {
                RaiseFileParsing(inputFile);
                using (var input = new System.IO.StreamReader(inputFile.FullName))
                {
                    while (!input.EndOfStream)
                    {
                        RaiseEntryParsed(ParseCity(input.ReadLine()));
                        Interlocked.Increment(ref _parsedEntries);
                    }
                }
                RaiseFileParsed(inputFile);
            });
        RaiseDirectoryParsed(Directory);
    }

问题在于，当这些非常长且计算量大的异步 foreach 操作完成（约 30 分钟）时，“解析线程”不会恢复。我的 GUI 仍然响应，但是应该继续在“解析线程”上运行的 RaiseDirectoryParsed 函数从未被调用。到目前为止，我已经调试了程序，但对于在这种情况下该怎么做感到非常困惑。

【问题讨论】：

RaiseDirectoryParsed 是做什么的，“解析线程”是做什么的？
Parellel.ForEach 任务中很可能没有正确终止。您是否使用了一些控制台消息来确定这一点？
引发解析线程处理的事件。无论如何它永远不会运行，在parallel.foreach之后执行停止，就好像解析线程永远不会恢复一样。
都铎王朝，说得好。如果任务的堆栈跟踪显示为外部代码，我该如何检查？
@Francisco Aguilera：只需在任务代码末尾添加Console.WriteLine。查看所有任务是否最终终止。我猜他们不会。

标签： c# multithreading parallel.foreach

【解决方案1】：

BlockingCollection 的意义在于，当某个操作现在无法执行但可能在将来执行时（例如，Take() 或 Add() 在容量有限的集合上），它将阻塞。这同样适用于GetConsumingEnumerable()，因此也适用于GetConsumingPartitioner()：如果集合当前为空，则可枚举将阻塞，直到您向集合中添加更多项目。

但是还有一种方法可以告诉集合您不再要添加新项目，并且从现在开始它不应该在为空时阻塞：the CompleteAdding() method。如果在您知道不会再向集合中添加任何新项目时调用此方法，您的 Parallel.ForEach() 将不再阻塞，您的线程将继续执行。

【讨论】：

感谢您的观察，不过，我调用了 CompleteAdding()，并验证了该集合的 isComplete 字段为 true。可能是什么问题？