Streaming operations for workflow process models using multiple views on a same buffer

摘要

A buffer may be configured to store a plurality of items, and to be accessed by one or more activities of an instance of a process model. A scheduler may be configured to schedule execution of each of a plurality of activities of the process model, and to determine an activation of an activity of the plurality of activities. The scheduler may include an activity manager configured to access an activity profile of the activity upon the determining of the activation, the activity profile including buffer access characteristics according to which the activity is designed to access the buffer. A process execution unit may be configured to execute the activity and may include a buffer access manager configured to access the buffer according to the buffer access characteristics of the activity profile, and to thereby facilitate an exchange of at least one item between the buffer and the activity.

主权项

1. A system comprising:
at least one processor; a non-transitory computer-readable medium storing executable instructions that when executed by the at least one processor are configured to implement: a buffer configured to store a plurality of items, and configured to be accessed by a plurality of activities of an instance of a process model; a scheduler configured to cause the at least one processor to schedule execution of each of the plurality of activities of the instance of the process model, and configured to determine a first activation of a first activity of the plurality of activities, and a second activation of a second activity of the plurality of activities, the scheduler including an activity manager configured to access a first activity profile of the first activity upon the determining of the first activation, and access a second activity profile of the second activity upon determining of the second activation, the first activity profile and the second activity profile including different buffer access characteristics that specify a manner in which a respective activity accesses the buffer within the instance of the process model; and a process execution unit configured to cause the at least one processor to execute the first activity and the second activity within the instance of the process model, the process execution unit including a buffer access manager configured to access the buffer when executing the first activity based on the buffer access characteristics of the first activity profile and access the buffer when executing the second activity based on the buffer access characteristics of the second activity profile, the first activity being activated only once to execute a plurality of access operations with respect to the buffer, the buffer access manager including an order mediator, wherein when streaming out from the buffer using multiple views on the same buffer, the order mediator is configured to provide multiple ordering views on the buffer by receiving the plurality of items from the buffer, reordering the received plurality of items of the buffer for inclusion within a first reordered buffer in which the plurality of items of the buffer are ordered for the first activity according to a first order, and reordering the received plurality of items of the buffer for inclusion within a second reordered buffer in which the plurality of items of the buffer are ordered for the second activity according to a second order such that the plurality of items are streamed in different orders to the first and second activities, the first order being different than the second order.