C#并行编程修改xDocument

Question

我以前从未在 C# 中尝试过并行编程。所以，在我开始之前，我希望我能得到一个快速的答案，以了解它是否值得深入研究。我有带有 .NET 4.0 的 C# WCF Web 服务应用程序。 (如果并行编程可以升级到4.5)

所有服务都是 REST 服务。特别是一项服务有时需要很长时间。该服务正在处理和修改 xml 文档。该服务接受一个 xml 字符串作为输入，并返回修改后的 xml 文件。

该服务确实在不同的位置和不同的元素中处理 xml。因此，我创建了从名为 IDocumentProcessor 的接口(interface)继承的类，并且我有一个列表

代码简要如下所示

interface IDocumentProcessor {
     void Process(XDocument doc);
}

public class DateProcessor : IDocumentProcessor
{
   public void Process(XDocument doc) {....};
}

public class CountryProcessor : IDocumentProcessor
{
   public void Process(XDocument doc) {....};
}


public class AddressProcessor : IDocumentProcessor
{
   public void Process(XDocument doc) {....};
}


public class AuthorProcessor : IDocumentProcessor
{
   public void Process(XDocument doc) {....};
}

....

Public class DocumentProcessorService
{
    public class ProcessDocument(string xmlFileAsString) 
    {
        var processorList = new List<IDocumentProcessor>{
            new DateProcessor();
            new CountryProcessor();
            new AddressProcessor();
            new AuthorProcessor();
        }

        var xDocument = XDocument.Parse(xmlFileAsString);
        processorList.forEach(x => x.Process(xDocument));
    }
}

所以我的快速问题，在我深入研究并行之前:并行计算能否修改同一个xDocument对象(在不同位置)

能否将此代码转换为使用 .net 4.0 进行并行计算？

Answer 1

来自 XElement 文档:

Thread Safety Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

这基本上意味着您不能并行修改 XDocument。

另一个问题是，对相同数据的一种操作进行 fork 是不切实际的。

这种方式不可扩展。

可能没有足够的操作类型来为每个 CPU 内核 fork ，并且一种类型的完成速度可能比另一种快得多。竞争也很激烈。

如果您的文档包含类似方案的高级元素的集合，您可以并行处理它们的副本，然后用新的替换旧的。

重组操作必须在一个线程中完成，如果您选择正确的粒度级别，应该不会太昂贵。

您基本上需要为每个要处理的 XElement 复制构造函数。

    var newElements = collectionElement.Elements().Select(el=>
    Process(new XElement(el))).AsParallel();

  var newCollection = new XElement("items", newElements);