Method, apparatus, and product for scheduling of distributed processing based on average execution time and communication time

A distributed processing apparatus for assigning a series of processing groups to a communicable worker calculator, wherein each of the processing groups includes a plurality of processings, the distributed processing apparatus comprising:

• a memory configured to store a program including a process;
• and
• a processor configured to execute the program, the process including:
• receiving information about an execution time and a waiting time from the worker calculator for a series of previously transmitted processing groups, the execution time being a time required for processing the previously transmitted processing groups, the waiting time being a time from receiving the previously transmitted processing groups to starting execution thereof;
• acquiring the time elapsed from transmitting the previously transmitted processing groups to the worker calculator to receiving the execution result of the previously transmitted processing groups from the worker calculator;
• storing the time elapsed, the execution time and the waiting time in a parameter table;
• calculating a communication time coefficient k and constant c required for communication with the worker calculator by setting up simultaneous equations using parameters k, c, the time elapsed, the execution time, and the waiting time;
• calculating a parameter indicating an average execution time per processing based on the information in the processing table;
• calculating a number of processings to be assigned to the worker calculator on the basis of the average executing time, and the parameters k and c;
• generating a selected processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the calculating of the number of processings;
• and
• transmitting the selected processing group generated by the generating to the worker calculator.

A distributed processing method for assigning a series of processing groups to a communicable worker calculator, wherein each of the processing groups includes a plurality of processings, the distributed processing method comprising:

• receiving information about an execution time and a waiting time from the worker calculator for a series of previously transmitted processing groups, the execution time being a time required for processing the previously transmitted processing groups, the waiting time being a time from receiving the previously transmitted processing groups to starting execution thereof;
• acquiring the time elapsed from transmitting the previously transmitted processing groups to the worker calculator to receiving the execution result of the previously transmitted processing groups from the worker calculator;
• storing the time elapsed, the execution time and the waiting time in a parameter table;
• calculating a communication time coefficient k and constant c required for communication with the worker calculator by setting up simultaneous equations using parameters k, c, the time elapsed, the execution time and the waiting time;
• calculating a parameter indicating an average execution time per processing based on the information in the processing table;
• calculating a number of processings to be assigned to the worker calculator on the basis of the average execution time, and the parameters k and c;
• generating a selected processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the calculating of the number of processings;
• and
• transmitting the selected processing group generated by the generating to the worker calculator.

A system comprising:

• a plurality of worker calculators;
• and
• a distributed processing apparatus configured to assign a series of processing groups to the worker calculator, wherein each of the processing groups includes a plurality of processings,
• the distributed processing apparatus comprising:
• a memory configured to store a program including a process;
• and
• a processor configured to execute the program, the process including:
• receiving information about an execution time and a waiting time from the worker calculator for a series of previously transmitted processing groups, the execution time being a time required for processing the previously transmitted processing groups, the waiting time being a time from receiving the previously transmitted processing groups to starting execution thereof;
• acquiring the time elapsed from transmitting the previously transmitted processing groups to the worker calculator to receiving the execution result of the previously transmitted processing groups from the worker calculator;
• storing the time elapsed, the execution time and the waiting time in a parameter table;
• calculating a communication time coefficient k and constant c required for communication with the worker calculator by setting up simultaneous equations using parameters k, c, the time elapsed, the execution time, and the waiting time;
• calculating a parameter indicating an average execution time per processing based on the information in the processing table;
• calculating a number of processings to be assigned to the worker calculator on the basis of the average execution time, and the parameters k and c;
• generating a selected processing group to be assigned to the worker calculator on the basis of the number of processings calculated by the calculating of the number of processings;
• and
• transmitting the selected processing group generated by the generating to the worker calculator.