公开(公告)号：US10019297B2

公开(公告)日：2018-07-10

申请号：US14306113

申请日：2014-06-16

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Ananya Yadav ,  Praveen Murugesan ,  Vijayanth Devadhar

IPC: G06F7/00 ,  G06F17/30 ,  G06F9/54 ,  H04L29/08

CPC classification number: G06F9/546 ,  G06F16/2455 ,  G06F2209/548 ,  H04L67/26

Abstract: Systems and methods for implementing bulk handling in asynchronous processing are described. For example, an exemplary system includes a processor and a memory to execute instructions at the system; a broker to enqueue received messages; a push connection from the broker to a thread, in which the broker is to push an initial message to the thread for processing; a pull connection from the thread to the broker, in which the thread is to request one or more additional messages for bulk processing with the initial message from the broker; a query interface to issue a database query from the thread to a data store, the database query specifying the initial message and the one or more additional messages as a set of messages to obtain a lock for the set of messages; and a message processing engine to handle the set of messages in bulk based on whether the lock for the set of messages is obtained.

公开(公告)号：US20140304246A1

公开(公告)日：2014-10-09

申请号：US14306113

申请日：2014-06-16

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Ananya Yadav ,  Praveen Murugesan ,  Vijayanth Devadhar

IPC: G06F17/30 ,  G06F9/52

CPC classification number: G06F9/546 ,  G06F17/30477 ,  G06F2209/548 ,  H04L67/26

Abstract: In accordance with disclosed embodiments, there are provided systems and methods for implementing bulk handling in asynchronous processing. According to a particular embodiment such a system includes a processor and a memory to execute instructions at the system; a broker to enqueue received messages; a push connection from the broker to a thread, in which the broker is to push an initial message to the thread for processing; a pull connection from the thread to the broker, in which the thread is to request one or more additional messages for bulk processing with the initial message from the broker; a query interface to issue a database query from the thread to a data store, the database query specifying the initial message and the one or more additional messages as a set of messages to obtain a lock for the set of messages; and a message processing engine to handle the set of messages in bulk based on whether the lock for the set of messages is obtained. Other related embodiments are disclosed.

Abstract translation: 根据所公开的实施例，提供了用于在异步处理中实现批量处理的系统和方法。 根据特定实施例，这样的系统包括处理器和存储器，用于在系统处执行指令; 一个经纪人排队收到的消息; 从代理到线程的推送连接，其中代理人将初始消息推送到线程进行处理; 从线程到代理的拉线连接，其中线程将使用来自代理器的初始消息来请求一个或多个附加消息进行批量处理; 查询接口，用于从线程发出数据库查询到数据存储，数据库查询指定初始消息，并将一个或多个附加消息作为一组消息获取消息集合的锁; 以及消息处理引擎，用于基于是否获得针对所述一组消息的锁来批量处理所述消息集合。 公开了其他相关实施例。