如何解决同步订阅一个通量到另外两个通量上
UPD:我想,我可以通过压缩两个源焊剂来制作flux3。我检查了一下,效果很好。因此,仅剩下一个问题:“我需要测量每个源通量的内部缓冲区队列,以了解在等待第二个计算的结果时,第一个计算的结果准备好了多少。”
我仍在探索反应堆和webflux,需要一些帮助。 有两个流,产生不同计算时间的计算结果。 我需要将它们结合在第三通量中,这样就可以在模板上产生CombinedCalculations: “ ,”,“ ,”,“ ,”等 从第一通量获得第一结果,从第二通量获得第二结果。每个源流都在其自己的单独线程中运行,因此结果以不同的速度发布。如果计算1的结果准备好了,我们需要等待计算2的结果,而在等待时,计算1的下一个结果正在Flux1中缓冲,这是因为我们的订户磁通3正在等待计算2的结果。 问题是-如何为这些任务组织和组装助焊剂3? 另外,我还需要测量每个源通量的内部缓冲区队列,以了解在等待第二个计算结果的同时第一个计算的结果准备好了多少。
这里是示例代码,仅出于演示目的而填充了第三通量体
$contents = ...
谢谢!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。