在分布式并行环境中对异步消息排序的方法、系统和计算机程序产品

摘要

本发明提供一种在分布式并行系统中，对分布的异步消息排序的系统和计算机实现的方法，所述分布式并行系统具有形成入站处理器层的多个入站处理器，和形成出站处理器层的多个出站处理器，所述方法包含利用至少一个数据处理器进行的以下步骤：在所述多个入站处理器中的任意入站处理器中，接收输入消息，所述输入消息具有识别包含该输入消息的序列的序列相关值，检查共享序列存储器中的所述序列的序列状态；确定输入消息是否是为了维持所述序列中的消息的顺序而要处理的下一个消息；-如果序列状态指示出站处理器层中的出站处理器目前都未处理所述序列的消息，并且如果输入消息被确定为所述序列的下一个待处理消息，那么把输入消息转发给共享队列存储器，随后通过出站处理器层中的可用出站处理器取回该消息，以便处理；-如果序列状态指示出站处理器层中的至少一个出站处理器目前在处理所述序列的消息；或者如果所述共享队列存储器已包含所述序列的下一个待处理消息；或者如果输入消息被确定为不是所述序列的下一个待处理消息，那么把输入消息保存在共享的溢出存储器的内存中，留待进一步处理。

主权项

一种计算机实现的在分布式并行系统中对分布的异步消息排序的方法，所述系统具有形成入站处理器层的多个入站处理器，和形成出站处理器层的多个出站处理器，其特征在于所述方法包含利用至少一个数据处理器进行的以下步骤：在所述多个入站处理器中的任意入站处理器中，接收输入消息，所述输入消息具有识别包含该输入消息的序列的序列相关值，检查共享序列存储器中的所述序列的序列状态；确定输入消息是否是为了维持所述序列中的消息的顺序而要处理的下一个消息；‑如果序列状态指示出站处理器层中的出站处理器目前都未处理所述序列的消息，并且如果输入消息被确定为所述序列的下一个待处理消息，那么把输入消息转发给队列存储器，随后通过出站处理器层中的可用出站处理器取回该消息，以便处理；‑如果序列状态指示出站处理器层中的至少一个出站处理器目前在处理所述序列的消息；或者如果所述队列存储器已包含所述序列的待处理消息；或者如果输入消息被确定为不是所述序列的下一个待处理消息，那么把输入消息保存在共享的溢出存储器的内存中，留待进一步处理。