9

我刚刚开始使用 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

4

1 回答 1

9

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

但这不是您的代码所做的。相反，当所有读取完成后，您将（异步）返回一个数组。如果您真的想异步地一一返回匹配项，则需要某种异步集合。您可以为此使用 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()）。

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

于 2013-02-11T13:01:22.627 回答