使用 C# 5.0 异步读取文件

Question

我刚刚开始使用 C# 的新 async 功能。我现在已经阅读了大量关于并行下载等的操作指南，但没有阅读/处理文本文件。

我有一个用于过滤日志文件的旧脚本，我想我应该升级它。但是我不确定我对新 async/await 语法的使用是否正确。

在我的脑海中，我看到这是逐行读取文件并将其传递给不同的线程进行处理，因此它可以继续而无需等待结果。

我的想法是否正确，或者实现它的最佳方法是什么？

static async Task<string[]> FilterLogFile(string fileLocation)
{
    string line;

    List<string> matches = new List<string>();

    using(TextReader file = File.OpenText(fileLocation))
    {        
        while((line = await file.ReadLineAsync()) != null)
        {
            CheckForMatch(line, matches);
        }
    }

    return matches.ToArray();
}

完整脚本：http://share.linqpad.net/29kgbe.linq

Answer 1

在我的脑海中，我看到这是逐行读取文件并将其传递给不同的线程进行处理，因此它可以继续而无需等待结果。

但这不是您的代码所做的。相反，您将（异步）在所有读取完成后返回一个数组。如果你真的想一个一个地异步返回匹配，你需要某种异步集合。您可以为此使用 TPL Dataflow 中的块。例如：

ISourceBlock<string> FilterLogFile(string fileLocation)
{
    var block = new BufferBlock<string>();

    Task.Run(async () =>
    {
        string line;

        using(TextReader file = File.OpenText(fileLocation))
        {        
            while((line = await file.ReadLineAsync()) != null)
            {
                var match = GetMatch(line);

                if (match != null)
                    block.Post(match);
            }
        }

        block.Complete();
    });

    return block;
}

（您可能需要添加错误处理，可能是通过错误返回的块。）

然后，您会将返回的块链接到另一个将处理结果的块。或者您可以直接从块中读取它们（使用ReceiveAsync()）。

---

但是查看完整代码，我不确定这种方法对您是否有用。由于您处理结果的方式（分组，然后按每组中的数量排序），在您拥有所有结果之前，您无法对它们做太多事情。