Method, device, and computer program product for managing processes based on reading speed of a message queue
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.
1. 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.
2. The method according to claim 1 , further comprising:
determining a total number of the messages in the message queue.
3. The method according to claim 1 , further comprising:
determining whether a speed at which the message queue is read is greater than a predetermined threshold of speed; and
in response to determining that the speed at which the message queue is read is greater than the predetermined threshold of speed, determining to allocate the process for the job.
4. The method according to claim 3 , further comprising:
in response to determining that the speed at which the message queue is read is less than or equal to the predetermined threshold of speed, determining whether the rate of change in speed at which the message queue is read is greater than the predetermined threshold rate of change in speed at which the message queue is read; and
in response to determining that the rate of change in speed at which the message queue is read is greater than the predetermined threshold of rate of change in speed at which the message queue is read, determining to allocate the process for the job.
5. The method according to claim 1 , further comprising:
determining whether a total number of the messages is less than a predetermined threshold number; and
in response to determining that the total number of the messages is less than the predetermined threshold of number, determining to allocate the process for the job.
6. 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.
7. The device according to claim 6 , wherein the acts further comprise:
determining a total number of the messages in the message queue.
8. The device according to claim 6 , wherein the acts further comprise:
determining whether a speed at which the message queue is read is greater than a predetermined threshold of speed; and
in response to determining that the speed at which the message queue is read is greater than the predetermined threshold of speed, determining to allocate the process for the job.
9. The device according to claim 8 , wherein the acts further comprise:
in response to determining that the speed at which the message queue is read is less than or equal to the predetermined threshold of speed, determining whether the rate of change in speed at which the message queue is read is greater than the predetermined threshold rate of change in speed at which the message queue is read; and
in response to determining that the rate of change in speed at which the message queue is read is greater than the predetermined threshold of rate of change in speed at which the message queue is read, determining to allocate the process for the job.
10. The device according to claim 6 , wherein the acts further comprise
determining whether a total number of the messages is less than a predetermined threshold number; and
in response to determining that the total number of the messages is less than the predetermined threshold of number, determining to allocate the process for the job.
11. 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.
12. The computer program product according to claim 11 , wherein the operations further comprise:
determining a total number of the messages in the message queue.
13. The computer program product according to claim 11 , wherein the operations further comprise:
determining whether a speed at which the message queue is read is greater than a predetermined threshold of speed; and
in response to determining that the speed at which the message queue is read is greater than the predetermined threshold of speed, determining to allocate the process for the job.
14. The computer program product according to claim 13 , wherein the operations further comprise:
in response to determining that the speed at which the message queue is read is less than or equal to the predetermined threshold of speed, determining whether the rate of change in speed at which the message queue is read is greater than the predetermined threshold rate of change in speed at which the message queue is read; and
in response to determining that the rate of change in speed at which the message queue is read is greater than the predetermined threshold rate of change in speed at which the message queue is read, determining to allocate the process for the job.