设计ChainStream Runtime中对于并发的控制结构

[rm-rf-me]

正如1.23号组会上提到的，通过消息队列堆积程度动态控制监听函数的并发度。

具体来说：
Runtime为每个stream后都分配一个消息队列，一方面是作为异步的分割点，形成消息订阅的模式。另一方面是Runtime的监控点，监控流量的大小。

当消息队列出现堆积或者减流时，需要动态调整消费者的并发度，以实现对流的维护。

当流堆积超过阈值需考虑硬停止流、部分丢弃或者直接系统崩溃；干涸时间超过阈值则考虑休眠流后内容以释放资源。