一种基于条件合并与共享的订阅方法

摘要

本发明涉及一种基于条件合并与共享的订阅方法，技术特征：建立订阅者到过滤器和方法的映射作为一级缓冲区，建立订阅条件到订阅者集合的映射作为二级缓冲区；检测一级缓冲区中是否已存在该条目的订阅者，如果存在则进行过滤器归并；不存在则将该条目作为新的元素加入到一级缓冲区中；对一级缓冲区的每一个元素的过滤器进行拆分，按照条件加入到二级缓冲区中；如果二级缓冲区已存在该条件，就将新元素的订阅者加入到该条目对应的订阅者集合中，如果不存在该条件，就新建立一个映射关系，并将该条目加入；最后按照条件将订阅者加入到订阅数据结构中。本发明通过缩短交易周期，更加适应瞬息万变的市场环境。

主权项

一种基于条件合并与共享的订阅方法，其特征在于步骤如下：步骤1：建立订阅者到过滤器和方法的映射作为一级缓冲区，建立订阅条件到订阅者集合的映射作为二级缓冲区；步骤2：当有新条目到来时，检测一级缓冲区中是否已存在该条目的订阅者，如果存在则进行过滤器归并；不存在则将该条目作为新的元素加入到一级缓冲区中；判断两个条目的方法是否相同，如果相同就对两个过滤器进行加法操作，如果不同的话就对两个过滤器进行减法操作。如果减法操作的结果为负的话，就将方法取反，并将过滤器的负号去掉；步骤3：对一级缓冲区的每一个元素的过滤器进行拆分，按照条件加入到二级缓冲区中；对于二级缓冲区，当有新元素到来时，如果二级缓冲区已存在该条件，就将新元素的订阅者加入到该条目对应的订阅者集合中，如果不存在该条件，就新建立一个映射关系，并将该条目加入；步骤4：最后按照条件将订阅者加入到订阅数据结构中。