是否有效返回 "Task<Task<MyObject>>" ？或者更好地返回“Task.FromResult(MyObject)”

Question

我的代码没问题，但我想知道哪种风格更好，你会怎么看，我在玩异步方法。

让我建立上下文：

Parallel.ForEach(xmlAnimalList, async xml =>
        {
            taskList.Add(await Task.FromResult(ReadAnimalXML(xml, token)));
        });

这段代码用这个方法效果很好：

public async Task<Animal> ReadAnimalXML(string filename, CancellationToken token)

在前面的示例中，您可以在 await 关键字之后看到 Task.FromResult()。 ReadAnimalXML 方法只返回一个：

return new Animal();

第二个例子是这样的：

Parallel.ForEach(xmlAnimalList, async xml =>
        {
            taskList.Add(await ReadAnimalXML2(xml, token));
        });

这次 ReadAnimalXML2 方法返回：

public async Task<Task<Animal>> ReadAnimalXML2(string filename, CancellationToken token)
    {
        return Task.FromResult(new Animal());
    }

但是！

第二种方法 ReadAnimalXML2（我觉得这很奇怪）返回一个

Task<Task<Animal>>

任务中的任务。

这就是我返回 Task.FromResult(new Animal()); 的原因 否则将无法正常工作。两种方法都可以，但一种更好。您能分享一下您的答案，并解释一下原因吗？

感谢您进入查看问题。 编码很有趣！

public async Task<IEnumerable<Animal>> ReadXMLFromFolderAsync(string folderPath, CancellationToken token)
    {
        if (!Directory.Exists(folderPath))
        {
            return new List<Animal>();
        }

        List<Task<Animal>> taskList = new List<Task<Animal>>();

        List<string> xmlAnimalList = Directory.GetFiles(folderPath, "*.xml").ToList();

        Parallel.ForEach(xmlAnimalList, async xml =>
        {
            taskList.Add(await Task.FromResult(ReadAnimalXML(xml, token)));
        });

        return await Task.WhenAll(taskList);
    }

    public async Task<Animal> ReadAnimalXML(string filename, CancellationToken token)
    {
        XDocument document = XDocument.Load(filename);

        IEnumerable<XElement> ADN = await Task.Run(() => 
            document.Descendants("ADN").Where(adn => adn.Name.LocalName == "Dinosaur"), token);

        //populate the animal object

        return new Animal();
    }

    public async Task<IEnumerable<Animal>> ReadXMLFromFolderAsync2(string folderPath, CancellationToken token)
    {
        if (!Directory.Exists(folderPath))
        {
            return new List<Animal>();
        }

        List<Task<Animal>> taskList = new List<Task<Animal>>();

        List<string> xmlAnimalList = Directory.GetFiles(folderPath, "*.xml").ToList();

        Parallel.ForEach(xmlAnimalList, async xml =>
        {
            taskList.Add(await ReadAnimalXML2(xml, token));
        });

        return await Task.WhenAll(taskList);
    }

    public async Task<Task<Animal>> ReadAnimalXML2(string filename, CancellationToken token)
    {
        XDocument document = XDocument.Load(filename);

        IEnumerable<XElement> ADN = await Task.Run(() => document
            .Descendants("ADN")
            .Where(adn => adn
                .Name
                .LocalName == "Dinosaur")
                , token);

        //populate the animal object

        return Task.FromResult(new Animal());
    }

Answer 1

我认为您将并行性与异步性混为一谈，并且两者都做对了。

如果您的方法返回Task.FromResult，那么它不是异步的。如果您想要异步代码，请关注 I/O - 例如，异步执行 I/O 以从磁盘加载文件数据，然后（同步）将其解析为 XML。

Parallel.ForEach 问题更危险。首先，您不能将async 方法与Parallel.ForEach 一起使用；您的代码恰好可以工作，因为您的 async 方法不是异步的。此外，您不能在并行代码中使用非线程安全方法，例如 List<T>.Add。所以几乎所有使用Parallel.ForEach 的代码都是错误的。但你可能不需要Parallel.ForEach。

如果你想做异步并发，那么你只需要LINQ的Select和await Task.WhenAll。如果你想建立一种可以做并行处理的管道，那么你可以使用TPL Dataflow，或者在异步部分完成后使用Parallel.ForEachonly同步代码。