RECORDING MEDIUM IN WHICH DISTRIBUTED PROCESSING PROGRAM IS STORED, DISTRIBUTED PROCESSING APPARATUS, AND DISTRIBUTED PROCESSING METHOD

• US 20090187907A1
• Filed: 12/29/2008
• Published: 07/23/2009
• Est. Priority Date: 01/17/2008
• Status: Active Grant

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: Shimizu, Toshihiro, Shigeta, Soichi
• Granted Patent: US 8,544,009 B2
• Time in Patent Office: Days
• US Class Current: 718/101
• CPC Class Codes: G06F 2209/509 Offload
• CPC Class Codes: G06F 9/505 considering the load

Abstract

A master calculator assigns a series of processing groups to a communicable worker calculator. The master receives information about an execution time and a waiting time from the worker calculator for the series of processing groups. The computer acquires the time elapsed between transmitting the processing group transmitted to the worker calculator and receiving the execution result of the processing group from the worker calculator. The master calculates the communication time required for communication with the worker calculator on the basis of the information received and the elapsed time acquired. The master calculates the number of processings to be assigned to the worker calculator on the basis of the communication time calculated. The master generates a processing group to be assigned to the worker calculator on the basis of the number of processings calculated, and transmits the processing group generated to the worker calculator.

Claims

1. A computer-readable recording medium storing a distributed processing program executed by a computer, the computer being a master calculator which assigns a series of processing groups to a communicable worker calculator, the program comprising:

receiving means for receiving information about an execution time and a waiting time from the worker calculator among the series of processing groups, the execution time being a time for a processing group transmitted beforehand, the waiting time being a time from receiving the processing group transmitted beforehand to starting execution thereof;

acquisition means for acquiring the time elapsed from transmitting the processing group transmitted beforehand to the worker calculator to receiving the execution result of the processing group transmitted beforehand from the worker calculator;

first calculation means for calculating the communication time required for communication with the worker calculator on the basis of the information received by the receiving means and the elapsed time acquired by the acquisition means;

second calculation means for calculating the number of processings to be assigned to the worker calculator on the basis of the communication time calculated by the first calculation means;

generation means for generating a processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the second calculation means; and

transmission means for transmitting the processing group generated by the generation means to the worker calculator.

2. The computer-readable recording medium according to claim 1, wherein

the first calculation means calculates a processing performance value from the throughput value of the worker calculator;

and

the second calculation means calculates the number of processings on the basis of the communication time and the processing performance value calculated by the first calculation means.

3. The computer-readable recording medium according to claim 1, wherein, when execution of a processing group transmitted beforehand between two processing groups already assigned to the worker calculator is completed, the receiving means, the first calculation means, the second calculation means, the generation means and the transmission means execute their respective processings again.

4. The computer-readable recording medium according to claim 1, wherein the second calculation means calculates such a number of processings that the communication time is equal to or shorter than the execution time required for the processing group, in which the processings are collected, in the worker calculator.

5. The computer-readable recording medium according to claim 1, further comprising:

determination means for determining an assignment destination of the series of processing groups from a worker calculator group under the control of the master worker, wherein

the receiving means receives information about the execution time required for the processing group transmitted beforehand among the series of processing groups and the waiting time from receiving the processing group transmitted beforehand to starting execution thereof, from the assignment-destination worker calculator determined by the determination means.

6. The computer-readable recording medium according to claim 5, wherein the determination means determines the assignment destination from the worker calculator group on the basis of the usage state of each of the worker calculators.

7. The computer-readable recording medium according to claim 5, wherein the determination means determines the assignment destination from the worker calculator group on the basis of the processing performance of each of the worker calculators.

8. A computer-readable recording medium storing a distributed processing program executed by a computer, the computer being a worker calculator capable of communicating with a master calculator, the program comprising:

execution means for executing a processing group assigned from the master calculator;

receiving means for receiving the processing group from the master calculator;

measurement means for measuring the waiting time from when the processing group is received by the receiving means to when execution of the processing group is started by the execution means; and

transmission means for transmitting information about the waiting time measured by the measurement means, to the master calculator.

9. The computer-readable recording medium according to claim 8, wherein

the measurement means measures the execution time required for execution of the processing group by the execution means;

and

the transmission means transmits information about the execution time measured by the measurement means, to the master calculator.

10. A distributed processing apparatus for assigning a series of processing groups to a communicable worker calculator, the distributed processing apparatus comprising:

receiving means for receiving information about an execution time and a waiting time from the worker calculator among the series of processing groups, the execution time being a time for a processing group transmitted beforehand, the waiting time being a time from receiving the processing group transmitted beforehand to starting execution thereof;

acquisition means for acquiring the time elapsed from transmitting the processing group transmitted beforehand to the worker calculator to receiving the execution result of the processing group transmitted beforehand from the worker calculator;

first calculation means for calculating the communication time required for communication with the worker calculator on the basis of the information received by the receiving means and the elapsed time acquired by the acquisition means;

second calculation means for calculating the number of processings to be assigned to the worker calculator on the basis of the result calculated by the first calculation means;

generation means for generating a processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the second calculation means; and

transmission means for transmitting the processing group generated by the generation means to the worker calculator.

11. A distributed processing apparatus comprising:

execution means for executing a processing group assigned from a master calculator;

receiving means for receiving the processing group from the master calculator;

measurement means for measuring the waiting time from when the processing group is received by the receiving means to when execution of the processing group is started by the execution means; and

transmission means for transmitting information about the waiting time measured by the measurement means, to the master calculator.

12. A distributed processing method for assigning a series of processing groups to a communicable worker calculator, the distributed processing method comprising:

a receiving step of receiving information about an execution time and a waiting time from the worker calculator among the series of processing groups, the execution time being a time for a processing group transmitted beforehand, the waiting time being a time from receiving the processing group transmitted beforehand to starting execution thereof;

an acquisition step of acquiring the time elapsed from transmitting the processing group transmitted beforehand to the worker calculator to receiving the execution result of the processing group transmitted beforehand from the worker calculator;

a first calculation step of calculating the communication time required for communication with the worker calculator on the basis of the information received by the receiving step and the elapsed time acquired by the acquisition step;

a second calculation step of calculating the number of processings to be assigned to the worker calculator on the basis of the result calculated by the first calculation step;

a generation step of generating a processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the second calculation step; and

a transmission step of transmitting the processing group generated by the generation step to the worker calculator.

13. A distributed processing method comprising:

an execution step of executing a processing group assigned from a master calculator;

a receiving step of receiving the processing group from the master calculator;

a measurement step of measuring the waiting time from when the processing group is received by the receiving step and to when execution of the processing group is started by the execution step; and

a transmission step of transmitting information about the waiting time measured by the measurement step, to the master calculator.