公开(公告)号：US20100005466A1

公开(公告)日：2010-01-07

申请号：US12166499

申请日：2008-07-02

申请人： Peter R. MacFarlane ,  Adrian W. Spender

发明人： Peter R. MacFarlane ,  Adrian W. Spender

IPC分类号： G06F9/46

CPC分类号： G06F9/5038 ,  G06F8/34 ,  G06F9/52 ,  G06F2209/5015 ,  G06Q10/10

摘要： A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.

摘要翻译： 提供了一种用于提供异步恢复数据流的方法，系统和计算机程序产品。 该方法包括从包括多个互连节点的数据流构建可执行有向图，其中至少一个互连节点是异步节点。 该方法还包括创建包括异步节点和异步节点之后的互连的事件流。 该方法还包括响应于到达异步节点来调用可执行定向图的执行，以及创建具有与事件流相关联的标识符的状态对象。 该方法还包括继续执行可执行定向图，同时避免异步节点和异步节点之后的互连，并且在接收到针对异步节点的响应时恢复通过状态对象标识的事件流的执行。

公开(公告)号：US08843938B2

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

申请号：US12166499

申请日：2008-07-02

申请人： Peter R. MacFarlane ,  Adrian W. Spender

发明人： Peter R. MacFarlane ,  Adrian W. Spender

IPC分类号： G06F9/46 ,  G06F9/52 ,  G06F9/50 ,  G06Q10/10 ,  G06F9/44

CPC分类号： G06F9/5038 ,  G06F8/34 ,  G06F9/52 ,  G06F2209/5015 ,  G06Q10/10

摘要： A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.

摘要翻译： 提供了一种用于提供异步恢复数据流的方法，系统和计算机程序产品。 该方法包括从包括多个互连节点的数据流构建可执行有向图，其中至少一个互连节点是异步节点。 该方法还包括创建包括异步节点和异步节点之后的互连的事件流。 该方法还包括响应于到达异步节点来调用可执行定向图的执行，以及创建具有与事件流相关联的标识符的状态对象。 该方法还包括继续执行可执行定向图，同时避免异步节点和异步节点之后的互连，并且在接收到针对异步节点的响应时恢复通过状态对象标识的事件流的执行。