-
公开(公告)号：US20130024538A1
公开(公告)日：2013-01-24
申请号：US13594716
申请日：2012-08-24
IPC分类号： G06F15/167
CPC分类号： H04L67/32 , G06F9/546 , G06F11/0709 , G06F11/0724 , G06F11/076 , G06F11/0766 , H04L67/02
摘要： A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.
-
公开(公告)号：US08261286B1
公开(公告)日：2012-09-04
申请号：US12176222
申请日：2008-07-18
CPC分类号： H04L67/32 , G06F9/546 , G06F11/0709 , G06F11/0724 , G06F11/076 , G06F11/0766 , H04L67/02
摘要： A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.
摘要翻译： 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是指定物理队列中的第一个未确认消息的物理ACK级别指针之前的消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。
-
公开(公告)号：US09170915B1
公开(公告)日：2015-10-27
申请号：US13311960
申请日：2011-12-06
申请人： Maxim E. Fateev
发明人： Maxim E. Fateev
CPC分类号： G06F11/3414 , G06F9/3836 , G06F9/3871 , G06F9/5038 , G06Q10/06
摘要： The state of a workflow application in a distributed computing environment can be reconstructed by replaying previously executed portions of the workflow application. Embodiments maintain non-serialized event data relating to workflow history and use the data to determine subsequent actions to take in order to advance the workflow. In some embodiments, workflow instances can be serialized in order to create a checkpoint.
摘要翻译： 在分布式计算环境中的工作流程应用程序的状态可以通过重播先前执行的工作流程部分的部分来重建。 实施例维护与工作流历史相关的非序列化事件数据，并且使用该数据来确定为了推进工作流而采取的后续动作。 在一些实施例中，工作流实例可以被序列化以便创建检查点。
-
公开(公告)号：US09015533B1
公开(公告)日：2015-04-21
申请号：US13312006
申请日：2011-12-06
申请人： Maxim E. Fateev
发明人： Maxim E. Fateev
IPC分类号： G06F11/00
CPC分类号： G06F11/0742 , G06F9/46 , G06F11/0715 , G06F11/0793 , G06F11/14
摘要： Various embodiments are disclosed herein including systems and methods for implementing exception-based error handling in asynchronous, parallel, multi-threaded, and other distributed systems. Embodiments implement exception-based error handling in asynchronous workflow systems, providing try/catch blocks and tree-based cancellation of pending and currently executing activities.
摘要翻译： 本文公开了各种实施例，其包括用于在异步，并行，多线程和其他分布式系统中实现基于异常的错误处理的系统和方法。 实施例在异步工作流系统中实现基于异常的错误处理，提供尝试/捕获块和基于树的取消挂起和正在执行的活动。
-
公开(公告)号：US09152533B1
公开(公告)日：2015-10-06
申请号：US13311974
申请日：2011-12-06
申请人： Maxim E. Fateev
发明人： Maxim E. Fateev
CPC分类号： G06F11/36 , G06F9/542 , G06F11/0709 , G06F11/0742 , G06F11/14 , G06Q10/06
摘要： Various embodiments are disclosed herein including systems and methods for managing the asynchronous and parallel execution of computer programs. Embodiments implement asynchronous execution in a distributed environment. Single-threaded execution of multiple routines can proceed without thread blocking. Asynchronous variable and routine classes are provided to facilitate development of asynchronous systems using substantially the same development techniques as used for synchronous systems. In some embodiments, the systems and methods for managing asynchronous execution of programs are applied to workflow processing systems.
摘要翻译： 本文公开了各种实施例，包括用于管理计算机程序的异步和并行执行的系统和方法。 实施例在分布式环境中实现异步执行。 单线程执行多个例程可以在没有线程阻塞的情况下进行。 提供了异步变量和例程类，以便利用与同步系统中使用的基本相同的开发技术来促进异步系统的开发。 在一些实施例中，用于管理程序的异步执行的系统和方法被应用于工作流处理系统。
-
公开(公告)号：US08763013B2
公开(公告)日：2014-06-24
申请号：US13594716
申请日：2012-08-24
IPC分类号： G06F9/44 , G06F15/167
CPC分类号： H04L67/32 , G06F9/546 , G06F11/0709 , G06F11/0724 , G06F11/076 , G06F11/0766 , H04L67/02
摘要： A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those proceeding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.
摘要翻译： 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是那些进行物理ACK级别指针，指定物理队列中的第一个未确认消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。
-
-
-
-
-
搜索结果
6 条记录 (耗时 0.012 秒)
