Method, device, and computer program product for managing processes based on reading speed of a message queue
AssigneeEMC IP Holding Company LLC
InventorsJun Tang, Wei Wang
Life of this patent
Estimating the term…
Abstract
Method, device, and computer program product for managing processes are disclosed. The method may include, in response to detecting a job to be executed in a job processing system, determining attribute information related to execution of a message queue in the job processing system; and determining, based on the attribute information, allocation information for a process to execute the job. The number of processes can be dynamically adjusted according to the current processing capacity of the job processing system, thereby improving the use of the resources of the job processing system and meanwhile avoiding crashing of the job processing system.
Claims14
A method comprising:
- detecting a job to be performed at a job processing system that comprises a message queue and a plurality of job executing devices, wherein the message queue is populated with messages, corresponding to running jobs being executed by the plurality of job executing devices, that are read;
- determining, for each predetermined time period of a plurality of consecutive predetermined time periods, a number of messages read within a respective predetermined time period in the message queue to calculate a speed at which the message queue was read corresponding to the respective predetermined time period;
- determining, based on each speed corresponding to each predetermined time period, a rate of change in speed at which the message queue is read;
- and
- allocating a process on a job executing device of the plurality of job executing devices to execute the job and executing the job on the process in response to determining that the rate of change in speed at which the message queue is read is greater than a predetermined threshold of rate of change in speed at which the message queue is read.
An electronic device comprising:
- at least one processing unit;
- and
- at least one memory, coupled to the at least one processing unit and storing instructions executed by the at least one processing unit, the instructions, when executed by the at least one processing unit, causing the electronic device to perform acts, the acts comprising:
- detecting a job to be performed at a job processing system that comprises a message queue and a plurality of job executing devices, wherein the message queue is populated with messages corresponding to running jobs being executed by the plurality of job executing devices, that are read;
- determining, for each predetermined time period of a plurality of consecutive predetermined time periods, a number of messages read within a respective predetermined time period in the message queue to calculate a speed at which the message queue was read corresponding to the respective predetermined time period;
- determining, based on each speed corresponding to each predetermined time period, a rate of change in speed at which the message queue is read;
- and
- allocating a process on a job executing device of the plurality of job executing devices to execute the job and executing the job on the process in response to determining that the rate of change in speed at which the message queue is read is greater than a predetermined threshold rate of change in speed at which the message queue is read.
A computer program product tangibly stored on a non-transitory computer-readable medium and comprising machine-executable instructions, the machine-executable instructions, when executed by a device, cause the device to perform operations comprising:
- detecting a job to be performed at a job processing system that comprises a message queue and a plurality of job executing devices, wherein the message queue is populated with messages, corresponding to running jobs being executed by the plurality of job executing devices, that are read;
- determining, for each predetermined time period of a plurality of consecutive predetermined time periods, a number of messages read within a respective predetermined time period in the message queue to calculate a speed at which the message queue was read corresponding to the respective predetermined time period;
- determining, based on each speed corresponding to each predetermined time period, a rate of change in speed at which the message queue is read;
- and
- allocating a process on a job executing device of the plurality of job executing devices to execute the job and executing the job on the process in response to determining that the rate of change in speed at which the message queue is read is greater than a predetermined threshold rate of change in speed at which the message queue is read.
Dependencies are inferred from the claim text.