aclnnInplaceAttentionWorkerScheduler

产品支持情况

[object Object]undefined

功能说明

• 算子功能：Attention和FFN分离部署场景下，Attention侧数据扫描算子。该算子接收来自FFNToAttention算子的输出数据，并对数据进行逐步扫描，确保数据准备就绪。

  该算子不建议单独使用，建议与FFNToAttention和AttentionWorkerCombine算子配合使用，形成完整的工作流。

  1. 接收FFNToAttention算子发送的数据。该数据以ScheduleContext结构体存储。其具体定义参见。该结构体包含CommonArea、ControlArea、AttentionArea、FfnArea域。本接口涉及CommonArea（用于存储配置信息，如session_num、micro_batch_num、micro_batch_size、selected_expert_num），ControlArea（用于上层控制进程是否退出），AttentionArea域（负责管理算子计算过程中所需的核心数据缓冲区与状态信息，其中token_info_buf存储了与输入相关的数据信息）。

  2. 读取ScheduleContext.AttentionArea域中token_info_buf存储的flag信息，查看通信数据是否准备就绪。

  3. 数据全部准备就绪后，后续可供AttentionWorkerCombine算子使用。

• 计算公式：

$$ \text{Initialize:} \quad \text{ready_count} = 0, \quad \text{flag_num} = \text{micro_batch_size} \times \text{selected_expert_num} $$ $$ \text{Check if run_flag is 0:} \quad \text{if run_flag} = 0, \quad \text{exit and log} $$ $$ \text{Loop:} \quad \text{while run_flag} \neq 0: \quad \text{ready_count} = \sum_{i=1}^{\text{flag_num}} \mathbf{1}_{\{ \text{flag}[i] = 1 \}}; \quad \text{if ready_count} = \text{flag_num}, \quad \text{break} $$ $$ \text{Reset flags:} \quad \text{flag}[i] = 0 \quad \text{for} \quad i = 1, 2, \dots, \text{flag_num} $$ $$ \text{Set micro_batch_id:} \quad \text{micro_batch_id} = (\text{micro_batch_id} + 1) \% \text{micro_batch_num} $$

备注：micro_batch_size、selected_expert_num、run_flag、micro_batch_id是入参ScheduleContext结构体的参数，该结构体信息在中进行展示说明。

函数原型

每个算子分为，必须先调用“aclnnInplaceAttentionWorkerSchedulerGetWorkspaceSize”接口获取计算所需workspace大小以及包含了算子计算流程的执行器，再调用“aclnnInplaceAttentionWorkerScheduler”接口执行计算。

aclnnInplaceAttentionWorkerSchedulerGetWorkspaceSize

• 参数说明：

  [object Object]

• 返回值：

  aclnnStatus：返回状态码，具体参见。

  第一段接口完成入参校验，出现以下场景时报错：

  [object Object]

aclnnInplaceAttentionWorkerScheduler

• 参数说明：

  [object Object]

• 返回值：

  aclnnStatus：返回状态码，具体参见。

约束说明

• aclnnInplaceAttentionWorkerScheduler默认为确定性实现，暂不支持非确定性实现，确定性计算配置也不会生效。

调用示例

示例代码如下，仅供参考，具体编译和执行过程请参考。