Apparatus and method for managing stream processing tasks
AssigneeElectronics and Telecommunications Research Institute
InventorMyung-Cheol Lee
Life of this patent
Estimating the term…
Abstract
An apparatus and method for managing stream processing tasks are disclosed. The apparatus includes a task management unit and a task execution unit. The task management unit controls and manages the execution of assigned tasks. The task execution unit executes the tasks in response to a request from the task management unit, collects a memory load state and task execution frequency characteristics based on the execution of the tasks, detects low-frequency tasks based on the execution frequency characteristics if it is determined that a shortage of memory has occurred based on the memory load state, assigns rearrangement priorities to the low-frequency tasks, and rearranges the tasks based on the assigned rearrangement priorities.
Claims18
An apparatus having a non-transitory computer readable recording medium (CRRM) containing programming instructions configured for managing stream processing tasks, comprising:
- a task management unit configured to control and manage execution of assigned tasks;
- and
- a task execution unit configured to execute the tasks in response to a request from the task management unit, to collect a memory load state and task execution frequency characteristics based on the execution of the tasks, to detect low-frequency tasks based on predetermined policies for the execution frequency characteristics if it is determined that a shortage of memory has occurred based on the memory load state, to assign rearrangement priorities to the low-frequency tasks, and to rearrange the tasks based on the assigned rearrangement priorities, wherein the task execution unit detects the low-frequency tasks in active tasks included in an active task pool based on their frequencies of execution or recent execution times included in the collected task execution frequency characteristics.
A non-transitory computer readable recording medium (CRRM) containing programming instructions configured to perform a method of managing stream processing tasks, comprising:
- collecting, by an apparatus for managing stream processing tasks, a memory load state and task execution frequency characteristics based on execution of tasks;
- determining, by the apparatus for managing stream processing tasks, whether or not a shortage of memory has occurred based on the collected memory load state;
- detecting, by the apparatus for managing stream processing tasks, low-frequency tasks based on the collected task execution frequency characteristics if, as a result of the determination, it is determined that a shortage of memory has occurred, wherein detecting the low-frequency tasks comprises detecting, by the apparatus for managing stream processing tasks, the low-frequency tasks in active tasks included in an active task pool based on predetermined policies for frequencies of execution or for recent execution times included in the collected task execution frequency characteristics;
- assigning, by the apparatus for managing stream processing tasks, rearrangement priorities to the detected low-frequency tasks;
- generating, by the apparatus for managing stream processing tasks, task rearrangement information based on the assigned rearrangement priorities;
- and
- rearranging, by the apparatus for managing stream processing tasks, the tasks based on the generated task rearrangement information.
Dependencies are inferred from the claim text.