2

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

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 函数从未被调用。到目前为止，我已经调试了程序，并且对于在这种情况下该怎么做感到非常困惑。

4

1 回答 1

2

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

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

于 2012-09-02T10:47:48.847 回答