首页 文章
  • 0 votes
     answers
     views

    RxJava - 背压键盘输入?

    这是一个有趣的RxJava问题 . 我想使用RxJava背压操作符在键入每个字符时快速查找键入的输入,就像Google在其搜索页面上所做的那样 . 我浏览了Backpressure文档,然后我想出了这个(我使用RxJavaFX / RxKotlinFX来利用JavaFX) . val myControl: Node = ... val burstyMulticast = myControl.eve...
  • 2 votes
     answers
     views

    持续演员的Akka Sharding背压

    是否有Akka流背压模型或使用持久演员的akka分片? 因为我有问题,我有一个持久演员的akka分片集群 . (使用cassandra作为日志插件) .有时候应该同时创建很多演员 . (例如,当我们想要向所有用户发送广播消息时 . )成千上万的持久性演员试图在短时间内恢复(例如3.秒)并且在重负荷下cassandra无法在一段时间内做出响应并且许多演员多次无法恢复并且永远不会再次恢复 .

热门问题