Granted Patent B2

US 12,293,218 · App. 17/027,569 · Granted May 6, 2025

Inventor: Iraj Sodagar (Los Angeles, CA)

Assignee: TENCENT AMERICA LLC

G06F9/485G06F9/4881G06F9/5038G06F9/542G06F9/544

Abstract

Claims (64)

1. A method for processing a workflow, the method comprising:

receiving, by processing circuitry, workflow information of the workflow;

generating, based on the workflow information, the workflow to process input data, the workflow including a plurality of processing tasks and a plurality of buffering tasks, the plurality of processing tasks including a first processing task, a second processing task, and a third processing task, the plurality of buffering tasks including a first buffering task and a second buffering task; and

sequentially processing, by the plurality of processing tasks, a subset of the input data by

causing the first processing task to enter a first running state in which the subset of the input data is processed by the first processing task and output to the first buffering task as first processed subset data;

causing the first processing task to transition from the first running state to a first paused state based on an amount of the first processed subset data stored in the first buffering task being equal to a first threshold, state information of the first processing task being stored in the first paused state;

after the first processing task is transitioned to the first paused state, causing the second processing task to enter a second running state in which the first processed subset data stored in the first buffering task is processed by the second processing task and output to the second buffering task as second processed subset data;

causing the second processing task to transition from the second running state to a second paused state based on one of (i) an amount of the second processed subset data stored in the second buffering task being equal to a second threshold and (ii) the amount of the first processed subset data stored in the first buffering task being provided to the second processing task, state information of the second processing task being stored in the second paused state; and

after the second processing task is transitioned to the second paused state, causing the third processing task to enter a third running state in which the second processed subset data stored in the second buffering task is processed by the third processing task, the first processing task, the second processing task, and the third processing task being different video processing tasks.

2. The method of claim 1 , wherein

the first buffering task is configured to generate an event indicating that the amount of the first processed subset data stored in the first buffering task is equal to the first threshold.

3. The method of claim 2 , wherein

the first buffering task is a first-in-first-out (FIFO) task configured with a FIFO buffer, the FIFO buffer having a FIFO length that is equal to or larger than the first threshold; and

the FIFO task is configured to:

generate the event indicating that the amount of the first processed subset data stored in the FIFO task is equal to the first threshold; and

generate another event indicating that the amount of the first processed subset data stored in the FIFO task is provided to the second processing task.

4. The method of claim 1 , wherein the subset of the input data is one of a plurality of subsets of the input data.

5. The method of claim 1 , wherein a lifecycle of the first processing task includes transitioning between the first paused state and one of the first running state, an error state, and a destroyed state.

6. The method of claim 1 , wherein

each input of the plurality of processing tasks is from one of the input data and one or more of the plurality of buffering tasks, and

only one of the plurality of processing tasks is allowed to be in a respective running state at any point in time.

7. The method of claim 1 , wherein

the input data includes the subset of the input data and another subset of the input data;

each input of the plurality of processing tasks is from one of the input data and one or more of the plurality of buffering tasks;

after the subset of the input data is processed by the plurality of processing tasks, the method includes sequentially processing the other subset of the input data by the plurality of processing tasks, remaining processing tasks in the plurality of processing tasks being in paused states; and

only one of the plurality of processing tasks is allowed to be in a respective running state at any point in time.

8. A method for processing a plurality of workflows, the method comprising:

receiving, by processing circuitry, workflow information of the plurality of workflows;

generating, based on the workflow information, the plurality of workflows to process input data, at least one of the plurality of workflows including a plurality of processing tasks, the plurality of workflows including a cascade of workflows that includes a first workflow and a second workflow, the plurality of processing tasks being different video processing tasks;

causing the first workflow to enter a running state in which a subset of the input data is processed by the first workflow and output to a buffering task as first processed subset data, the buffering task being a first-in-first-out (FIFO) task configured with a FIFO buffer;

