协同并发式消息总线、主动构件组装模型及构件拆分方法

摘要

本发明提供一种协同并发式消息总线、主动构件组装模型及构件拆分方法，协同并发式消息总线包括：信息获取模块、并行环形分配器、线性内存块、消息填充模块、并行入队器、消息队列池、排队顺序管理器、入口映射表和系统堆栈。本发明提供的协同并发式消息总线、主动构件组装模型及构件拆分方法，能够有效克服现有“并发”实现技术的弱点，高效可靠地实现“并发”技术、并行编程，具有普适、廉价、高效、可靠、节能、复用、透明分布、微内核、内在支持对象技术等一系列优点。

主权项

一种协同并发式消息总线，其特征在于，包括：信息获取模块、并行环形分配器、线性内存块、消息填充模块、并行入队器、消息队列池、排队顺序管理器、入口映射表和系统堆栈；其中，所述信息获取模块用于从接收到的待处理的外部并行的消息中获取目标算子ID以及消息长度值；其中，所述目标算子ID为处理所述消息的算子标识；同时用于获取附加管理消息的附加管理消息长度值，然后计算所述附加管理消息长度值与获取到的所述消息长度值的和，得到消息占用空间值；其中，所述附加管理消息长度值≥0；所述并行环形分配器为非阻塞式并行的空间环形分配器，用于根据所述信息获取模块获取到的所述消息占用空间值，按环形划分原则连续动态的划割所述线性内存块，非阻塞式并行地得到与消息占用空间值相同的空白消息槽；所述消息填充模块用于将所述消息及所述附加管理消息填充到所述并行环形分配器分配的所述空白消息槽，得到非空白消息槽；所述并行入队器用于对所述空白消息槽或所述非空白消息槽进行非阻塞式并行入队操作；所述消息队列池用于缓存尚未处理的已入队消息；所述排队顺序管理器用于根据预设调度策略从所述消息队列池中选择需处理的指定消息，对所述指定消息进行协同的出队操作；所述入口映射表，根据所述目标算子ID查找所述入口映射表，获得与所述目标算子ID对应的函数入口地址；根据所述函数入口地址以及所述指定消息的指定消息槽地址，调用对应的算子执行函数，从而处理出队的所述指定消息；所述系统堆栈为所述消息总线中所有算子共享的堆栈空间；各个算子所共享的系统堆栈空间相互覆盖，为重叠式，即非层叠式；并且，所述消息总线内的算子仅具有就绪状态，即使当所述消息总线内不存在任何消息时，所述消息总线内的算子仍处于就绪状态；一旦当所述消息总线内到达消息时，且当该消息所对应的算子被调度时，被调度到的算子立即获得处理器。