Data actor and data processing method thereof

A data actor, implemented by a computer processing unit (CPU), comprising:

• a message bin,
• a finite state machine,
• a processing component and
• an output data cache, wherein,
• the data actor is in data communication with a direct upstream data actor and/or a direct downstream data actor;
• the message bin receives a first message from the direct upstream data actor and/or a second message from the direct downstream data actor;
• the finite state machine changes a current state of the actor based on the first message and/or the second message in the message bin and an operation of the processing component;
• the finite state machine comprises a state and the state is based on whether there is the first message from the direct upstream data actor and whether the output data cache of the data actor is changed to an idle state;
• as the state of the finite state machine indicates that the first message from the direct upstream data actor is already received and the output data cache of the data actor is already changed to an idle state, the processing component reads data in an output data cache of the direct upstream data actor and performs a predetermined operation, and stores result data in a local output cache;
• after the data actor completes an operation task, the finite state machine returns to an original state to await a next state change cycle, and at the same time, the data actor feeds a third message that the use of data from the direct upstream data actor is completed back to a message bin of the direct upstream data actor, and sends a fourth message that data of the data actor is already generated to the direct downstream data actor, to notify the direct downstream data actor that the data of the data actor is already in a readable state;
• when the direct downstream data actor reads the data of the data actor and complete its use, the direct downstream data actor feeds a fifth message back to the data actor, notifying the direct upstream data actor that the use of the first data is completed;
• the output data cache of the direct upstream data actor is in an idle state, and the finite state machine of the direct upstream data actor modifies its state;
• when the state of the finite state machine reaches a trigger condition, the processing component directly reads output data in the readable state in the output data cache of the direct upstream data actor and executes the predetermined operation, and then stores result data subsequent to execution of the predetermined operation in an output data cache of the data actor;
• the processing component sends the fourth message to a message bin of the direct downstream data actor while storing the result data in the output data cache of the data actor, so as to notify the downstream data actor that the result data stored in the output data cache of the data actor is readable;
• and
• the processing component sends the third message to a message bin of the direct upstream data actor while storing the result data in the output data cache of the data actor, so as to notify the direct upstream data actor that result data stored in the output data cache of the direct upstream data actor is already read.