causing the first workflow to transition from the running state to a paused state based on an event that indicates an amount of the first processed subset data stored in the buffering task is equal to a threshold being generated by the FIFO task, state information of the first workflow being stored in the paused state, wherein

the FIFO buffer has a FIFO length that is equal to or larger than the threshold; and

the FIFO task is configured to:

generate the event indicating that the amount of the first processed subset data stored in the FIFO task is equal to the threshold; and

generate another event indicating that the amount of the first processed subset data stored in the FIFO task is provided to the second workflow; and

after the first workflow is transitioned to the paused state, causing the second workflow to enter a running state in which the first processed subset data stored in the buffering task is processed by the second workflow.

9. The method of claim 8 , wherein the subset of the input data is one of a plurality of subsets of the input data.

10. An apparatus for processing a workflow, the apparatus including:

processing circuitry that is configured to:

receive workflow information of the workflow;

generate, based on the workflow information, the workflow to process input data, the workflow including a plurality of processing tasks and a plurality of buffering tasks, the plurality of processing tasks including a first processing task, a second processing task, and a third processing task, the plurality of buffering tasks including a first buffering task and a second buffering task; and

sequentially process, by the plurality of processing tasks, a subset of the input data by

causing the first processing task to enter a first running state in which the subset of the input data is processed by the first processing task and output to the first buffering task as first processed subset data;

causing the first processing task to transition from the first running state to a first paused state based on an amount of the first processed subset data stored in the first buffering task being equal to a first threshold, state information of the first processing task being stored in the first paused state;

after the first processing task is transitioned to the first paused state, causing the second processing task to enter a second running state in which the first processed subset data stored in the first buffering task is processed by the second processing task and output to the second buffering task as second processed subset data;

causing the second processing task to transition from the second running state to a second paused state based on one of (i) an amount of the second processed subset data stored in the second buffering task being equal to a second threshold and (ii) the amount of the first processed subset data stored in the first buffering task being provided to the second processing task, state information of the second processing task being stored in the second paused state; and

after the second processing task is transitioned to the second paused state, causing the third processing task to enter a third running state in which the second processed subset data stored in the second buffering task is processed by the third processing task, the first processing task, the second processing task, and the third processing task being different video processing tasks.

11. The apparatus of claim 10 , wherein the first buffering task is configured to generate an event indicating that the amount of the first processed subset data stored in the first buffering task is equal to the first threshold.

12. The apparatus of claim 11 , wherein

the first buffering task is a first-in-first-out (FIFO) task configured with a FIFO buffer, the FIFO buffer having a FIFO length that is equal to or larger than the first threshold; and

the FIFO task is configured to:

generate the event indicating that the amount of the first processed subset data stored in the FIFO task is equal to the first threshold; and

generate another event indicating that the amount of the first processed subset data stored in the FIFO task is provided to the second processing task.

13. The apparatus of claim 10 , wherein the subset of the input data is one of a plurality of subsets of the input data.

14. The apparatus of claim 10 , wherein a lifecycle of the first processing task includes transitioning between the first paused state and one of the first running state, an error state, and a destroyed state.

15. The apparatus of claim 10 , wherein

each input of the plurality of processing tasks is from one of the input data and one or more of the plurality of buffering tasks, and

only one of the plurality of processing tasks is allowed to be in a respective running state at any point in time.

16. The apparatus of claim 10 , wherein

the input data includes the subset of the input data and another subset of the input data;

each input of the plurality of processing tasks is from one of the input data and one or more of the plurality of buffering tasks;

only one of the plurality of processing tasks is allowed to be in a respective running state at any point in time; and

the processing circuitry is configured to:

after the subset of the input data is processed by the plurality of processing tasks, sequentially process the other subset of the input data by the plurality of processing tasks, remaining processing tasks in the plurality of processing tasks being in paused states.

Assignments (1)

Continuity (2)

References Cited (19)