一种数据处理方法及处理器

    公开(公告)号:CN104951240B

    公开(公告)日:2018-08-24

    申请号:CN201410117556.9

    申请日:2014-03-26

    发明人: 马凌 姚四海 张磊

    IPC分类号: G06F12/0817 G06F12/10

    摘要: 本申请提供了一种数据处理方法及处理器;方法包括:第一处理器开始事务处理,将第一数据读取到私有缓存中;第一处理器在私有缓存中对所述第一数据进行写操作,完成后开始提交事务内存;如果所述第一数据在被第一处理器写操作前的最后一次更改是由第二处理器进行的,则将所述第一处理器的私有缓存中的所述第一数据写到最后一级缓存LLC中,无效化所述第一处理器的私有缓存中的所述第一数据;事务内存完成提交。本申请能够减少多核系统中由于数据冲突产生的回滚事件,加速关键区域的运行。

    用于在交易处理环境中提供MSSQ通知的系统和方法

    公开(公告)号:CN107533488A

    公开(公告)日:2018-01-02

    申请号:CN201680025005.7

    申请日:2016-10-20

    IPC分类号: G06F9/54 G06F9/46

    摘要: 根据实施例,本文描述了一种用于在具有多服务器单队列(MSSQ)配置的交易处理环境中向特定服务器做出请求的系统和方法。MSSQ集合中的每个服务器可以与辅助请求队列相关联,并且可以包括主线程、辅助线程以及内部存储器队列。每个服务器可以使用应用编程接口(API)以在与该服务器相关联的辅助请求队列上通告一个或多个非一致服务。特定服务器的所述辅助线程被配置为使针对非一致服务的请求消息从与所述特定服务器相关联的所述辅助请求队列中出队,并且将出队的消息存储于内部存储器队列中。所述特定服务器的所述主线程在针对要处理的消息检查所述主请求队列之前,检查所述内部存储器队列。

    一种避免消息丢失的方法与装置

    公开(公告)号:CN107423145A

    公开(公告)日:2017-12-01

    申请号:CN201710561749.7

    申请日:2017-07-11

    发明人: 张晓鹏 张菊元

    IPC分类号: G06F9/54 G06F9/46

    CPC分类号: G06F9/546 G06F9/467

    摘要: 本发明实施例提供一种避免消息丢失的方法与装置,涉及互联网技术领域。其中,所述方法包括:响应于系统或消息处理程序的重启/升级指令,关闭消息获取通道以停止从Kafka集群中获取待处理消息至内存队列;若所述内存队列中有待处理消息,则以轮询的方式查询所述内存队列中消息的处理情况;若所述内存队列中没有所述待处理消息,则关闭所述消息处理程序,以执行所述系统或所述消息处理程序的重启/升级操作。本发明实施例能够避免系统或消息消费程序的重启/升级导致内存中缓存的待处理消息丢失的情况。

    处理节点、计算机系统及事务冲突检测方法

    公开(公告)号:CN107025130A

    公开(公告)日:2017-08-08

    申请号:CN201610067776.4

    申请日:2016-01-29

    发明人: 肖昊 王元钢 徐君

    IPC分类号: G06F9/46 G06F9/52

    摘要: 本申请公开了一种处理节点、计算机系统及事务冲突检测方法。该处理节点包括处理单元和事务缓存。当该处理单元获取到访问共享数据的事务的指令时,该处理单元根据所述操作指令访问该事务缓存。其中,该事务缓存用于缓存该处理节点正在处理的事务的共享数据,共享数据为该处理节点与其他处理节点都能够访问的数据。若该事务缓存确定该操作指令未命中该事务缓存中的缓存行cache line,则该事务缓存向其他处理节点中的事务缓存发送该操作指令中的目的地址,并接收其他处理节点中的事务缓存返回的被该目的地址命中的cache line的状态信息。进而,该事务缓存根据其接收的状态信息确定该操作指令是否与所述其他处理节点正在执行的操作指令相冲突。