该库是一个混合的概念,将独立的 pieces 连接起来,形成一个数据处理管道。这些独立的 pieces 可以有:内部状态与他人对话的类型化的渠道调度规则这些pieces(actors)是由一个调度程序管理的,它有一个预定义的线程数来运行它们。输入和输出通道的数量由 actors 的类型决定。可能的类型:Source:一个输出Sink:一个输入Filter:一个输出,一个输入Y-split:2个可能的不同类型的输入,1个输出Y-merge:2个可能的不同类型的输入,1个输出Scatter:1个输入,同类型的多个输出Gather:同一类型的多个输入,1个输出