- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我是 Rx 的新手,我在想当 IObservable 非常快速地产生大量事件而 OnNext 需要很长时间时会发生什么。我想新事件在内部以某种方式排队,所以我可以运行我们的内存。我对吗?考虑以下小示例:
Subject<int> subject = new Subject<int>();
subject.ObserveOn(Scheduler.ThreadPool).Subscribe(x => { Console.WriteLine("Value published: {0}", x); Thread.Sleep(100); },
() => Console.WriteLine("Sequence Completed."));
for (int i = 0; i < 10; i++)
{
subject.OnNext(i);
}
我发布了 10 个事件,消费者方法非常慢。所有事件都经过处理,因此必须将其缓存在内存中。如果我发布很多事件,我会用完内存,对吗?还是我错过了什么?
有没有办法限制响应式扩展中未决事件的数量?例如,如果有超过 5 个未决事件,我想忽略新事件。
最佳答案
是的,你是对的,缓慢的消费者会导致排队。与您所要求的内容最接近的内置运算符是 Observable.Sample
- 但是,这会丢弃较旧的事件以支持较新的事件。这是更常见的要求,因为它可以让你的慢速观察者 catch 来。
让我知道示例是否足够,因为您描述的缓冲行为是一个不寻常的要求 - 它是可以实现的,但实现起来非常复杂并且需要相当重要的代码。
编辑 - 如果您像这样使用 Sample,它将在每次 OnNext 之后返回最新的事件(您需要为此提供一个调度程序 - 并且 NewThreadScheduler 创建一个线程每个订阅,而不是每个事件:
void Main()
{
var source = Observable.Interval(TimeSpan.FromMilliseconds(10)).Take(100);
source.Sample(TimeSpan.Zero, NewThreadScheduler.Default)
.Subscribe(SlowConsumer);
Console.ReadLine();
}
private void SlowConsumer(long item)
{
Console.WriteLine(item + " " + Thread.CurrentThread.ManagedThreadId);
Thread.Sleep(TimeSpan.FromSeconds(1));
}
关于C# react 扩展当 OnNext 花费很长时间并且可观察到产生新事件时会发生什么,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20018503/
这个问题在这里已经有了答案: Isn't an Int64 equal to a long in C#? (2 个答案) 关闭 9 年前。 它不应该是一个整数类型吗? 这样,一些使用 int 的函数
当我遇到一些我想知道的事情时,我正忙着解析一个二进制文件。 Stream.Position属性的类型为Int64或long。为什么是这样?因为流中的位置不能为负,所以使用 UInt64 不是更有意义吗
所以第一部分是我从用户那里获得输入,在本例中,输入是“1”作为从另一个函数接收的字符值。 printf ("\nPlease enter 1, 2, 3 or q: "); option =
我正在尝试使用以下代码从 REST 服务返回 JSON: $categories = $categoriesController->listAll(); if($categories){ hea
我阅读了文档,它说 long 是 %li,但打印输出返回为 -2147024891。是什么赋予了? 最佳答案 您甚至没有提供要打印的号码,但我猜您已经无意中发现了签名打印和未签名打印之间的区别。 使用
我正在创建自定义购物车,我正在构建一个查询,该查询从检索我刚刚保存到购物车表中的 session_id 开始。我知道这个值被保存了,我在 mysql 命令行运行这个查询,它返回我需要的但我没有将值放入
我有一个包含 textView 的 scrollView。如果文本很长并且不适合屏幕,我想增加 textView 高度(我想我可以通过添加 NSLayoutConstraint outlet 并修改它
我有一个基本的数据库处理程序类,其中有一个使用 PDO::FETCH_ASSOC 参数返回结果集的公共(public)方法: public function resultSet() { $th
在后台线程中,我调用 PublishSubject.onNext(); 并在主线程中通过 subscribe(PublishSubject.filter(message -> message.getI
我想知道为什么 Amazon Web Services 控制台登录页面有这么长的 url?为什么不只发布数据而不显示其中包含大量数据的冗长 url。以这种方式实现有什么充分的理由吗? 最佳答案 我认为
这个问题在这里已经有了答案: Can I mix MySQL APIs in PHP? (4 个答案) 关闭 6 年前。 希望我犯了一个快速而明显的错误,我浏览了 previous question
我得到了答案:如果我禁用了cookie,那么使用URL重定向我可以传递JSESSIONID,但我的URL已经很长,因为我使用它有约束的GET方法。那怎么办我应该使用我的 session 吗?我希望我的
目前,当我使用 DOMDocument 对象并调用 saveHTML() 时,它会自动添加一些我不需要的 html 标签。我尝试了此处建议的解决方案 ( https://stackoverflow.c
我是一名优秀的程序员,十分优秀!