我正在寻找一种方法来保持Kotlin序列能够非常快地生成值，而不是超越其值的慢异步使用者。在下面的代码中，如果异步handleValue(it)无法跟上序列产生值的速率，则速率不平衡会导致产生值的缓冲，并最终导致内存不足。getSequence().map { async {}}
我相信这是一个典型的生产者/消费者“背压”的情况，我试图了解如何使用Kotlin<
浏览 0提问于2021-11-11得票数 0
回答已采纳
2回答
我的应用程序只有两个基本活动和几个片段，我想要显示一个退出警报，当用户通过点击后退达到特定的基本片段 if (drawer_layout.isDrawerOpen
浏览 29提问于2019-07-10得票数 5
回答已采纳
1回答
项目反应堆的背压是如何工作的？
、、、、
我一直在Spring反应堆工作，以前做过一些测试，这让我想知道通量在默认情况下如何处理背压。我知道onBackpressureBuffer和诸如此类的东西存在，我也读过
那么，谁能为我澄清:反应堆3中的通量的默认背压行为是什么？我试着搜索答案，但没有找到任何明确的答案，只有背压的定义或上面链接到RxJava的答案。
浏览 0提问于2019-07-31得票数 22
回答已采纳
由于JDK 9 ()中只有少数几个接口，因此JDK 9显然不包括像RxJava这样的反应性库。那么，将这些接口包含到JDK中有什么意义呢？
反应性库的供应商是否应该使用它们，以便它们的Java实现(如RxJava)使用一组公共接口？
浏览 2提问于2017-09-23得票数 9
回答已采纳
1回答
我确实知道，我有时会遇到网站之间的连接问题。由于我不想丢失数据，是否可以将FE NIFI集群配置为保留数据2-3天，以防站点之间的网络连接断开？我知道这需要更多的磁盘空间 如果可能，我需要哪个存储库来扩展内容或流文件？如何做到这一点呢？
浏览 18提问于2020-11-22得票数 1
回答已采纳
我想找到一些资源或例子，它展示了如何构建一个端到端、完全背压的REST服务+客户端。我的意思是，我希望看到，如果REST客户机实现了反应性流(无论是在Akka、JS还是其他类型的)，我将拥有(并且能够“可视化”)在构建的整个REST服务器中处理背压，例如使用Akka-Http。为了明确起见，我正在搜索类似于以下谈话的内容(但我找不到幻灯片或视频来证实)：
我对大多数示例表示怀疑<e
浏览 3提问于2015-05-18得票数 5
回答已采纳
我是"backpressure".的初学者，我对RxJava的含义很好奇或者这是否意味着消费者正在对生产者施加压力？(相反方向的压力)
浏览 4提问于2017-10-01得票数 28
2回答
我有一个文件处理工作，目前使用带有手动管理背压的akka参与者来处理处理管道，但我从未能够在输入文件读取阶段成功地管理背压。此作业接受一个输入文件，并根据每行开头的ID号对行进行分组，然后，一旦它用新的ID号击中一行，就会通过消息将分组行推送给处理参与者，然后继续使用新的ID号，直到到达文件的末尾为止。这似乎是使用文件作为接收器的Akka流<em
浏览 6提问于2016-04-15得票数 5
回答已采纳
1回答
我一直试图谷歌和搜索堆栈的答案，但一直无法找到。我知道我们可以创建脚本来在以前的进程失败时失败，但是如果我需要整个组在失败时停止，这有可能吗？我们不希望队列中的每个作业都遵循失败路径，我们希望它停止，直到我们能够查看数据并分析故障。
TL;DR -我们能否在失败时停止一个过程，而
浏览 6提问于2017-04-05得票数 3
回答已采纳
对于操作符，输入流比它的输出流更快，因此它的输入缓冲区将阻塞前一个操作符的输出线程，该线程将数据传输到该操作符。对吗？对于数据源，它不断地产生数据，如果它的输出线程被阻塞了怎么办？缓冲区会溢出吗？
浏览 10提问于2016-08-29得票数 2
1回答
考虑到TCP提供本机流控制，我正在研究为什么某些系统实现应用程序级的背压。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗？其他更确切的问题是：
反应性流是否通过简单地让TCP处理它来实现TCP之上的应用
浏览 1提问于2018-03-27得票数 4
，我有一个用背压降创建的Flowable。filter(v -> v > 2) .subscribe(n -> doSomething(n));
由于所选择的背压策略，项目被删除。但是，doSomething(n)在执行拖放后从
浏览 0提问于2018-02-22得票数 0
回答已采纳
1回答
我有一个与NavigationView的UWP应用程序，在不同的框架中处理后端堆栈。在我的MainPage.xaml中，背压是由以下函数处理的： private bool On_BackRequested() if (contentFrame.CanGoBackreturn true; return false;
浏览 18提问于2019-01-21得票数 2
回答已采纳
1回答
如何创建不受背压影响的源
、、、
为此，我需要在一个简单的单元测试中构造一个不受背压影响的源。天真的尝试不要因为背压而工作。超过HTTP的OTOH可能是过度的。
如何为不受背压影响的单元测试创建简单 Source？
浏览 2提问于2017-05-03得票数 4
回答已采纳
我有个卡夫卡消费者：它愉快地处理消息，我设置final Map<TopicPartition, List<ConsumerRecord<K, V>>> records = pollForFetches(timer然后，我要求它暂停所有分配的分区。在日志中可以看到它的</
浏览 3提问于2021-02-26得票数 0
回答已采纳
1回答
我一直在寻找新的rx java2，我不太确定我是否已经理解了backpressure的想法…… Flowable.interval(1, TimeUnit.MILLISECONDS, Schedulers.io())Exception {
// do sm
浏览 19提问于2016-10-30得票数 146
回答已采纳
0回答
流处理的背压是什么？
、、、
我开始学习node和streams似乎是你经常使用的东西，在我读过的大多数文档中都提到了处理大文件时的“背压问题”，但我没有找到一个明确的解释这个问题到底是什么。我也读到过使用管道可以帮助解决这个问题，但是管道到底是如何解决背压问题的呢？
感谢您提前给我解释。
浏览 4提问于2017-01-05得票数 5
使用远程功能的Flink 涉及到Flink StateFun集群将计算任务的执行交给通过某种FaaS机制部署的远程员工，例如AWS Lambda。正如所述，AWS lambda受到扩展限制(它们可以扩展的速度和限制)。请注意，并发的Lambda配额适用于帐户，而不是每个单独的lambda函数。在大规模流传输系统中，特别是如果由单个Lambda调用执行的工作相对于在该时段中在数据流中遇到的密钥
浏览 9提问于2021-10-18得票数 0
我无论如何也想不出如何实现一个能正确处理背压的。你应该永远不要使用暂停和恢复吗？}
它正确地发送输出，但不能正确地产生背压。我怎样才能改变它来正确地支持背压？
浏览 4提问于2015-03-28得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
