加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

c# – IEnumerable与IObservable的不同之处是什么?

发布时间:2020-12-15 08:10:58 所属栏目:百科 来源:网络整理
导读:我很好奇IEnumerable与IObservable的不同之处.我分别理解了pull和push模式,但是C#在内存等方面如何通知订阅者(对于IObservable)它应该在内存中接收下一位数据来处理?观察到的实例如何知道它有一个数据的变化推送到订阅者. 我的问题来自于我正在从文件中读取
我很好奇IEnumerable与IObservable的不同之处.我分别理解了pull和push模式,但是C#在内存等方面如何通知订阅者(对于IObservable)它应该在内存中接收下一位数据来处理?观察到的实例如何知道它有一个数据的变化推送到订阅者.

我的问题来自于我正在从文件中读取行的测试.该文件总共约为6Mb.

标准时间:4.7s,行:36587

Rx拍摄时间:0.68秒,行数:36587

Rx如何能够大量改进文件中每条线的正常迭代?

private static void ReadStandardFile()
{
    var timer = Stopwatch.StartNew();
    var linesProcessed = 0;

    foreach (var l in ReadLines(new FileStream(_filePath,FileMode.Open)))
    {
        var s = l.Split(',');
        linesProcessed++;
    }

    timer.Stop();

    _log.DebugFormat("Standard Time Taken: {0}s,lines: {1}",timer.Elapsed.ToString(),linesProcessed);
}

private static void ReadRxFile()
{
    var timer = Stopwatch.StartNew();
    var linesProcessed = 0;

    var query = ReadLines(new FileStream(_filePath,FileMode.Open)).ToObservable();

    using (query.Subscribe((line) =>
    {
        var s = line.Split(',');
        linesProcessed++;
    }));

    timer.Stop();

    _log.DebugFormat("Rx Time Taken: {0}s,linesProcessed);
}

private static IEnumerable<string> ReadLines(Stream stream)
{
    using (StreamReader reader = new StreamReader(stream))
    {
        while (!reader.EndOfStream)
            yield return reader.ReadLine();
    }
}

解决方法

我的预感是你看到的反映操作系统缓存文件的行为.我想如果你颠倒了调用的顺序,你会看到类似的速度差异,只是换了.

您可以通过执行一些预热运行或在测试每个文件之前使用File.Copy将输入文件复制到临时文件来改进此基准测试.这样文件就不会“热”,你会得到一个公平的比较.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读