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