同步订阅一个通量到另外两个通量上

问题描述

UPD:我想,我可以通过压缩两个源焊剂来制作flux3。我检查了一下,效果很好。因此,仅剩下一个问题:“我需要测量每个源通量的内部缓冲区队列,以了解在等待第二个计算的结果时,第一个计算的结果准备好了多少。”

我仍在探索反应堆和webflux,需要一些帮助。 有两个流,产生不同计算时间的计算结果。 我需要将它们结合在第三通量中,这样就可以在模板上产生CombinedCalculations: “ ,”,“ ,”,“ ,”等 从第一通量获得第一结果,从第二通量获得第二结果。每个源流都在其自己的单独线程中运行,因此结果以不同的速度发布。如果计算1的结果准备好了,我们需要等待计算2的结果,而在等待时,计算1的下一个结果正在Flux1中缓冲,这是因为我们的订户磁通3正在等待计算2的结果。 问题是-如何为这些任务组织和组装助焊剂3? 另外,我还需要测量每个源通量的内部缓冲区队列,以了解在等待第二个计算结果的同时第一个计算的结果准备好了多少。

这里是示例代码,仅出于演示目的而填充了第三通量体

$contents = ...

谢谢!

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)