当前位置：首页 > news >正文

3.3.6 VO-O语法- 流程算子

news 来源：原创 2025/8/26 11:10:31

流程算子是VO语言最重要的一类语法算子。它们是VO语言特有的语法概念。这些算子属于容器算子，用于组织管理各类流程。这样的设计有利于流程的复用。可以将流程视为一个大级别的函数模块，在更大的业务逻辑中复用，从而降低业务开发的复杂度，提升流程的开发效率。

流程算子根据其运行方式及应用场景分为以下几种：

并行流程算子(ProcessOperator)

并行流程算子表示其容器内的算子在运行时是并行的，即每个算子都会被分配一个独立的线程，数据流在算子间流转。由于数据流是由多个数据集组成的，故而整个数据流实际是被并行处理的。这样可以大幅提升数据被处理的速度。

如下图的流程：

图中的所有算子运行时都会占据一个独立的线程，不仅图中的两个分支可以并行运行。当数据流拥有多个数据集时，标准的并行流水线的计算效果会在整个流程中实现。每个算子都在处理当前流经算子的数据流。由于算子间存在计算速度的差异。因此，算子间缺省拥有缓存队列，用来平衡算子间的计算速度差异。

串行流程算子(ChainOperator)

串行流程算子表示其容器内的算子在运行时是串行的，即所有算子会共享同一条线程。串行流程算子会根据流程逻辑，依次执行每一个算子直到流程运行完成。

这样的调度方式显然是没有性能优势的，但是可以极大的节省计算资源。有些业务场景会比较复杂，当进行流程编写时，可能需要几百个算子。如果使用并行流程算子调用，那么每次都要分配几百个线程。对于数据量不大，仅是业务复杂的场景来说，很多线程绝大多数情况都是闲置的，它们无效的占用了设备的算力。因此，为这些算子分配一个共享的线程来完成数据计算是一种更优的方案。

流程编写者可以根据实际的业务情况在流程编写时选用不同的流程算子，优化流程的调度运行。

流程引用算子(ProcessReference)

当需要在一个流程中嵌套使用另外一个流程的功能时，会用到流程引用算子。可以通过拖拽流程到流程定义空间面板的方式复用一个流程。被拖拽到空间面板的流程会被提示是使用“引用”模式还是“容器内运行”模式被嵌入流程。”引用“模式下，流程以”流程引用算子“的形式嵌入当前流程；”容器内运行“模式下，流程以”流程自驱算子“的形式嵌入当前流程。

流程引用算子在外观上看到的端口与其对应的流程一致。即其外观的端口是随被引用流程的端口状况变化的。比如被引用的流程(以下称子流程)有两个输入端口，两个输出端口，那么可以看到流程引用算子也是两个输入端口和两个输出端口。流程引用算子通过数据端口与主流程的数据流进行数据的交换。运行时，流程引用算子会装载子流程，并按照端口的连接情况，将数据传输给子流程。子流程经过计算，将数据输出到主流程进行后续的计算。

主流程

子流程

被引用的子流程一般都会有输入或输出端口。并通过输入或输出端口与主流程完成数据的交互。也有一种特殊的应用情况，子流程不需要提供任何输入、输出端口。此时，主流程通过控制流驱动子流程的运行，实现流程按照控制关系运行。即前置算子执行完，子流程开始执行，子流程执行结束后，后续算子开始运行。这样的运行逻辑可以用于如前置算子执行结束后，后续算子如果要执行，必须进行一个复杂的数据环境准备的场景。子流程可以用于实现数据环境的准备工作，且不需要与主流程有数据交换。

流程自驱算子(ReferenceExecution)

除了上节中提到的没有输入、输出端口的特殊子流程外。有时候我们编写的流程并不希望通过输入端口接收数据，而只是希望通过变量来驱动流程的执行。一种典型的编程思维模式，就是面向过程的编程模式。把编写好的流程看作是一个函数，通过变量为流程传递运行所需的参数。当引用这样的流程作为子流程时，就需要选择“流程自驱”算子了。

流程自驱算子的意思是，它会遍历输入的数据集，使用数据集中的每一条数据依次替换子流程中的变量，并驱动子流程运行。这种模式下，子流程会被独立装载运行多次。彼此之间不共享任何数据。与流程引用的不同之处在于，流程引用算子内的子流程只会被装载一次，子流程内的算子会自行批量处理输入子流程的数据集。

从流程引用算子和流程自驱算子的运行方式上我们可以看出，流程引用算子的运行效率更高；流程自驱算子的流程编写自由度更高，也更符合一般程序编程经验的思维方式。

并行流程算子(ProcessOperator)

串行流程算子(ChainOperator)

流程引用算子(ProcessReference)

流程自驱算子(ReferenceExecution)

相关文章：