[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

JP2005063066A - Distributed computing system - Google Patents

Distributed computing system Download PDF

Info

Publication number
JP2005063066A
JP2005063066A JP2003290814A JP2003290814A JP2005063066A JP 2005063066 A JP2005063066 A JP 2005063066A JP 2003290814 A JP2003290814 A JP 2003290814A JP 2003290814 A JP2003290814 A JP 2003290814A JP 2005063066 A JP2005063066 A JP 2005063066A
Authority
JP
Japan
Prior art keywords
calculation
partial
calculation processing
power
processing
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
JP2003290814A
Other languages
Japanese (ja)
Other versions
JP3896352B2 (en
Inventor
Kazuo Iwano
和生 岩野
Toshihiko Kamijo
利彦 上條
Takanori Seki
孝則 関
Seishi Kobayashi
小林 誠士
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
International Business Machines Corp
Original Assignee
International Business Machines Corp
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by International Business Machines Corp filed Critical International Business Machines Corp
Priority to JP2003290814A priority Critical patent/JP3896352B2/en
Publication of JP2005063066A publication Critical patent/JP2005063066A/en
Application granted granted Critical
Publication of JP3896352B2 publication Critical patent/JP3896352B2/en
Anticipated expiration legal-status Critical
Expired - Fee Related legal-status Critical Current

Links

Images

Classifications

    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Multi Processors (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

<P>PROBLEM TO BE SOLVED: To provide a distributed computing system which is designed for reduction of power consumption. <P>SOLUTION: A computing demand system which makes two or more computing devices perform two or more partial calculations respectively, is provided with;a means 200 for acquiring power processing index information which indicates power consumption per computing throughput for each computing device; a means 225 for generating power consumption index information which indicates electric energy required for processing of the partial calculations concerned in comparison with other partial calculations for each of two or more partial calculations; a means 250 for acquiring conditions of the electric energy consumed when two or more partial calculations are performed; a means 275 to choose a computing device which fulfills the conditions concerned when performing the partial calculations concerned among two or more computing devices based on the power processing index information and the power consumption index information in association with each of two or more partial calculations; a means 215 for making each of two or more partial calculations be performed by the computing device chosen in association with the partial calculation concerned respectively; and a means 280 for outputting a received group of partial calculation results. <P>COPYRIGHT: (C)2005,JPO&NCIPI

Description

本発明は、分散コンピューティングシステムに関する。特に、本発明は、消費電力の低減を目的とする分散コンピューティングシステムに関する。   The present invention relates to distributed computing systems. In particular, the present invention relates to a distributed computing system aimed at reducing power consumption.

近年、資源を有効に利用し、かつ自然環境に与える影響を軽減することを目的として、電力を有効に活用する技術が注目されている。従来、電力を有効に活用する技術として、消費電力を削減する省電力技術及び余剰電力を有効に利用する技術が知られている。   In recent years, attention has been paid to a technique for effectively using power for the purpose of effectively using resources and reducing the influence on the natural environment. Conventionally, as a technique for effectively using power, a power saving technique for reducing power consumption and a technique for effectively using surplus power are known.

例えば、情報処理装置の消費電力を削減する省電力技術として、情報処理装置の稼動状態に応じて駆動周波数又は駆動電圧を調節する技術が用いられている。一例として、インテルコーポレーションのSpeedStep(登録商標)、トランスメタコーポ−レーションのLongRun(登録商標)、又はネットワーク上の複数の情報処理装置を一括して制御する技術(特許文献1参照)が用いられている。   For example, as a power saving technique for reducing the power consumption of the information processing apparatus, a technique of adjusting the driving frequency or the driving voltage according to the operating state of the information processing apparatus is used. As an example, SpeedStep (registered trademark) of Intel Corporation, LongRun (registered trademark) of Trans Meta Corporation, or a technology for collectively controlling a plurality of information processing apparatuses on a network (see Patent Document 1) is used. Yes.

また、余剰電力を有効に利用する技術として、電力消費を平準化する技術が提案されている。例えば、時間帯に応じた電力消費の偏りを平準化する技術として、所定の地域内において電力消費が集中した場合には、予め充電したバッテリーを優先的に使う技術(特許文献2参照)が提案されている。また、地域に応じた電力消費の偏りを平準化する方法として、余剰電力を有する地域から電気を買い取る方法(特許文献3参照)が提案されている。   Further, as a technique for effectively using surplus power, a technique for leveling power consumption has been proposed. For example, a technique for preferentially using a precharged battery when power consumption is concentrated in a predetermined area is proposed as a technique for leveling the bias of power consumption according to time zones (see Patent Document 2). Has been. In addition, as a method for leveling out the bias of power consumption according to the region, a method of purchasing electricity from a region having surplus power (see Patent Document 3) has been proposed.

また、近年、膨大な時間を要する計算処理又は膨大なメモリ空間を必要とする計算処理を、計算力が余剰している複数の情報処理装置により実行させるグリッドコンピューティングシステムが注目されている。   In recent years, attention has been paid to a grid computing system that allows a plurality of information processing apparatuses having surplus computing power to execute a calculation process that requires an enormous amount of time or a calculation process that requires an enormous amount of memory space.

特開2000−259292号公報JP 2000-259292 A 特開2002−271992号公報JP 2002-271992 A 特開2002−58160号公報JP 2002-58160 A

しかしながら、従来のグリッドコンピューティング技術によると、余剰計算力を有する情報処理装置を有効に利用することにより計算処理を高速化することができる一方、膨大な計算機リソースを並行して利用してしまう。これにより、計算処理を実行する情報処理装置が所定の地域に集中した場合には、当該地域の電力消費量が増大する。   However, according to the conventional grid computing technology, it is possible to speed up the calculation process by effectively using the information processing apparatus having surplus computing power, but it uses a huge amount of computer resources in parallel. Thereby, when the information processing apparatus which performs calculation processing concentrates on a predetermined area, the power consumption of the area increases.

上記省電力技術によると、情報処理装置は、計算の処理量が少ない場合又は処理の内容に関わらず、計算の実行速度を抑えることにより消費電力を低減する。しかしながら、処理の重要度に応じて高速に処理する等、処理の内容に応じた消費電力の調節を行うことはできないので、グリッドコンピューティング技術への適用は困難であった。また、電力消費を平準化する上記技術は、蓄電池の充電又は電気の長距離輸送等により、電力が多量に損失する場合がある。   According to the power saving technique, the information processing apparatus reduces power consumption by suppressing the calculation execution speed regardless of the amount of calculation processing or the content of the processing. However, since it is impossible to adjust the power consumption according to the content of processing, such as processing at high speed in accordance with the importance of processing, it has been difficult to apply to grid computing technology. In addition, the above technique for leveling power consumption may cause a large amount of power loss due to charging of storage batteries or long-distance transportation of electricity.

上記課題を解決するために、本発明の第1の形態においては、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行する複数の計算処理装置と、複数の計算処理装置に部分計算を要求する計算要求装置とを備える分散コンピューティングシステムであって、計算要求装置は、複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、複数の計算処理装置が複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、複数の部分計算のそれぞれに対応付けて、複数の計算処理装置のうち当該部分計算を実行する場合に電力量条件情報を満たす計算処理装置を、電力処理指標情報及び消費電力指標情報に基づいて選択する選択手段と、複数の部分計算のそれぞれを、選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、複数の計算処理装置から受け取った部分計算の結果の組を、計算処理の結果として出力する処理結果出力手段とを有し、複数の計算処理装置のそれぞれは、計算要求装置から要求された部分計算を処理する部分計算処理手段と、部分計算の処理結果を計算要求装置に送信する処理結果送信手段とを有する分散コンピューティングシステム、当該分散コンピューティングシステムを制御する制御方法、コンピュータシステムを当該分散コンピューティングシステムとして機能させるプログラム、及び当該プログラムを記録した記録媒体を提供する。   In order to solve the above problems, in the first embodiment of the present invention, a plurality of calculation processing devices respectively executing a plurality of partial calculations constituting a predetermined calculation processing, and a partial calculation in a plurality of calculation processing devices A calculation requesting device that obtains power processing index information indicating power consumption per predetermined calculation processing amount for each of a plurality of calculation processing devices. For each of the processing index information acquisition means and the plurality of partial calculations, power consumption index information indicating the amount of power required for the processing of the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device is generated. Power indicating the condition to be satisfied by the amount of power consumed when the power consumption index information generating means and a plurality of calculation processing devices execute a plurality of partial calculations A condition information acquisition unit that acquires condition information, and a calculation processing device that satisfies the power amount condition information when executing the partial calculation among a plurality of calculation processing devices in association with each of the plurality of partial calculations. A selection means for selecting based on the index information and the power consumption index information; a partial calculation requesting means for causing the calculation processing device selected by the selection means to associate each partial calculation with the partial calculation; Processing result output means for outputting a set of partial calculation results received from the calculation processing device as a result of the calculation processing, and each of the plurality of calculation processing devices performs a partial calculation requested by the calculation requesting device. A distributed computing system comprising: a partial calculation processing means for processing; and a processing result transmission means for transmitting a processing result of the partial calculation to a calculation requesting device, Control method for controlling a computing system, a program that causes a computer system as the distributed computing system, and provides a recording medium recording the program.

なお、上記の発明の概要は、本発明の必要な特徴の全てを列挙したものではなく、これらの特徴群のサブコンビネーションもまた、発明となりうる。   The above summary of the invention does not enumerate all the necessary features of the present invention, and sub-combinations of these feature groups can also be the invention.

本発明によれば、電力を有効に利用することができる。   According to the present invention, power can be used effectively.

以下、発明の実施の形態を通じて本発明を説明するが、以下の実施形態は特許請求の範囲にかかる発明を限定するものではなく、また実施形態の中で説明されている特徴の組み合わせの全てが発明の解決手段に必須であるとは限らない。   Hereinafter, the present invention will be described through embodiments of the invention. However, the following embodiments do not limit the invention according to the scope of claims, and all combinations of features described in the embodiments are included. It is not necessarily essential for the solution of the invention.

図1は、分散コンピューティングシステム10のブロック図を示す。分散コンピューティングシステム10は、予め定められた計算処理700を構成する複数の部分計算を計算処理装置30−1〜Nに実行させると共に、計算処理装置30−1〜Nの消費電力を低減することを目的とする。   FIG. 1 shows a block diagram of a distributed computing system 10. The distributed computing system 10 causes the calculation processing devices 30-1 to 30-N to execute a plurality of partial calculations constituting the predetermined calculation processing 700 and reduces the power consumption of the calculation processing devices 30-1 to 30-N. With the goal.

分散コンピューティングシステム10は、計算処理装置30−1〜Nに部分計算の処理を要求する計算要求装置20と、複数の部分計算をそれぞれ実行する計算処理装置30−1〜Nと、計算処理装置30−1〜Nを管理する下階層管理装置40−1〜Mと、下階層管理装置40−1〜Mを管理する上階層管理装置50−1〜Lとを備える。   The distributed computing system 10 includes a calculation requesting device 20 that requests the calculation processing devices 30-1 to 30 -N to perform partial calculation processing, a calculation processing devices 30-1 to 30 -N that respectively execute a plurality of partial calculations, and a calculation processing device. The lower tier management devices 40-1 to 40-M that manage 30-1 to N and the upper tier management devices 50-1 to 50L that manage the lower tier management devices 40-1 to M are provided.

計算要求装置20は、計算処理装置30−1〜Nのそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報及び当該計算処理装置に供給される電力の安定性を示す安定性情報を、下階層管理装置40−1〜M及び上階層管理装置50−1〜Lから取得する。そして、計算要求装置20は、電力処理指標情報及び安定性情報に基づいて、複数の部分計算のそれぞれを計算処理装置30−1〜Nの何れかに実行させる。   The calculation requesting device 20 includes, for each of the calculation processing devices 30-1 to 30-N, power processing index information indicating power consumption per predetermined calculation processing amount and stability indicating stability of power supplied to the calculation processing device. Information is acquired from the lower layer management devices 40-1 to 40-M and the upper layer management devices 50-1 to 50-L. Then, the calculation requesting device 20 causes each of the plurality of partial calculations to be executed by any of the calculation processing devices 30-1 to 30-N based on the power processing index information and the stability information.

ここで、計算処理又は部分計算とは、例えば、情報処理装置により実行されることにより所望の計算結果を出力するアプリケーションプログラムである。これに代えて、計算処理又は部分計算とは、サブルーチン、関数、手続、又はメソッドであってもよい。   Here, the calculation process or the partial calculation is an application program that outputs a desired calculation result by being executed by the information processing apparatus, for example. Alternatively, the calculation process or partial calculation may be a subroutine, a function, a procedure, or a method.

下階層管理装置40−1〜Mは、計算処理装置30−1〜Nを分類した複数の処理装置グループのそれぞれに対応して設けられ、当該処理装置グループにおける各計算処理装置の電力消費指標情報を管理する。例えば、下階層管理装置40−1は、計算処理装置30−1及び計算処理装置30−2等を分類した処理装置グループ35−1に対応して設けられ、処理装置グループ35−1における各計算処理装置の電力消費指標情報を管理している。また、下階層管理装置40−1〜Mは、対応する処理装置グループにおいて消費される電力量が所定の基準量を超えた場合に、管理する計算処理装置のそれぞれにその旨を通知する。   The lower layer management devices 40-1 to 40-M are provided corresponding to each of the plurality of processing device groups into which the calculation processing devices 30-1 to 30-N are classified, and the power consumption index information of each calculation processing device in the processing device group. Manage. For example, the lower layer management device 40-1 is provided corresponding to the processing device group 35-1 in which the calculation processing device 30-1 and the calculation processing device 30-2 are classified, and each calculation in the processing device group 35-1 is performed. It manages the power consumption index information of the processing device. Further, when the amount of power consumed in the corresponding processing device group exceeds a predetermined reference amount, the lower layer management devices 40-1 to 40-M notify the management processing devices to that effect.

また、上階層管理装置50−1〜Lは、下階層管理装置40−1〜Mを分類した複数の管理装置グループのそれぞれに対応して設けられ、当該管理装置グループにおける各下階層管理装置が管理する電力消費指標情報の最大値及び最小値の間の値である電力処理総合情報を管理する。例えば、上階層管理装置50−1は、下階層管理装置40−1及び下階層管理装置40−2等を分類した管理装置グループ45−1に対応して設けられ、下階層管理装置40−1が管理する電力消費指標情報の最大値及び最小値の間の値と、下階層管理装置40−2が管理する電力消費指標情報の最大値及び最小値の間の値とを、電力処理総合情報として管理している。   The upper layer management devices 50-1 to 50-L are provided corresponding to the plurality of management device groups into which the lower layer management devices 40-1 to 40-M are classified, and each lower layer management device in the management device group is provided. It manages power processing comprehensive information that is a value between the maximum value and the minimum value of the power consumption index information to be managed. For example, the upper layer management device 50-1 is provided corresponding to the management device group 45-1 in which the lower layer management device 40-1, the lower layer management device 40-2, and the like are classified, and the lower layer management device 40-1 is provided. A value between the maximum value and the minimum value of the power consumption index information managed by the server and a value between the maximum value and the minimum value of the power consumption index information managed by the lower layer management apparatus 40-2 Manage as.

一例として、上階層管理装置50−1は、下階層管理装置40−1及び下階層管理装置40−2のそれぞれに対応付けて、電力処理総合情報として当該下階層管理装置が管理する電力処理指標情報の平均値を管理してもよい。これに代えて、上階層管理装置50−1は、電力処理総合情報として、電力処理指標情報の分散値又は標準偏差を管理してもよいし、度数分布等の統計情報を管理してもよい。   As an example, the upper tier management apparatus 50-1 is associated with each of the lower tier management apparatus 40-1 and the lower tier management apparatus 40-2, and is a power processing index managed by the lower tier management apparatus as power processing comprehensive information. An average value of information may be managed. Instead, the upper layer management apparatus 50-1 may manage the dispersion value or the standard deviation of the power processing index information as power processing comprehensive information, or may manage statistical information such as a frequency distribution. .

図2は、計算要求装置20のブロック図を示す。計算要求装置20は、電力処理指標情報取得手段200と、安定性情報取得手段205と、計算機環境データベース210と、部分計算要求手段215と、要求履歴情報格納手段220と、消費電力指標情報生成手段225と、消費電力指標情報格納手段230と、計算内容解析手段240と、条件情報取得手段250と、地域情報取得手段260と、電力料金情報生成手段270と、選択手段275と、処理結果出力手段280とを有する。   FIG. 2 shows a block diagram of the calculation requesting device 20. The calculation requesting device 20 includes a power processing index information acquisition unit 200, a stability information acquisition unit 205, a computer environment database 210, a partial calculation request unit 215, a request history information storage unit 220, and a power consumption index information generation unit. 225, power consumption index information storage means 230, calculation content analysis means 240, condition information acquisition means 250, area information acquisition means 260, power charge information generation means 270, selection means 275, and processing result output means. 280.

電力処理指標情報取得手段200は、計算処理装置30−1〜Nのそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を、上階層管理装置50−1〜Lを介して下階層管理装置40−1〜Mから取得し、計算機環境データベース210に格納する。更に、電力処理指標情報取得手段200は、計算処理装置30−1〜Nの何れかについての電力処理指標を処理結果出力手段280から受け取った場合に、当該電力処理指標により計算機環境データベース210中の情報を更新する。また、電力処理指標情報取得手段200は、電力処理総合情報を上階層管理装置50−1〜Lから取得して計算機環境データベース210に格納する。   The power processing index information acquisition unit 200 transmits power processing index information indicating power consumption per predetermined calculation processing amount for each of the calculation processing devices 30-1 to 30-N via the upper layer management devices 50-1 to 50-L. Acquired from the lower layer management apparatuses 40-1 to 40 -M and stored in the computer environment database 210. Furthermore, when the power processing index information acquisition unit 200 receives the power processing index for any of the calculation processing devices 30-1 to 30 -N from the processing result output unit 280, the power processing index information acquisition unit 200 stores the power processing index information in the computer environment database 210. Update information. Further, the power processing index information acquisition unit 200 acquires the power processing comprehensive information from the upper layer management devices 50-1 to 50 -L and stores it in the computer environment database 210.

安定性情報取得手段205は、計算処理装置30−1〜Nのそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得し、計算機環境データベース210に格納する。例えば、安定性情報取得手段205は、各計算処理装置が予め定められた複数の地域の何れに設けられているかを示す地域情報を、地域情報取得手段260から受け取り、当該地域情報に供給される電気の安定性を示す情報を安定性情報として上階層管理装置50−1〜Nから受け取り、計算機環境データベース210に格納する。   The stability information acquisition unit 205 acquires, for each of the calculation processing devices 30-1 to 30 -N, stability information indicating the stability of the power supplied to the calculation processing device, and stores it in the computer environment database 210. For example, the stability information acquisition unit 205 receives, from the region information acquisition unit 260, regional information indicating in which of the plurality of predetermined regions each calculation processing device is provided, and is supplied to the regional information. Information indicating the stability of electricity is received from the upper level management devices 50-1 to 50 -N as stability information and stored in the computer environment database 210.

これに代えて、電力処理指標情報取得手段200及び安定性情報取得手段205は、下位階層管理装置及び上位階層管理装置を介することなく計算処理装置30−1〜Nのそれぞれから電力処理指標情報及び安定性情報のそれぞれを取得してもよい。   Instead of this, the power processing index information acquisition unit 200 and the stability information acquisition unit 205 receive power processing index information and information from each of the calculation processing devices 30-1 to 30-N without going through the lower layer management device and the upper layer management device. Each of the stability information may be acquired.

要求履歴情報格納手段220は、当該計算要求装置20が既に行わせた計算処理の種類に、当該計算処理を行った計算処理装置の組を識別する情報を対応付けた情報を格納する。例えば、計算処理の種類とは、当該計算処理により行われる計算の性質を示す情報であり、一例として、当該計算処理が実行された場合に呼び出されるオペレーティングシステムのAPIにより定められる。   The request history information storage unit 220 stores information in which information for identifying a set of calculation processing devices that have performed the calculation processing is associated with the type of calculation processing that has already been performed by the calculation requesting device 20. For example, the type of calculation process is information indicating the nature of the calculation performed by the calculation process, and is determined by an API of an operating system that is called when the calculation process is executed.

部分計算要求手段215は、実行するべき計算処理700を利用者から取得すると、計算処理700の種類に基づいて、計算処理700の当該種類に対応付けられた計算処理装置の組を識別する情報を、要求履歴情報格納手段220から検索する。検索できた場合に、部分計算要求手段215は、検索した当該計算処理装置の組に計算処理700を行わせる。検索できなかった場合に、部分計算要求手段215は、その旨を消費電力指標情報生成手段225に送る。   When the partial calculation request unit 215 obtains the calculation process 700 to be executed from the user, the partial calculation request unit 215 obtains information for identifying a set of calculation processing devices associated with the type of the calculation process 700 based on the type of the calculation process 700. The request history information storage means 220 is searched. If the search is successful, the partial calculation requesting unit 215 causes the searched set of calculation processing devices to perform the calculation process 700. If the search is not successful, the partial calculation request unit 215 sends a message to that effect to the power consumption index information generation unit 225.

そして、部分計算要求手段215は、複数の部分計算のそれぞれを、選択手段275により当該部分計算に対応付けて選択された計算処理装置に実行させるべく、当該計算処理装置に送信する。これに代えて、部分計算要求手段215は、複数の部分計算のそれぞれを、下階層管理装置40−1〜M及び上階層管理装置50−1〜Lを介して計算処理装置のそれぞれに送信してもよい。   Then, the partial calculation request unit 215 transmits each of the plurality of partial calculations to the calculation processing device so that the selection processing unit 275 causes the calculation processing device selected in association with the partial calculation to execute. Instead, the partial calculation requesting unit 215 transmits each of the plurality of partial calculations to each of the calculation processing devices via the lower layer management devices 40-1 to M and the upper layer management devices 50-1 to L. May be.

更に、部分計算要求手段215は、複数の部分計算のそれぞれについて、当該部分計算を実行させる計算処理装置を識別する情報を、処理結果出力手段280に送る。また、部分計算要求手段215は、複数の部分計算により構成される計算処理の種類を、複数の部分計算を実行する計算処理装置の組に対応付けて要求履歴情報格納手段220に格納する。   Further, the partial calculation requesting unit 215 sends, to each of the plurality of partial calculations, information for identifying a calculation processing device that executes the partial calculation, to the processing result output unit 280. Further, the partial calculation request unit 215 stores the types of calculation processes constituted by a plurality of partial calculations in the request history information storage unit 220 in association with a set of calculation processing devices that execute a plurality of partial calculations.

消費電力指標情報格納手段230は、部分計算の種類を、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報に対応付けて格納する。   The power consumption index information storage unit 230 associates the type of partial calculation with power consumption index information indicating the amount of power required for the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device. Store.

部分計算要求手段215が計算処理装置の組を識別する情報を要求履歴情報格納手段220から検索できなかった場合に、消費電力指標情報生成手段225は、利用者から取得した計算処理700を複数の部分計算に分割する。複数の部分計算のそれぞれについて、当該部分計算の種類が消費電力指標情報格納手段230に格納されている場合において、消費電力指標情報生成手段225は、当該部分計算の種類に対応付けられた消費電力指標情報を消費電力指標情報格納手段230から選択する。   When the partial calculation requesting unit 215 cannot search the request history information storage unit 220 for information for identifying a set of calculation processing devices, the power consumption index information generating unit 225 executes the calculation processing 700 acquired from the user by a plurality of calculation processes 700. Divide into partial calculations. For each of the partial calculations, when the type of the partial calculation is stored in the power consumption index information storage unit 230, the power consumption index information generation unit 225 uses the power consumption associated with the type of the partial calculation. The index information is selected from the power consumption index information storage unit 230.

一方、当該部分計算の種類が消費電力指標情報格納手段230に格納されていない場合において、消費電力指標情報生成手段225は、当該部分計算を計算内容解析手段240に送る。そして、消費電力指標情報生成手段225は、計算内容解析手段240から受け取った解析結果に基づいて消費電力指標情報を生成し、選択手段275に送る。また、消費電力指標情報生成手段225は、当該部分計算の種類を、生成した消費電力指標に対応付けて消費電力指標情報格納手段230に格納する。   On the other hand, when the type of the partial calculation is not stored in the power consumption index information storage unit 230, the power consumption index information generation unit 225 sends the partial calculation to the calculation content analysis unit 240. Then, the power consumption index information generation unit 225 generates power consumption index information based on the analysis result received from the calculation content analysis unit 240 and sends it to the selection unit 275. Further, the power consumption index information generating unit 225 stores the type of partial calculation in the power consumption index information storage unit 230 in association with the generated power consumption index.

計算内容解析手段240は、消費電力指標情報生成手段225から受け取った部分計算について、当該部分計算の処理内容を解析し、消費電力指標情報生成手段225に返送する。また、計算内容解析手段240は、当該部分計算が計算処理のクリティカルパスに含まれるか否かを解析したクリティカルパス情報を生成し、選択手段275に送る。ここで、クリティカルパスとは、複数の部分計算のうち、互いに実行順序が定まっており並列に実行不能な部分計算の組のうち、計算の所要時間が最も長い部分計算の組をいう。   The calculation content analysis unit 240 analyzes the processing content of the partial calculation received from the power consumption index information generation unit 225 and returns it to the power consumption index information generation unit 225. Further, the calculation content analysis unit 240 generates critical path information obtained by analyzing whether or not the partial calculation is included in the critical path of the calculation process, and sends the critical path information to the selection unit 275. Here, the critical path refers to a group of partial calculations having the longest time required for the calculation among a plurality of partial calculations whose execution order is fixed and cannot be executed in parallel.

条件情報取得手段250は、計算処理装置30−1〜Nが複数の部分計算を実行する場合に消費する電力量が満たすべき電力量条件情報と、計算処理装置30−1〜Nが複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報とを利用者から取得し、選択手段275に送る。   The condition information acquisition unit 250 includes power amount condition information that should be satisfied when the calculation processing devices 30-1 to 30-N execute a plurality of partial calculations, and the calculation processing devices 30-1 to 30-N include a plurality of portions. Stability condition information indicating the condition of the stability of electricity received when the calculation is executed is acquired from the user and sent to the selection means 275.

地域情報取得手段260は、計算処理装置30−1〜Nのそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を、上階層管理装置50−1〜Nから取得し、安定性情報取得手段205、電力料金情報生成手段270、及び選択手段275に送る。   The area information acquisition unit 260 receives area information indicating which of the plurality of predetermined areas each of the calculation processing apparatuses 30-1 to 30-N is provided from the upper layer management apparatuses 50-1 to 50-N. The information is acquired and sent to the stability information acquisition unit 205, the power rate information generation unit 270, and the selection unit 275.

電力料金情報生成手段270は、計算処理装置30−1〜Nのそれぞれについて、当該計算処理装置の消費電力当たりの電力料金を示す電力料金情報を、地域情報取得手段260から受け取った地域情報に基づいて生成し、選択手段275に送る。   The power charge information generating unit 270 is configured to calculate, for each of the calculation processing devices 30-1 to 30 -N, the power charge information indicating the power charge per power consumption of the calculation processing device from the regional information acquisition unit 260. And is sent to the selection means 275.

選択手段275は、複数の部分計算のそれぞれに対応付けて、計算処理装置30−1〜Nのうち当該部分計算を実行する場合に電力量条件情報及び安定性条件情報を満たす計算処理装置を、電力処理指標情報、安定性情報、消費電力指標情報、クリティカルパス情報、地域情報、及び電力料金情報に基づいて選択し、選択結果を部分計算要求手段215に送る。   The selection unit 275 associates each of the plurality of partial calculations with a calculation processing device that satisfies the power amount condition information and the stability condition information when executing the partial calculation among the calculation processing devices 30-1 to 30-N. Selection is made based on the power processing index information, stability information, power consumption index information, critical path information, area information, and power charge information, and the selection result is sent to the partial calculation request means 215.

より具体的には、選択手段275は、下階層管理装置40−1〜M及び上階層管理装置50−1〜Lが管理する電力処理指標情報及び電力処理総合情報を用いて、以下の手順により計算処理装置を選択してもよい。まず、選択手段275は、管理する電力処理総合情報の何れかが電力量条件情報及び安定性条件情報を満たす上階層管理装置、例えば、上階層管理装置50−1を選択する。そして、選択手段275は、上階層管理装置50−1により管理される下階層管理装置のうち、管理する電力処理指標情報の何れかが電力量条件情報及び安定性条件情報を満たす下階層管理装置、例えば、下階層管理装置40−1を選択する。更に、選択手段275は、下階層管理装置40−1により管理される計算処理装置のうち、電力量条件情報及び安定性条件情報を満たす計算処理装置、例えば、計算処理装置30−1を選択する。
これにより、計算処理装置30−1〜Nが膨大な数である場合であっても、適切な計算処理装置を効率的に検索することができる。
More specifically, the selection unit 275 uses the power processing index information and the power processing general information managed by the lower layer management devices 40-1 to M and the upper layer management devices 50-1 to L according to the following procedure. A computing device may be selected. First, the selection unit 275 selects an upper layer management device, for example, the upper layer management device 50-1, in which any of the power processing comprehensive information to be managed satisfies the power amount condition information and the stability condition information. And the selection means 275 is a lower hierarchy management apparatus in which any of the power processing index information to be managed satisfies the power amount condition information and the stability condition information among the lower hierarchy management apparatuses managed by the upper hierarchy management apparatus 50-1. For example, the lower layer management apparatus 40-1 is selected. Further, the selection unit 275 selects a calculation processing device that satisfies the power amount condition information and the stability condition information, for example, the calculation processing device 30-1 among the calculation processing devices managed by the lower layer management device 40-1. .
Thereby, even if it is a case where there are a huge number of calculation processing devices 30-1 to 30-N, it is possible to efficiently search for an appropriate calculation processing device.

処理結果出力手段280は、複数の部分計算を実行する計算処理装置を識別する情報を部分計算要求手段215から受け取る。そして、処理結果出力手段280は、これらの計算処理装置から受け取った部分計算の結果の組を、計算処理700の結果として利用者に出力する。これに加えて、処理結果出力手段280は、受け取った部分計算の結果の組を用いて更に計算をした結果を計算処理700の結果として出力してもよい。   The processing result output means 280 receives from the partial calculation request means 215 information for identifying a calculation processing device that executes a plurality of partial calculations. Then, the processing result output means 280 outputs a set of partial calculation results received from these calculation processing devices to the user as a result of the calculation processing 700. In addition to this, the processing result output means 280 may output the result of further calculation using the received set of partial calculation results as the result of the calculation processing 700.

また、処理結果出力手段280は、各部分計算が処理された場合に実際に消費された電力量を示す電力実消費量情報を、当該部分計算を実行した計算処理装置を識別する情報に対応付けて計算処理装置30−1〜Nから取得し、電力処理指標情報取得手段200に送る。これに加えて、処理結果出力手段280は、計算処理装置を識別する情報に対応付けて電力実消費量情報を利用者に対して出力してもよい。この場合、利用者は、例えば所定の地域で使用される総電力量を知ることができる。これにより、利用者は電気事業者との契約内容が、現状の総電力量と比較して適切か否かを判断し、必要に応じて契約変更することができる。   Further, the processing result output means 280 associates the actual power consumption information indicating the amount of power actually consumed when each partial calculation is processed with the information for identifying the calculation processing device that has executed the partial calculation. Are acquired from the calculation processing devices 30-1 to 30 -N and sent to the power processing index information acquisition means 200. In addition, the processing result output unit 280 may output the actual power consumption information to the user in association with information for identifying the calculation processing device. In this case, the user can know the total amount of power used in a predetermined area, for example. As a result, the user can determine whether or not the content of the contract with the electric power company is appropriate as compared with the current total amount of power, and can change the contract as necessary.

図3は、計算処理装置30−1のブロック図を示す。計算処理装置30−1は、部分計算処理手段300と、処理結果送信手段310と、実消費量送信手段320と、部分計算再割当手段330とを有する。なお、計算処理装置30−2〜Nのそれぞれは、計算処理装置30−1と略同一の構成を取るので、相違する点についてのみ説明する。   FIG. 3 is a block diagram of the calculation processing device 30-1. The calculation processing device 30-1 includes a partial calculation processing unit 300, a processing result transmission unit 310, an actual consumption transmission unit 320, and a partial calculation reassignment unit 330. Since each of the calculation processing devices 30-2 to 30-N has substantially the same configuration as the calculation processing device 30-1, only the differences will be described.

部分計算処理手段300は、計算要求装置20から要求された部分計算を処理し、処理結果を処理結果送信手段310に送る。これを受けて、処理結果送信手段310は、部分計算の処理結果を計算要求装置20に送信する。また、実消費量送信手段320は、部分計算処理手段300が部分計算を処理した場合に消費した電力量を示す電力実消費量情報を、部分計算処理手段300の処理内容を解析することにより生成し、当該部分計算を識別する情報に対応付けて計算要求装置20に送信する。   The partial calculation processing unit 300 processes the partial calculation requested from the calculation requesting device 20 and sends the processing result to the processing result transmission unit 310. In response to this, the processing result transmission unit 310 transmits the processing result of the partial calculation to the calculation requesting device 20. Further, the actual consumption amount transmitting unit 320 generates power actual consumption amount information indicating the amount of power consumed when the partial calculation processing unit 300 processes the partial calculation by analyzing the processing content of the partial calculation processing unit 300. Then, it is transmitted to the calculation requesting device 20 in association with the information for identifying the partial calculation.

電力実消費量情報を生成する処理の一例を以下に示す。まず、実消費量送信手段320は、電力消費量測定用の所定のプログラムにより、当該部分計算が実行された期間における計算処理装置30−1の電力消費量を測定する。そして、実消費量送信手段320は、オペレーティングシステムの統計情報を参照することにより、計算処理装置30−1全体の処理によりCPUが使用された時間に対する当該部分計算によりCPUが使用された時間の割合を特定する。これにより、実消費量送信手段320は、部分計算により使用された電力消費量を概算し、電力実消費量情報として生成することができる。   An example of processing for generating actual power consumption information is shown below. First, the actual consumption amount transmitting unit 320 measures the power consumption amount of the calculation processing device 30-1 in the period in which the partial calculation is executed by a predetermined program for measuring the power consumption amount. Then, the actual consumption transmission means 320 refers to the statistical information of the operating system, and thereby the ratio of the time when the CPU is used by the partial calculation to the time when the CPU is used by the processing of the entire calculation processing device 30-1. Is identified. As a result, the actual consumption transmission means 320 can estimate the power consumption used by the partial calculation and generate it as the actual power consumption information.

また、電力消費量についての上記測定方法は一例であり、他の方法を用いてもよい。例えば、実消費量送信手段320は、オペレーティングシステムにおいて定められたAPIを用いて電力実消費量情報を生成してもよいし、BIOSにおいて定められたシステムコールを用いて電力実消費量情報を生成してもよい。更に、計算処理装置30−2〜Nのそれぞれは、計算処理装置30−1とは異なる方法により電力実消費量情報を生成してもよい。   Moreover, the said measuring method about electric power consumption is an example, You may use another method. For example, the actual consumption transmission means 320 may generate the actual power consumption information using an API defined in the operating system, or generate the actual power consumption information using a system call defined in the BIOS. May be. Further, each of the calculation processing devices 30-2 to 30-N may generate the actual power consumption information by a method different from that of the calculation processing device 30-1.

部分計算再割当手段330は、下階層管理装置40−1からの通知を受けて、計算処理装置30−1が設けられた地域の総消費電力が、当該地域における最大供給可能電力のうち予め定められた基準割合に達したか否かを判断する。部分計算再割当手段330は、当該地域の総消費電力が基準割合に達したと判断した場合に、部分計算処理手段300に部分計算の処理を中止させ、部分計算処理手段300において処理する部分計算を部分計算処理手段300から取得する。そして、部分計算再割当手段330は、当該部分計算を、当該地域とは異なる地域に設けられた他の計算処理装置、例えば、計算処理装置30−Nにおいて実行させるべく、下階層管理装置40−1に送信する。これを受けて、下階層管理装置40−1は、上階層管理装置50−1及び下階層管理装置40−2を介して、計算処理装置30−Nに部分計算を送信する。   In response to the notification from the lower layer management apparatus 40-1, the partial calculation reassignment unit 330 determines in advance the total power consumption in the area where the calculation processing apparatus 30-1 is provided among the maximum suppliable power in the area. It is determined whether or not the specified standard ratio has been reached. When the partial calculation reassignment unit 330 determines that the total power consumption of the area has reached the reference ratio, the partial calculation processing unit 300 causes the partial calculation processing unit 300 to stop the partial calculation processing, and the partial calculation processing unit 300 processes the partial calculation. Is obtained from the partial calculation processing means 300. Then, the partial calculation reassignment unit 330 executes the partial calculation in another calculation processing device provided in a region different from the region, for example, the calculation processing device 30-N. 1 to send. In response to this, the lower hierarchy management device 40-1 transmits the partial calculation to the calculation processing device 30-N via the upper hierarchy management device 50-1 and the lower hierarchy management device 40-2.

以上、図1から図3において示したように、分散コンピューティングシステム10は、所定の計算処理を構成する複数の部分計算のそれぞれを実行する計算処理装置のそれぞれを、所定の計算処理量当たりの消費電力を示す電力処理指標情報及び当該計算処理装置に供給される電力の安定性を示す安定性情報を満たすように選択する。これにより、消費電力量の条件を満たすと共に、計算処理を高速かつ高効率に実行することができる。   As described above, as illustrated in FIGS. 1 to 3, the distributed computing system 10 allows each of the computing devices that execute each of the plurality of partial calculations constituting the predetermined calculation process to be performed per predetermined calculation processing amount. Selection is made so as to satisfy the power processing index information indicating the power consumption and the stability information indicating the stability of the power supplied to the calculation processing device. Thereby, while satisfy | filling the conditions of power consumption, a calculation process can be performed at high speed and highly efficient.

図4は、分散コンピューティングシステム10が計算処理を実行する動作フローを示す。電力処理指標情報取得手段200は、計算処理装置30−1〜Nのそれぞれについて電力処理指標情報を取得する(S400)。例えば、電力処理指標情報取得手段200は、各計算処理装置の電力処理指標情報として、当該計算処理装置のCPU、ハードディスクドライブ、及び入出力装置の少なくとも一について、所定の処理量あたりの消費電力を示す性能情報を取得する。   FIG. 4 shows an operation flow in which the distributed computing system 10 executes calculation processing. The power processing index information acquisition unit 200 acquires power processing index information for each of the calculation processing devices 30-1 to 30-N (S400). For example, the power processing index information acquisition unit 200 uses the power consumption per predetermined processing amount for at least one of the CPU, the hard disk drive, and the input / output device of the calculation processing apparatus as the power processing index information of each calculation processing apparatus. Get the performance information shown.

具体的には、電力処理指標情報取得手段200は、性能情報としてCPUの熱設計消費電力(TDP:Thermal Design Power)及びCPUの種類を示す情報を取得してもよい。これにより、計算要求装置20は、電力処理指標情報として、CPU1クロック当たりの消費電力を見積もることができる。   Specifically, the power processing index information acquisition unit 200 may acquire information indicating the thermal design power consumption (TDP: Thermal Design Power) of the CPU and the type of CPU as performance information. Thereby, the calculation request | requirement apparatus 20 can estimate the power consumption per CPU 1 clock as power process parameter | index information.

例えば、インテルコーポレーションのPentium(登録商標)4プロセッサ(Northwood)において、動作周波数の互いに異なる複数の種類のプロセッサは、互いに異なるTDPを有している。一例として、3.0Ghz動作のプロセッサにおいて、TDPは81.9Wであり、2.4Ghz動作のプロセッサにおいて、TDPは57.8Wである。従って、3.0Ghz動作のプロセッサにおいて、1Ghz当たりの消費電力は27.3Wであり、2.4Ghz動作のプロセッサにおいて、1Ghz当たりの消費電力は24.1Wである。このように、電力処理指標情報取得手段200が、電力処理指標情報として、CPUのTDP及び種類の組を取得することにより、計算要求装置20は、1クロック当たりの消費電力を見積もることができる。   For example, in the Pentium (registered trademark) 4 processor (Northwood) of Intel Corporation, a plurality of types of processors having different operating frequencies have different TDPs. As an example, in a processor operating at 3.0 Ghz, the TDP is 81.9 W, and in a processor operating at 2.4 Ghz, the TDP is 57.8 W. Therefore, in the 3.0 Ghz operation processor, the power consumption per 1 Ghz is 27.3 W, and in the 2.4 Ghz operation processor, the power consumption per 1 Ghz is 24.1 W. As described above, the power processing index information acquisition unit 200 acquires the CPU TDP and type set as the power processing index information, so that the calculation requesting device 20 can estimate the power consumption per clock.

また、電力処理指標情報取得手段200は、電力処理指標情報として、計算処理装置30−1〜Nのそれぞれが所定量の計算を行った場合における、当該計算処理装置の消費電力及び当該計算処理装置が接続されたネットワーク機器の消費電力の合計を取得してもよい。即ち、電力処理指標情報とは、計算処理装置のみの消費電力に限定されず、計算要求装置20から要求された計算を計算処理装置が行い計算結果を送信する一連の処理における消費電力である。   In addition, the power processing index information acquisition unit 200 uses the power consumption of the calculation processing apparatus and the calculation processing apparatus when the calculation processing apparatuses 30-1 to 30-N perform a predetermined amount of calculation as the power processing index information. You may acquire the sum total of the power consumption of the network apparatus to which is connected. That is, the power processing index information is not limited to the power consumption of only the calculation processing device, but is the power consumption in a series of processes in which the calculation processing device performs the calculation requested from the calculation requesting device 20 and transmits the calculation result.

安定性情報取得手段205は、計算処理装置30−1〜Nのそれぞれについて安定性情報を取得する(S410)。例えば、安定性情報取得手段205は、単位時間の瞬断発生平均回数に、平均瞬断時間を乗じた値を、安定性情報として上階層管理装置50−1〜Nから取得する。また、安定性情報取得手段205は、地域情報取得手段260から取得した地域情報に基づいて、計算処理装置30−1〜Nのそれぞれが設けられている地域における電力の安定性を示す情報を安定性情報として取得してもよい。   The stability information acquisition unit 205 acquires stability information for each of the calculation processing devices 30-1 to 30-N (S410). For example, the stability information acquisition unit 205 acquires a value obtained by multiplying the average number of instantaneous interruption occurrences per unit time by the average instantaneous interruption time from the upper hierarchy management devices 50-1 to 50 -N as the stability information. Further, the stability information acquisition unit 205 stabilizes information indicating the power stability in the area where each of the calculation processing devices 30-1 to 30 -N is provided based on the area information acquired from the area information acquisition unit 260. It may be acquired as sex information.

更に、安定性情報取得手段205は、各計算処理装置における安定性情報として、当該計算処理装置が電池又は発電機による無停電電源装置により管理されているか否かを示す情報を取得してもよい。この場合、選択手段275は、無停電電源装置により管理されている計算処理装置を、無停電電源装置により管理されていない計算処理装置と比較して電力の安定性が高い計算処理装置であると判断することができる。   Furthermore, the stability information acquisition unit 205 may acquire information indicating whether or not the calculation processing device is managed by an uninterruptible power supply using a battery or a generator as stability information in each calculation processing device. . In this case, the selection means 275 is a calculation processing device with high power stability compared to a calculation processing device managed by the uninterruptible power supply device compared to a calculation processing device not managed by the uninterruptible power supply device. Judgment can be made.

部分計算要求手段215は、実行するべき計算処理700を利用者から取得すると(S420)、計算処理700の種類に基づいて、計算処理700の当該種類に対応付けられた計算処理装置の組を識別する情報を、要求履歴情報格納手段220から検索する(S430)。   When the partial calculation requesting unit 215 obtains the calculation process 700 to be executed from the user (S420), the partial calculation requesting unit 215 identifies a set of calculation processing devices associated with the type of the calculation process 700 based on the type of the calculation process 700. Information to be searched is retrieved from the request history information storage means 220 (S430).

検索できた場合、即ち、計算処理700の種類が、計算要求装置20により既に処理したことのある種類である場合に(S440:YES)、部分計算要求手段215は、検索した当該計算処理装置の組に計算処理700を行わせ(S450)、処理を終了する。これにより、計算要求装置20は、同一の種類の計算処理を繰り返し行う場合に、部分計算を実行させるべき計算処理装置を選択する処理を省いて効率的に動作することができる。例えば、パラメータの一部のみが互いに異なる複数の計算処理を繰り返す場合、一例として、モンテカルロシュミレーションを行う場合において、効率的である。   When the search is successful, that is, when the type of the calculation processing 700 is a type that has already been processed by the calculation requesting device 20 (S440: YES), the partial calculation requesting unit 215 determines that the searched calculation processing device The set is subjected to the calculation process 700 (S450), and the process is terminated. As a result, the calculation requesting apparatus 20 can efficiently operate by omitting the process of selecting a calculation processing apparatus on which partial calculation is to be performed when repeatedly performing the same type of calculation processing. For example, when a plurality of calculation processes in which only some of the parameters are different from each other are repeated, for example, when performing Monte Carlo simulation, it is efficient.

検索できなかった場合、即ち、計算処理700の種類が、計算要求装置20により未だ処理したことのない種類である場合に(S440:NO)、消費電力指標情報生成手段225は、計算処理700を複数の部分計算に分割する(S460)。続いて、計算要求装置20は、複数の部分計算のそれぞれについて、以下の処理を実行する(S470)。   When the search cannot be performed, that is, when the type of the calculation process 700 is a type that has not yet been processed by the calculation requesting device 20 (S440: NO), the power consumption index information generation unit 225 executes the calculation process 700. Dividing into a plurality of partial calculations (S460). Subsequently, the calculation requesting apparatus 20 executes the following processing for each of the plurality of partial calculations (S470).

消費電力指標情報生成手段225は、当該部分計算の種類が消費電力指標情報格納手段230に格納されている場合に(S480:YES)、当該部分計算の種類に対応付けられて格納されている消費電力指標情報を消費電力指標情報格納手段230から取得する(S490)。一方、消費電力指標情報生成手段225は、当該部分計算の種類が消費電力指標情報格納手段230に格納されていない場合に(S480:NO)、消費電力指標情報を生成する(S485)。詳細については後述する。
計算要求装置20は、以上の処理を複数の部分計算のそれぞれについて実行する(S495)。
When the partial calculation type is stored in the power consumption index information storage unit 230 (S480: YES), the power consumption index information generation unit 225 stores the consumption stored in association with the partial calculation type. The power index information is acquired from the power consumption index information storage unit 230 (S490). On the other hand, the power consumption index information generation means 225 generates power consumption index information when the partial calculation type is not stored in the power consumption index information storage means 230 (S480: NO) (S485). Details will be described later.
The calculation requesting device 20 executes the above processing for each of the plurality of partial calculations (S495).

図5は、分散コンピューティングシステム10における図4に続く動作フローを示す。条件情報取得手段250は、計算処理装置30−1〜Nが複数の部分計算を実行する場合に消費する電力量が満たすべき電力量条件情報と、計算処理装置30−1〜Nが複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報とを利用者から取得する(S500)。   FIG. 5 shows an operation flow subsequent to FIG. 4 in the distributed computing system 10. The condition information acquisition unit 250 includes power amount condition information that should be satisfied when the calculation processing devices 30-1 to 30-N execute a plurality of partial calculations, and the calculation processing devices 30-1 to 30-N include a plurality of portions. Stability condition information indicating the condition of the stability of electricity received when the calculation is executed is acquired from the user (S500).

例えば、条件情報取得手段250は、電力量条件情報として、所定の地域に設けられた複数の計算処理装置における単位時間当たりに消費する電力の上限を定める電力上限値を取得する。これに代えて、条件情報取得手段250は、電力量条件情報として、計算処理を開始してから終了するまでに消費される総消費電力の上限値を取得してもよい。また、条件情報取得手段250は、計算処理のクリティカルパスの実行時間が所定時間以内となる条件の下、消費電力を所定量以下とする電力量条件情報を取得してもよいし、電気料金を所定以下とする電力量条件情報を取得してもよい。   For example, the condition information acquisition unit 250 acquires a power upper limit value that defines an upper limit of power consumed per unit time in a plurality of calculation processing devices provided in a predetermined region as the power amount condition information. Instead of this, the condition information acquisition unit 250 may acquire the upper limit value of the total power consumption consumed from the start to the end of the calculation process as the power amount condition information. In addition, the condition information acquisition unit 250 may acquire the power amount condition information that sets the power consumption to a predetermined amount or less under the condition that the execution time of the critical path of the calculation process is within a predetermined time, You may acquire the electric energy condition information made into below predetermined.

地域情報取得手段260は、計算処理装置30−1〜Nのそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する(S510)。例えば、地域情報取得手段260は、計算処理装置30−1〜Nのそれぞれにおける地域情報として、当該計算処理装置が設けられている国家を示す情報、当該計算処理装置に電力を供給する電力会社を示す情報、当該計算処理装置が所属するネットワークのドメインを示す情報、当該計算処理装置が設けられる建造物を示す情報、若しくは当該計算処理装置が設けられるフロア又は部屋を示す情報を取得してもよい。   The area information acquisition unit 260 acquires area information indicating which of the plurality of predetermined areas each of the calculation processing devices 30-1 to 30-N is provided (S510). For example, the regional information acquisition unit 260 includes, as regional information in each of the calculation processing devices 30-1 to 30-N, information indicating the country in which the calculation processing device is provided, and a power company that supplies power to the calculation processing device. Information indicating a network domain to which the calculation processing device belongs, information indicating a building in which the calculation processing device is provided, or information indicating a floor or a room in which the calculation processing device is provided may be acquired. .

電力料金情報生成手段270は、計算処理装置30−1〜Nのそれぞれについて、当該計算処理装置に消費電力当たりの電力料金を示す電力料金情報を、地域情報に基づいて生成する(S520)。例えば、電力料金情報生成手段270は、計算処理が行われる時間帯及び地域情報により定まる地域のタイムゾーンに基づいて、計算処理が行われる時間帯が当該地域において昼間及び夜間の何れであるかを特定し、計算処理装置30−1〜Nのそれぞれに対応付けて電気料金情報を生成する。より具体的には、電力料金情報生成手段270は、NTPサーバから取得した現在時刻を、計算処理が行われる時間帯として取得してもよい。また、電力料金情報生成手段270は、国家又は地域毎に対応付けて時差を記録したデータベースに基づいて、地域情報により定まる地域のタイムゾーンを定めてもよい。   The power charge information generation unit 270 generates power charge information indicating the power charge per power consumption for each of the calculation processing devices 30-1 to 30-N based on the regional information (S520). For example, based on the time zone in which the calculation process is performed and the time zone of the region determined by the region information, the power rate information generation unit 270 determines whether the time zone in which the calculation process is performed is daytime or nighttime in the region. The electricity bill information is generated in association with each of the calculation processing devices 30-1 to 30-N. More specifically, the power rate information generation unit 270 may acquire the current time acquired from the NTP server as a time zone during which the calculation process is performed. In addition, the power rate information generation unit 270 may determine a time zone of a region determined by the region information based on a database in which a time difference is recorded in association with each country or region.

選択手段275は、複数の部分計算のそれぞれに対応付けて、計算処理装置30−1〜Nのうち当該部分計算を実行する場合に電力量条件情報及び安定性条件情報を満たす計算処理装置を、電力処理指標情報、安定性情報、消費電力指標情報、地域情報、及び電力料金情報に基づいて選択する(S525)。選択方法の例を以下に示す。   The selection unit 275 associates each of the plurality of partial calculations with a calculation processing device that satisfies the power amount condition information and the stability condition information when executing the partial calculation among the calculation processing devices 30-1 to 30-N. A selection is made based on power processing index information, stability information, power consumption index information, area information, and power rate information (S525). An example of the selection method is shown below.

条件情報取得手段250が、電力量条件情報として所定の地域に設けられた複数の計算処理装置における電力上限値を取得した場合において、選択手段275は、当該所定の地域における複数の計算処理装置が複数の部分計算を処理することにより単位時間当たりに消費する電力が、条件情報取得手段250が取得した電力上限値(例えば、ワット数で指定される値)以下である場合に、複数の部分計算のそれぞれに対応付けて、当該所定の地域における複数の計算処理装置を選択してもよい。   When the condition information acquisition unit 250 acquires the power upper limit value in a plurality of calculation processing devices provided in a predetermined region as the power amount condition information, the selection unit 275 indicates that the plurality of calculation processing devices in the predetermined region When the power consumed per unit time by processing a plurality of partial calculations is less than or equal to the power upper limit value acquired by the condition information acquisition unit 250 (for example, a value specified by wattage), the plurality of partial calculations are performed. A plurality of calculation processing devices in the predetermined area may be selected in association with each of the above.

この場合、好ましくは、条件情報取得手段250は、電力上限値に代えて、当該電力上限値から所定量減じた値を、当該所定の地域において消費可能な電力量とする。即ち、選択手段275は、単位時間当たりに消費する電力が、電力上限値から所定量減じた値以下である場合に、当該所定の地域における複数の計算処理装置を選択することが好ましい。これにより、電力処理指標情報又は消費電力指標情報が、実際の消費電力と比較した誤差を有している場合であっても、実際の消費電力が電力上限値を上回ることを防ぐことができる。   In this case, preferably, the condition information acquisition unit 250 sets a value obtained by subtracting a predetermined amount from the power upper limit value instead of the power upper limit value as a power amount that can be consumed in the predetermined area. That is, when the power consumed per unit time is equal to or less than a value obtained by subtracting a predetermined amount from the power upper limit value, the selection unit 275 preferably selects a plurality of calculation processing devices in the predetermined area. Thereby, even if the power processing index information or the power consumption index information has an error compared with the actual power consumption, it is possible to prevent the actual power consumption from exceeding the power upper limit value.

他の例として、選択手段275は、複数の部分計算のそれぞれを実行させる計算処理装置として、計算処理装置が設けられる地域において部分計算要求手段215が部分計算を要求する時刻が夜間である計算処理装置を、当該時刻が昼間である計算処理装置より優先して選択する。これにより、夜間に余剰する電力を有効に利用できると共に、分散コンピューティングシステム10全体における電気料金を節約することができる。ここで、夜間とは、電力を供給する事業者により定められた、夜間用電気料金が適用される時間帯をいう。また、昼間とは、昼間用電気料金が適用される時間帯をいう。また、夜間と昼間による区別は一例であり、選択手段275は、所定の地域における電力消費量がより少ない時間帯である計算処理装置を、電力消費量がより多い時間帯である計算処理装置より優先して選択すればよい。   As another example, the selection unit 275 is a calculation processing device that executes each of a plurality of partial calculations. In the area where the calculation processing device is provided, the calculation processing in which the partial calculation request unit 215 requests partial calculation is nighttime. A device is selected in preference to a calculation processing device whose time is daytime. This makes it possible to effectively use the surplus power at night and to save the electricity bill in the distributed computing system 10 as a whole. Here, the night refers to a time zone in which a night electricity charge is applied, which is determined by a company that supplies power. In addition, daytime means a time zone in which daytime electricity charges are applied. In addition, the distinction between nighttime and daytime is an example, and the selection unit 275 is configured so that the calculation processing device in the time zone in which power consumption in the predetermined area is smaller than the calculation processing device in the time zone in which power consumption is higher. You should select with priority.

更に他の例として、選択手段275は、電力量条件情報及び安定性条件情報を満たす計算処理装置のうち、クリティカルパスに含まれない部分計算に対応付けて選択する計算処理装置と比較して、電力処理指標情報の示す消費電力量がより大きくかつ処理速度がより速い計算処理装置を、計算処理のクリティカルパスに含まれる部分計算に対応付けて選択する。これにより、クリティカルパス内の計算については、消費電力が大きい場合であっても迅速に処理することができるので、電力量条件情報及び安定性条件情報を満たしつつ処理を高速化することができる。   As yet another example, the selection unit 275 compares the calculation processing device that satisfies the power amount condition information and the stability condition information with a calculation processing device that selects and matches the partial calculation that is not included in the critical path. A calculation processing device having a larger power consumption and a faster processing speed indicated by the power processing index information is selected in association with the partial calculation included in the critical path of the calculation processing. As a result, the calculation in the critical path can be quickly processed even when the power consumption is large, so that the processing speed can be increased while satisfying the power amount condition information and the stability condition information.

また、選択手段275は、計算処理装置のクリティカルパスに含まれる部分計算に対応付けて、当該クリティカルパスに含まれない部分計算に対応付けて選択する計算処理装置と比較して、安定性情報の示す安定性がより大きい計算処理装置を選択する。これにより、電力の瞬断等に起因する計算の中断又は再計算により、計算処理の完了が遅延することを防ぐことができる。   In addition, the selecting unit 275 associates the stability information with the partial calculation included in the critical path of the calculation processing device, as compared with the calculation processing device selected in association with the partial calculation not included in the critical path. Select a computing device that exhibits greater stability. Thereby, it is possible to prevent the completion of the calculation process from being delayed due to the interruption or recalculation of the calculation due to an instantaneous power interruption or the like.

続いて、部分計算要求手段215は、複数の部分計算のそれぞれについて、当該部分計算の実行を開始させる指示を、選択手段275により当該部分計算に対応付けて選択された計算処理装置に送信する(S530)。例えば、部分計算要求手段215は、当該部分計算を、当該部分計算に対応付けて選択された計算処理装置30−1に送信する。これに代えて、部分計算要求手段215は、選択手段275により選択された上階層管理装置、例えば、上階層管理装置50−1に、当該部分計算を送信してもよい。この場合、上階層管理装置50−1は、当該部分計算を、当該部分計算を実行させる計算処理装置を管理する下階層管理装置40−1に転送する。更に、下階層管理装置40−1は、当該部分計算を、選択された計算処理装置に転送する。即ち、部分計算要求手段215は、上階層管理装置及び下階層管理装置を介して部分計算を計算処理装置に送信してもよい。   Subsequently, the partial calculation request unit 215 transmits an instruction to start execution of the partial calculation for each of the plurality of partial calculations to the calculation processing device selected by the selection unit 275 in association with the partial calculation ( S530). For example, the partial calculation request unit 215 transmits the partial calculation to the calculation processing device 30-1 selected in association with the partial calculation. Instead, the partial calculation request unit 215 may transmit the partial calculation to the upper hierarchy management device selected by the selection unit 275, for example, the upper hierarchy management device 50-1. In this case, the upper hierarchy management apparatus 50-1 transfers the partial calculation to the lower hierarchy management apparatus 40-1 that manages the calculation processing apparatus that executes the partial calculation. Furthermore, the lower layer management apparatus 40-1 transfers the partial calculation to the selected calculation processing apparatus. That is, the partial calculation request unit 215 may transmit the partial calculation to the calculation processing device via the upper hierarchy management device and the lower hierarchy management device.

ここで、複数の部分計算を処理させる計算処理装置として、同一の地域における複数の計算処理装置が選択された場合、好ましくは、部分計算要求手段215は、同一の地域における一の計算処理装置に部分計算を開始させる時刻及び当該地域における他の計算処理装置に部分計算を開始させる時間を異ならせるべく、複数の部分計算のそれぞれを実行開始させるタイミングを調節する。これにより、計算開始時に計算開始後と比較して消費電力が高くなる場合、例えば、計算開始時にハードディスクドライブ等を駆動する場合であっても、同一の地域における瞬間最大消費電力を低減することができる。   Here, when a plurality of calculation processing devices in the same region are selected as calculation processing devices for processing a plurality of partial calculations, preferably, the partial calculation requesting means 215 is assigned to one calculation processing device in the same region. The timing for starting execution of each of the plurality of partial calculations is adjusted so that the time at which the partial calculation is started and the time at which the other calculation processing device in the region starts the partial calculation are different. As a result, when the power consumption becomes higher at the start of the calculation than after the start of the calculation, for example, even when a hard disk drive or the like is driven at the start of the calculation, the instantaneous maximum power consumption in the same region can be reduced. it can.

更に好ましくは、部分計算要求手段215は、より長い処理時間を要する部分計算を、より短い処理時間を要する部分計算より早く開始させる。これにより、計算開始から複数の部分計算のそれぞれが終了するまでの所要時間を短縮することができる。   More preferably, the partial calculation requesting unit 215 starts the partial calculation that requires a longer processing time earlier than the partial calculation that requires a shorter processing time. Thereby, the time required from the start of calculation to the end of each of the plurality of partial calculations can be shortened.

続いて、部分計算要求手段215は、複数の部分計算により構成される計算処理の種類を、複数の部分計算を実行させる計算処理装置の組に対応付けて要求履歴情報格納手段220に格納する(S533)。   Subsequently, the partial calculation requesting unit 215 stores the types of calculation processing constituted by a plurality of partial calculations in the request history information storage unit 220 in association with a set of calculation processing devices that execute the plurality of partial calculations ( S533).

部分計算処理手段300は、部分計算の実行を開始する指示を受信すると(S535:YES)、部分計算を実行する(S540)。部分計算再割当手段330は、計算処理装置30−1が設けられた地域の総消費電力が、当該地域における最大供給可能電力のうち予め定められた基準割合に達したか否かを判断する(S545)。   When receiving an instruction to start execution of partial calculation (S535: YES), the partial calculation processing means 300 executes partial calculation (S540). The partial calculation reassignment unit 330 determines whether or not the total power consumption of the area where the calculation processing device 30-1 is provided has reached a predetermined reference ratio among the maximum suppliable power in the area ( S545).

部分計算再割当手段330は、当該地域の総消費電力が基準割合に達したと判断した場合に(S545:YES)、部分計算処理手段300に部分計算の処理を中止させ、部分計算処理手段300において処理する部分計算を部分計算処理手段300から取得して他の計算処理装置に送信する(S550)。これにより、計算処理装置30−1は、計算要求装置20の処理に関わらず自律的に、所定の地域における電力消費の集中を防止することができる。   When the partial calculation reassignment unit 330 determines that the total power consumption of the area has reached the reference rate (S545: YES), the partial calculation processing unit 300 causes the partial calculation processing unit 300 to stop the partial calculation processing, and the partial calculation processing unit 300 The partial calculation to be processed in step S3 is acquired from the partial calculation processing unit 300 and transmitted to another calculation processing device (S550). Thereby, the calculation processing apparatus 30-1 can prevent the concentration of power consumption in a predetermined area autonomously regardless of the processing of the calculation requesting apparatus 20.

当該地域の総消費電力が基準割合に達していないと判断した場合に(S545:NO)、部分計算が終了したか否かを判断する(S555)。部分計算が終了していない場合(S555:NO)、計算処理装置30−1は、S540に処理を戻して部分計算の処理を継続する。   When it is determined that the total power consumption in the area has not reached the reference ratio (S545: NO), it is determined whether or not the partial calculation is completed (S555). When the partial calculation is not completed (S555: NO), the calculation processing device 30-1 returns the process to S540 and continues the partial calculation process.

一方、部分計算が終了した場合に(S555:YES)、処理結果送信手段310は、部分計算の処理結果を計算要求装置20に送信する(S560)。また、実消費量送信手段320は、部分計算処理手段300が部分計算を処理した場合に消費した電力量を示す電力実消費量情報を、部分計算処理手段300の処理内容を解析することにより生成し、当該部分計算を識別する情報に対応付けて計算要求装置20に送信する(S575)。   On the other hand, when the partial calculation is completed (S555: YES), the processing result transmitting unit 310 transmits the processing result of the partial calculation to the calculation requesting apparatus 20 (S560). Further, the actual consumption amount transmitting unit 320 generates power actual consumption amount information indicating the amount of power consumed when the partial calculation processing unit 300 processes the partial calculation by analyzing the processing content of the partial calculation processing unit 300. Then, it is transmitted to the calculation requesting apparatus 20 in association with the information for identifying the partial calculation (S575).

処理結果出力手段280は、計算処理装置30−1〜Nから複数の部分計算のそれぞれについて処理結果を受け取った場合に(S565:YES)、受け取った部分計算の結果の組を、計算処理700の結果として利用者に出力する(S570)。また、電力処理指標情報取得手段200は、各部分計算が処理された場合に実際に消費された電力量を示す電力実消費量情報を、当該部分計算を実行した計算処理装置を識別する情報に対応付けて、処理結果出力手段280を介して計算処理装置30−1〜Nから取得する(S580)。そして、電力処理指標情報取得手段200は、受け取った電力実消費量を電力処理指標情報として計算機環境データベース210に格納する(S590)。   When the processing result output unit 280 receives processing results for each of the plurality of partial calculations from the calculation processing devices 30-1 to 30 -N (S 565: YES), the processing result output unit 280 As a result, it outputs to the user (S570). In addition, the power processing index information acquisition unit 200 uses the actual power consumption information indicating the amount of power actually consumed when each partial calculation is processed as information for identifying the calculation processing device that has executed the partial calculation. Correspondingly, it is acquired from the calculation processing devices 30-1 to 30-N via the processing result output means 280 (S580). Then, the power processing index information acquisition unit 200 stores the received actual power consumption as power processing index information in the computer environment database 210 (S590).

図6は、S485における動作フローの詳細を示す。計算内容解析手段240は、複数の部分計算のそれぞれについて、当該部分計算に含まれるインストラクション数を解析する(S600)。例えば、計算内容解析手段240は、インストラクション数として、部分計算における実行されることが予測される実行パスにおける実行ステップ数を解析してもよいし、部分計算全体のインストラクション数を解析してもよい。また、計算内容解析手段240は、ループ処理における誘導変数を用いてインストラクション数を解析してもよい。   FIG. 6 shows the details of the operation flow in S485. The calculation content analysis means 240 analyzes the number of instructions included in each partial calculation for each of the plurality of partial calculations (S600). For example, the calculation content analysis unit 240 may analyze the number of execution steps in the execution path predicted to be executed in the partial calculation as the number of instructions, or may analyze the number of instructions in the entire partial calculation. . Moreover, the calculation content analysis means 240 may analyze the number of instructions using the induction variable in the loop processing.

また、計算内容解析手段240は、複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置がアクセスされるアクセス回数を解析する(S610)。例えば、計算内容解析手段240は、入出力装置のアクセスに用いられるAPIの呼び出し回数に基づいて、アクセス回数を解析してもよい。   In addition, the calculation content analysis unit 240 analyzes the number of times the input / output device is accessed in the partial calculation processing for each of the plurality of partial calculations (S610). For example, the calculation content analysis unit 240 may analyze the number of accesses based on the number of API calls used to access the input / output device.

更に、計算内容解析手段240は、複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置が転送する転送データのサイズを解析する(S620)。例えば、計算内容解析手段240は、入出力装置のアクセスに用いられるAPIの引数の値に基づいて、転送データのサイズを解析してもよい。   Furthermore, the calculation content analysis means 240 analyzes the size of the transfer data transferred by the input / output device in the partial calculation process for each of the partial calculations (S620). For example, the calculation content analysis means 240 may analyze the size of transfer data based on the value of an API argument used to access the input / output device.

また、計算内容解析手段240は、複数の部分計算のそれぞれについて、当該部分計算が、計算処理におけるクリティカルパスに含まれるか否かを解析する(S630)。また、計算内容解析手段240は、複数の部分計算のそれぞれについて、当該部分計算と同一の種類の処理であって、当該部分計算より処理時間が短い他の処理である、ベンチマークプログラムを実行する(S640)。   In addition, the calculation content analysis unit 240 analyzes, for each of the plurality of partial calculations, whether or not the partial calculation is included in the critical path in the calculation process (S630). Further, the calculation content analysis means 240 executes, for each of the plurality of partial calculations, a benchmark program that is another process that is the same type of process as the partial calculation and has a shorter processing time than the partial calculation ( S640).

続いて、消費電力指標情報生成手段225は、解析結果に基づいて、以下の処理により消費電力指標情報を生成する(S650)。例えば、消費電力指標情報生成手段225は、複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較してインストラクション数が多い場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する。   Subsequently, the power consumption index information generating unit 225 generates power consumption index information by the following processing based on the analysis result (S650). For example, the power consumption index information generating unit 225 compares each partial calculation with the other partial calculations when the partial calculation has a larger number of instructions than the other partial calculations. Power consumption index information indicating that the power consumption is large is generated.

また、消費電力指標情報生成手段225は、複数の部分計算のそれぞれについて、当該部部計算が他の部分計算と比較してアクセス回数が多い場合に、当該部分計算が他の部分計算と比較して消費電力が大きい旨を示す消費電力指標を生成する。また、消費電力指標情報生成手段225は、複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較して転送データのサイズが大きい場合に、当該部分計算が他の部分計算と比較して消費電力が大きい旨を示す消費電力指標を生成する。   In addition, the power consumption index information generating unit 225 compares each partial calculation with the other partial calculations when the number of accesses is larger than that of the other partial calculations. To generate a power consumption index indicating that the power consumption is large. In addition, the power consumption index information generation unit 225 compares each partial calculation with another partial calculation when the size of the transfer data is larger than that of the other partial calculation. Then, a power consumption index indicating that the power consumption is large is generated.

例えば、消費電力指標情報生成手段225は、複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要するCPUの演算量、ハードディスクドライブへのアクセス量、及び入出力装置の使用量の少なくとも一を示す処理内容情報を、消費電力指標情報として生成してもよい。また、消費電力指標情報生成手段225は、ベンチマークプログラムを実行した結果消費した電力量に基づいて、消費電力指標情報を生成してもよい。   For example, the power consumption index information generating unit 225 includes, for each of the plurality of partial calculations, the amount of CPU computation required for the partial calculation processing compared to the case where another partial calculation is processed in the same calculation processing device, the hard disk drive Processing content information indicating at least one of the access amount to the device and the usage amount of the input / output device may be generated as power consumption index information. The power consumption index information generating unit 225 may generate power consumption index information based on the amount of power consumed as a result of executing the benchmark program.

続いて、消費電力指標情報生成手段225は、当該部分計算の種類を、生成した消費電力指標に対応付けて消費電力指標情報格納手段230に格納する(S660)。   Subsequently, the power consumption index information generation unit 225 stores the type of partial calculation in the power consumption index information storage unit 230 in association with the generated power consumption index (S660).

図7は、計算処理700の詳細を示す。計算処理700は、それぞれが部分計算の一例であるアプリケーション1、アプリケーション2、アプリケーション3、アプリケーション4、アプリケーション5、アプリケーション6、及びアプリケーション7を含む。本図における実線矢印は、アプリケーション間の呼び出し関係を示し、例えば、アプリケーション1に処理中に、アプリケーション2から4が順次呼び出されて実行される。また、消費電力指標情報生成手段225は、アプリケーション1から7のそれぞれに対応付けて、消費電力指標情報A1からA7のそれぞれを生成する。   FIG. 7 shows details of the calculation process 700. The calculation process 700 includes application 1, application 2, application 3, application 4, application 5, application 6, and application 7, each of which is an example of partial calculation. A solid line arrow in this figure indicates a calling relationship between applications. For example, during processing by the application 1, the applications 2 to 4 are sequentially called and executed. Further, the power consumption index information generating unit 225 generates each of the power consumption index information A1 to A7 in association with each of the applications 1 to 7.

更に、アプリケーションのそれぞれは、それぞれが部分計算の一例であるジョブを複数含む。例えば、アプリケーション4は、ジョブ1、ジョブ2、ジョブ3、ジョブ4、ジョブ5、及びジョブ6を含む。アプリケーションの場合と同様、ジョブ1に処理中に、ジョブ2及びジョブ3が順次呼び出されて実行される。また、消費電力指標情報生成手段225は、ジョブ1から6のそれぞれに対応付けて、消費電力指標情報J1からJ6のそれぞれを生成する。   Further, each of the applications includes a plurality of jobs, each of which is an example of partial calculation. For example, the application 4 includes job 1, job 2, job 3, job 4, job 5, and job 6. As in the case of the application, job 2 and job 3 are sequentially called and executed during processing by job 1. The power consumption index information generating unit 225 generates each of the power consumption index information J1 to J6 in association with each of the jobs 1 to 6.

このように、計算処理700は、呼び出されて実行される単位毎に複数の部分計算に分類されており、計算要求装置20は、これらの部分計算のそれぞれを計算処理装置30−1〜Nの何れかにおいて実行させる。例えば、アプリケーション2、アプリケーション3、及びアプリケーション4間に実行の順序関係が定まっていない場合においては、計算要求装置20は、アプリケーション2、アプリケーション3、及びアプリケーション4のそれぞれを、互いに異なる3つの計算処理装置により並行に実行させることにより、処理を高速化することができる。   As described above, the calculation processing 700 is classified into a plurality of partial calculations for each unit that is called and executed, and the calculation requesting device 20 assigns each of these partial calculations to the calculation processing devices 30-1 to 30-N. Run in either. For example, in the case where the execution order relationship between the application 2, the application 3, and the application 4 is not determined, the calculation requesting device 20 performs three different calculation processes for the application 2, the application 3, and the application 4, respectively. The processing can be speeded up by executing in parallel by the apparatus.

図8は、計算要求装置20のハードウェア構成の一例を示す。計算要求装置20は、ホストコントローラ1082により相互に接続されるCPU1000、RAM1020、グラフィックコントローラ1075、及び表示装置1080を有するCPU周辺部と、入出力コントローラ1084によりホストコントローラ1082に接続される通信インターフェイス1030、ハードディスクドライブ1040、及びCD−ROMドライブ1060を有する入出力部と、入出力コントローラ1084に接続されるROM1010、フレキシブルディスクドライブ1050、及び入出力チップ1070を有するレガシー入出力部とを備える。   FIG. 8 shows an example of the hardware configuration of the calculation requesting device 20. The calculation requesting device 20 includes a CPU peripheral unit including a CPU 1000, a RAM 1020, a graphic controller 1075, and a display device 1080 connected to each other by a host controller 1082, and a communication interface 1030 connected to the host controller 1082 by an input / output controller 1084. An input / output unit having a hard disk drive 1040 and a CD-ROM drive 1060, and a legacy input / output unit having a ROM 1010, a flexible disk drive 1050 and an input / output chip 1070 connected to the input / output controller 1084 are provided.

ホストコントローラ1082は、RAM1020と、高い転送レートでRAM1020をアクセスするCPU1000及びグラフィックコントローラ1075とを接続する。CPU1000は、ROM1010及びRAM1020に格納されたプログラムに基づいて動作し、各部の制御を行う。グラフィックコントローラ1075は、CPU1000等がRAM1020内に設けたフレームバッファ上に生成する画像データを取得し、表示装置1080上に表示させる。これに代えて、グラフィックコントローラ1075は、CPU1000等が生成する画像データを格納するフレームバッファを、内部に含んでもよい。   The host controller 1082 connects the RAM 1020 to the CPU 1000 and the graphic controller 1075 that access the RAM 1020 at a high transfer rate. The CPU 1000 operates based on programs stored in the ROM 1010 and the RAM 1020, and controls each unit. The graphic controller 1075 acquires image data generated by the CPU 1000 or the like on a frame buffer provided in the RAM 1020 and displays it on the display device 1080. Alternatively, the graphic controller 1075 may include a frame buffer that stores image data generated by the CPU 1000 or the like.

入出力コントローラ1084は、ホストコントローラ1082と、比較的高速な入出力装置である通信インターフェイス1030、ハードディスクドライブ1040、及びCD−ROMドライブ1060を接続する。通信インターフェイス1030は、ファイバチャネル等のネットワークを介して外部の装置と通信する。ハードディスクドライブ1040は、計算要求装置20が使用するプログラム及びデータを格納する。CD−ROMドライブ1060は、CD−ROM1095からプログラム又はデータを読み取り、RAM1020を介して入出力チップ1070に提供する。   The input / output controller 1084 connects the host controller 1082 to the communication interface 1030, the hard disk drive 1040, and the CD-ROM drive 1060, which are relatively high-speed input / output devices. The communication interface 1030 communicates with an external device via a network such as a fiber channel. The hard disk drive 1040 stores programs and data used by the calculation requesting device 20. The CD-ROM drive 1060 reads a program or data from the CD-ROM 1095 and provides it to the input / output chip 1070 via the RAM 1020.

また、入出力コントローラ1084には、ROM1010と、フレキシブルディスクドライブ1050や入出力チップ1070等の比較的低速な入出力装置とが接続される。ROM1010は、計算要求装置20の起動時にCPU1000が実行するブートプログラムや、計算要求装置20のハードウェアに依存するプログラム等を格納する。フレキシブルディスクドライブ1050は、フレキシブルディスク1090からプログラム又はデータを読み取り、RAM1020を介して入出力チップ1070に提供する。入出力チップ1070は、フレキシブルディスク1090や、例えばパラレルポート、シリアルポート、キーボードポート、マウスポート等を介して各種の入出力装置を接続する。   The input / output controller 1084 is connected to the ROM 1010 and relatively low-speed input / output devices such as the flexible disk drive 1050 and the input / output chip 1070. The ROM 1010 stores a boot program executed by the CPU 1000 when the calculation requesting device 20 is started up, a program depending on the hardware of the calculation requesting device 20, and the like. The flexible disk drive 1050 reads a program or data from the flexible disk 1090 and provides it to the input / output chip 1070 via the RAM 1020. The input / output chip 1070 connects various input / output devices via a flexible disk 1090 and, for example, a parallel port, a serial port, a keyboard port, a mouse port, and the like.

計算要求装置20に提供されるプログラムは、フレキシブルディスク1090、CD−ROM1095、又はICカード等の記録媒体に格納されて利用者によって提供される。プログラムは、入出力チップ1070及び/又は入出力コントローラ1084を介して、記録媒体から読み出され計算要求装置20にインストールされて実行される。   The program provided to the calculation requesting device 20 is stored in a recording medium such as the flexible disk 1090, the CD-ROM 1095, or an IC card and provided by the user. The program is read from the recording medium via the input / output chip 1070 and / or the input / output controller 1084, installed in the calculation requesting apparatus 20, and executed.

計算要求装置20にインストールされて実行されるプログラムは、電力処理指標情報取得モジュールと、安定性情報取得モジュールと、部分計算要求モジュールと、消費電力指標情報生成モジュールと、計算内容解析モジュールと、条件情報取得モジュールと、地域情報取得モジュールと、電力料金情報生成モジュールと、選択モジュールと、処理結果出力モジュールとを含む。各モジュールが計算要求装置20に働きかけて行わせる動作は、図1から図7において説明した計算要求装置20における、対応する部材の動作と同一であるから、説明を省略する。   The programs installed and executed in the calculation requesting device 20 include a power processing index information acquisition module, a stability information acquisition module, a partial calculation request module, a power consumption index information generation module, a calculation content analysis module, a condition An information acquisition module, a region information acquisition module, a power rate information generation module, a selection module, and a processing result output module are included. The operation that each module causes the calculation requesting apparatus 20 to perform is the same as the operation of the corresponding member in the calculation requesting apparatus 20 described with reference to FIGS.

以上に示したプログラム又はモジュールは、外部の記憶媒体に格納されてもよい。記憶媒体としては、フレキシブルディスク1090、CD−ROM1095の他に、DVDやPD等の光学記録媒体、MD等の光磁気記録媒体、テープ媒体、ICカード等の半導体メモリ等を用いることができる。また、専用通信ネットワークやインターネットに接続されたサーバシステムに設けたハードディスク又はRAM等の記憶装置を記録媒体として使用し、ネットワークを介してプログラムを計算要求装置20に提供してもよい。   The program or module shown above may be stored in an external storage medium. As the storage medium, in addition to the flexible disk 1090 and the CD-ROM 1095, an optical recording medium such as a DVD or PD, a magneto-optical recording medium such as an MD, a tape medium, a semiconductor memory such as an IC card, or the like can be used. Further, a storage device such as a hard disk or a RAM provided in a server system connected to a dedicated communication network or the Internet may be used as a recording medium, and the program may be provided to the calculation requesting device 20 via the network.

以上、本実施例から明らかなように、分散コンピューティングシステム10は、膨大な時間を要する計算処理を複数の部分計算に分割し、当該複数の部分計算を計算処理装置30−1〜Nを用いて並行に処理する。これにより、計算処理を高速に行うことができる。また、分散コンピューティングシステム10は、部分計算の処理内容を解析することにより、部分計算に要する電力又は部分計算の重要性等の情報を生成する。更に、分散コンピューティングシステム10は、各計算処理装置において計算量当たりに消費する電力の情報を取得する。これらの情報に基づいて、分散コンピューティングシステム10は、部分計算を実行するべき計算処理装置を選択する。これにより、これにより、利用者から取得する条件に応じて、電力消費量を削減し、夜間電力を有効利用し、電気料金を削減し、又は計算処理の安定性を確保することができる。   As described above, as is apparent from the present embodiment, the distributed computing system 10 divides a calculation process that requires a large amount of time into a plurality of partial calculations, and uses the calculation processors 30-1 to 30-N for the plurality of partial calculations. Process in parallel. Thereby, calculation processing can be performed at high speed. Further, the distributed computing system 10 generates information such as the power required for the partial calculation or the importance of the partial calculation by analyzing the processing contents of the partial calculation. Furthermore, the distributed computing system 10 acquires information on the power consumed per calculation amount in each calculation processing device. Based on these pieces of information, the distributed computing system 10 selects a calculation processing device that should execute the partial calculation. Thereby, according to the conditions acquired from a user, electric power consumption can be reduced, nighttime electric power can be used effectively, an electricity bill can be reduced, or the stability of calculation processing can be ensured.

以上、本発明を実施の形態を用いて説明したが、本発明の技術的範囲は上記実施の形態に記載の範囲には限定されない。上記実施の形態に、多様な変更または改良を加えることが可能であることが当業者に明らかである。その様な変更または改良を加えた形態も本発明の技術的範囲に含まれ得ることが、特許請求の範囲の記載から明らかである。   As mentioned above, although this invention was demonstrated using embodiment, the technical scope of this invention is not limited to the range as described in the said embodiment. It will be apparent to those skilled in the art that various modifications or improvements can be added to the above-described embodiment. It is apparent from the scope of the claims that the embodiments added with such changes or improvements can be included in the technical scope of the present invention.

以上に示した実施例によると、以下の各項目に示す分散コンピューティングシステム、制御方法、プログラム、及び記録媒体が実現される。   According to the embodiment described above, the distributed computing system, the control method, the program, and the recording medium shown in the following items are realized.

(項目1) 予め定められた計算処理を構成する複数の部分計算をそれぞれ実行する複数の計算処理装置と、前記複数の計算処理装置に部分計算を要求する計算要求装置とを備える分散コンピューティングシステムであって、前記計算要求装置は、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段とを有し、前記複数の計算処理装置のそれぞれは、前記計算要求装置から要求された部分計算を処理する部分計算処理手段と、前記部分計算の処理結果を前記計算要求装置に送信する処理結果送信手段とを有する分散コンピューティングシステム。
(項目2) 前記電力処理指標情報取得手段は、各計算処理装置の前記電力処理指標情報として、当該計算処理装置のCPU、ハードディスクドライブ、及び入出力装置の少なくとも一について、所定の処理量当たりの消費電力を示す性能情報を取得し、前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要するCPUの演算量、ハードディスクドライブへのアクセス量、及び入出力装置の使用量の少なくとも一を示す処理内容情報を、前記消費電力指標情報として生成する項目1記載の分散コンピューティングシステム。
(Item 1) A distributed computing system comprising: a plurality of calculation processing devices that respectively execute a plurality of partial calculations constituting predetermined calculation processing; and a calculation requesting device that requests partial calculations from the plurality of calculation processing devices. The calculation requesting device includes, for each of the plurality of calculation processing devices, power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount, and the plurality of parts For each of the calculations, power consumption index information generating means for generating power consumption index information indicating the amount of power required for the process of the partial calculation compared to the case where another partial calculation is processed in the same calculation processing device, and the plurality A condition for acquiring power amount condition information indicating a condition to be satisfied by the amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations. A calculation processing device that satisfies the power amount condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations. Selection means for selecting based on the information and the power consumption index information; and a partial calculation requesting means for causing the calculation processing device selected by the selection means to associate each of the partial calculations with the partial calculation. And a processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing, each of the plurality of calculation processing devices from the calculation requesting device. A distributed computer comprising: a partial calculation processing means for processing the requested partial calculation; and a processing result transmission means for transmitting the result of the partial calculation to the calculation requesting device. Computing system.
(Item 2) The power processing index information acquisition unit is configured to store at least one of a CPU, a hard disk drive, and an input / output device of the calculation processing device per predetermined processing amount as the power processing index information of each calculation processing device. The performance information indicating power consumption is acquired, and the power consumption index information generating unit performs processing of the partial calculation for each of the plurality of partial calculations compared to a case where another partial calculation is processed in the same calculation processing device. The distributed computing system according to item 1, wherein processing content information indicating at least one of an amount of computation of a CPU, an access amount to a hard disk drive, and a usage amount of an input / output device required for generating is used as the power consumption index information.

(項目3) 前記計算要求装置は、前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段と、前記複数の計算処理装置のそれぞれについて、当該計算処理装置の消費電力当たりの電力料金を示す電力料金情報を、前記地域情報に基づいて生成する電力料金情報生成手段とを更に有し、前記選択手段は、前記電力量条件情報を満たす計算処理装置を、更に前記電力料金情報に基づいて選択する項目1記載の分散コンピューティングシステム。
(項目4) 前記電力料金情報生成手段は、前記計算処理が行われる時間帯及び前記地域情報により定まる地域のタイムゾーンに基づいて、前記複数の計算処理装置のそれぞれに対応付けて前記電気料金情報を生成し、前記選択手段は、前記複数の部分計算のそれぞれを実行させる計算処理装置として、計算処理装置が設けられる地域における前記部分計算要求手段が前記部分計算を要求する時刻が夜間である計算処理装置を、当該時刻が昼間である計算処理装置より優先して選択する項目3記載の分散コンピューティングシステム。
(項目5) 前記計算要求装置は、前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段を更に有し、前記条件情報取得手段が、前記電力量条件情報として、所定の地域に設けられた複数の計算処理装置における単位時間当たりに消費する電力の上限を定める電力上限値を取得した場合において、前記選択手段は、前記所定の地域における複数の計算処理装置が前記複数の部分計算を処理することにより単位時間当たりに消費する電力が、前記電力上限値以下である場合に、当該複数の部分計算のそれぞれに対応付けて、前記所定の地域における複数の計算処理装置を選択する項目1記載の分散コンピューティングシステム。
(項目6) 前記複数の部分計算を処理させる計算処理装置として、同一の地域における複数の計算処理装置が選択された場合に、前記部分計算要求手段は、同一の地域における一の計算処理装置に部分計算を開始させる時間及び当該地域における他の計算処理装置に部分計算を開始させる時間を異ならせるべく、前記複数の部分計算のそれぞれを実行開始させるタイミングを調節する項目5記載の分散コンピューティングシステム。
(Item 3) The calculation requesting device includes: region information acquisition means for acquiring region information indicating which of the plurality of calculation processing devices is provided in a plurality of predetermined regions; For each of the calculation processing devices, it further includes power rate information generating means for generating power rate information indicating a power rate per power consumption of the calculation processing device based on the regional information, and the selection unit includes: The distributed computing system according to item 1, wherein a calculation processing device that satisfies the power amount condition information is further selected based on the power rate information.
(Item 4) The power rate information generation means associates the electricity rate information with each of the plurality of calculation processing devices based on a time zone in which the calculation process is performed and a time zone of a region determined by the region information. The selection means is a calculation processing device that executes each of the plurality of partial calculations, and the time when the partial calculation requesting means in the area where the calculation processing device is provided requests the partial calculation is nighttime. 4. The distributed computing system according to item 3, wherein the processing device is selected with priority over the computing device whose time is daytime.
(Item 5) The calculation requesting apparatus further includes area information acquisition means for acquiring area information indicating which of the plurality of calculation processing apparatuses is provided in a plurality of predetermined areas. In the case where the condition information acquisition unit acquires, as the power amount condition information, a power upper limit value that defines an upper limit of power consumed per unit time in a plurality of calculation processing devices provided in a predetermined area, the selection When the power consumed per unit time by the plurality of calculation processing devices in the predetermined area processing the plurality of partial calculations is equal to or less than the power upper limit value, each of the plurality of partial calculations The distributed computing system according to item 1, wherein a plurality of calculation processing devices in the predetermined area are selected in association with each other.
(Item 6) When a plurality of calculation processing devices in the same region are selected as the calculation processing devices for processing the plurality of partial calculations, the partial calculation requesting unit is assigned to one calculation processing device in the same region. 6. The distributed computing system according to item 5, wherein the timing for starting execution of each of the plurality of partial calculations is adjusted so that the time for starting the partial calculation differs from the time for starting another partial calculation processing device in the region. .

(項目7) 前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算に含まれるインストラクション数を解析する計算内容解析手段を更に有し、前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較してインストラクション数が多い場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する項目1記載の分散コンピューティングシステム。
(項目8) 前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置がアクセスされるアクセス回数を解析する計算内容解析手段を更に有し、前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較して前記アクセス回数が多い場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する項目1記載の分散コンピューティングシステム。
(項目9) 前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置が転送する転送データのサイズを解析する計算内容解析手段を更に有し、前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較して前記転送データのサイズが大きい場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する項目1記載の分散コンピューティングシステム。
(項目10) 前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算と同一の種類の処理であって、当該部分計算より処理時間が短い他の処理を実行した場合に消費する電力量に基づいて、消費電力指標情報を生成する項目1記載の分散コンピューティングシステム。
(項目11) 前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算が前記計算処理におけるクリティカルパスに含まれるか否かを解析する計算内容解析手段を更に有し、前記選択手段は、前記電力量条件情報を満たす計算処理装置のうち、前記クリティカルパスに含まれない部分計算に対応付けて選択する計算処理装置と比較して、前記電力処理指標情報の示す消費電力量がより大きくかつ処理速度がより速い計算処理装置を前記クリティカルパスに含まれる部分計算に対応付けて選択する項目1記載の分散コンピューティングシステム。
(Item 7) The calculation requesting device further includes calculation content analysis means for analyzing the number of instructions included in the partial calculation for each of the plurality of partial calculations, and the power consumption index information generating means For each of the partial calculations, power consumption index information indicating that the partial calculation has a larger power consumption than the other partial calculations when the partial calculation has a larger number of instructions than the other partial calculations. The distributed computing system according to item 1, wherein:
(Item 8) The calculation requesting device further includes calculation content analysis means for analyzing the number of times the input / output device is accessed in the partial calculation processing for each of the plurality of partial calculations. The information generation means, for each of the plurality of partial calculations, when the partial calculation has a higher access count compared to other partial calculations, the partial calculation consumes less power than the other partial calculations. Item 4. The distributed computing system according to item 1, which generates power consumption index information indicating a large value.
(Item 9) The calculation requesting device further includes calculation content analysis means for analyzing the size of transfer data transferred by the input / output device in the partial calculation processing for each of the plurality of partial calculations. The index information generating means consumes each partial calculation when the partial calculation is larger than the other partial calculations and the transfer data is larger in size than the other partial calculations. Item 4. The distributed computing system according to item 1, which generates power consumption index information indicating that the amount of power is large.
(Item 10) When the power consumption index information generating unit executes, for each of the plurality of partial calculations, another process that is the same type of process as the partial calculation and has a processing time shorter than the partial calculation. Item 4. The distributed computing system according to item 1, wherein power consumption index information is generated based on an amount of power consumed by the device.
(Item 11) The calculation requesting device further includes, for each of the plurality of partial calculations, a calculation content analysis unit that analyzes whether or not the partial calculation is included in a critical path in the calculation process, and the selection unit Compared with a calculation processing device selected in association with a partial calculation not included in the critical path among calculation processing devices satisfying the power amount condition information, the power consumption amount indicated by the power processing index information is more 2. The distributed computing system according to item 1, wherein a computing device that is large and has a faster processing speed is selected in association with a partial calculation included in the critical path.

(項目12) 前記計算処理装置は、前記部分計算処理手段が部分計算を処理した場合に消費した電力量を示す電力実消費量情報を、当該部分計算を識別する情報に対応付けて、前記計算要求装置に送信する実消費量送信手段を更に有し、前記電力処理指標情報取得手段は、当該部分計算当たりの当該電力実消費量情報を、前記電力処理指標情報として前記実消費量送信手段から取得する項目1記載の分散コンピューティングシステム。
(項目13) 前記計算要求装置は、部分計算の種類と、当該部分計算の消費電力指標情報とを対応付けて格納する消費電力指標情報格納手段を更に有し、前記複数の部分計算のそれぞれについて、当該部分計算の種類が前記消費電力指標情報格納手段に格納されている場合において、前記消費電力指標情報生成手段は、当該部分計算の種類に対応付けられた消費電力指標情報を前記消費電力指標情報格納手段から選択することにより、当該部分計算の消費電力指標情報を生成する項目1記載の分散コンピューティングシステム。
(項目14) 前記計算要求装置は、当該計算要求装置が既に行わせた計算処理の種類に、当該計算処理を行った計算処理装置の組を識別する情報を対応付けた情報を格納する要求履歴情報格納手段を更に有し、前記部分計算要求手段は、実行するべき計算処理の種類に基づいて、計算処理の当該種類に対応付けられた計算処理装置の組を識別する情報を、前記要求履歴情報格納手段から検索し、検索した当該計算処理装置の組に当該計算処理を行わせる、項目1記載の分散コンピューティングシステム。
(項目15) 前記部分計算要求手段は、より長い処理時間を要する部分計算を、より短い処理時間を要する部分計算より早く開始させる項目1記載の分散コンピューティングシステム。
(項目16) 前記計算処理装置は、当該計算処理装置が設けられた地域の総消費電力が、当該地域における最大供給可能電力のうち予め定められた割合に達したと判断した場合に、前記部分計算処理手段において処理する部分計算を、当該地域とは異なる地域に設けられた他の計算処理装置において実行させる部分計算再割当手段を更に有する項目1記載の分散コンピューティングシステム。
(Item 12) The calculation processing device associates the actual power consumption information indicating the amount of power consumed when the partial calculation processing unit processes the partial calculation with the information for identifying the partial calculation, and calculates the calculation. The power consumption index information acquisition means further transmits the actual power consumption information per partial calculation from the actual consumption amount transmission means as the power processing index information. Item 4. A distributed computing system according to item 1.
(Item 13) The calculation requesting device further includes power consumption index information storage means for storing a type of partial calculation and power consumption index information of the partial calculation in association with each other, and for each of the plurality of partial calculations. When the partial calculation type is stored in the power consumption index information storage unit, the power consumption index information generation unit displays the power consumption index information associated with the partial calculation type as the power consumption index. The distributed computing system according to item 1, wherein the power consumption index information of the partial calculation is generated by selecting from the information storage means.
(Item 14) The request history in which the calculation requesting device stores information in which the type of the calculation processing already performed by the calculation requesting device is associated with information for identifying the set of the calculation processing devices that have performed the calculation processing. The partial calculation requesting means further includes information for identifying a set of calculation processing devices associated with the type of calculation processing based on the type of calculation processing to be executed. The distributed computing system according to item 1, wherein a search is performed from an information storage unit, and the set of calculated processing devices is caused to perform the calculation processing.
(Item 15) The distributed computing system according to item 1, wherein the partial calculation request means starts a partial calculation requiring a longer processing time earlier than a partial calculation requiring a shorter processing time.
(Item 16) When the calculation processing device determines that the total power consumption of the area where the calculation processing device is provided has reached a predetermined ratio of the maximum suppliable power in the region, the calculation processing device 2. The distributed computing system according to item 1, further comprising partial calculation reassignment means for causing partial calculation processed in the calculation processing means to be executed in another calculation processing device provided in an area different from the area.

(項目17) 前記複数の計算処理装置を分類した複数の処理装置グループのそれぞれに対応して設けられ、当該処理装置グループにおける各計算処理装置の電力処理指標情報を管理する下階層管理装置と、複数の前記下階層管理装置を分類した複数の管理装置グループのそれぞれに対応して設けられ、当該管理装置グループにおける各下階層管理装置が管理する電力処理指標情報の最大値及び最小値の間の値である電力処理総合情報を管理する上階層管理装置とを更に備え、前記電力処理指標情報取得手段は、前記上階層管理装置から前記電力処理総合情報を、前記下階層管理装置から前記電力処理指標情報をそれぞれ取得し、前記選択手段は、管理する電力処理総合情報の何れかが前記電力量条件情報を満たす上階層管理装置を選択し、当該上階層管理装置により管理される下階層管理装置のうち、管理する電力処理指標情報の何れかが前記電力量条件情報を満たす下階層管理装置を選択し、当該下階層管理装置により管理される計算処理装置のうち、前記電力量条件を満たす計算処理装置を選択する項目1記載の分散コンピューティングシステム。
(項目18) 予め定められた計算処理を構成する複数の部分計算をそれぞれ実行する複数の計算処理装置と、前記複数の計算処理装置に部分計算を要求する計算要求装置とを備える分散コンピューティングシステムであって、前記計算要求装置は、前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段とを有し、前記複数の計算処理装置のそれぞれは、前記計算要求装置から要求された部分計算を処理する部分計算処理手段と、前記部分計算の処理結果を前記計算要求装置に送信する処理結果送信手段とを有する分散コンピューティングシステム。
(Item 17) A lower-layer management device that is provided corresponding to each of a plurality of processing device groups into which the plurality of calculation processing devices are classified, and that manages power processing index information of each calculation processing device in the processing device group; Between the maximum value and the minimum value of the power processing index information provided corresponding to each of the plurality of management device groups into which the plurality of lower layer management devices are classified, and managed by each lower layer management device in the management device group An upper tier management device that manages power processing total information that is a value, and the power processing index information acquisition means receives the power processing total information from the upper tier management device and the power processing from the lower tier management device. Each of the index information is acquired, and the selection unit selects an upper layer management device in which any of the power processing comprehensive information to be managed satisfies the power amount condition information, Among the lower tier management devices managed by the upper tier management device, a lower tier management device in which any of the power processing index information to be managed satisfies the power amount condition information is selected and managed by the lower tier management device. The distributed computing system according to item 1, wherein a computing processing device that satisfies the power consumption condition is selected from the computing processing devices.
(Item 18) A distributed computing system comprising: a plurality of calculation processing apparatuses that respectively execute a plurality of partial calculations constituting a predetermined calculation process; and a calculation requesting apparatus that requests partial calculations from the plurality of calculation processing apparatuses. The calculation requesting device includes, for each of the plurality of calculation processing devices, stability information acquisition means for acquiring stability information indicating stability of power supplied to the calculation processing device, and the plurality of calculation processing devices. In association with each of the plurality of partial calculations, a condition information acquisition unit that acquires stability condition information indicating a condition of the stability of electricity received when the calculation processing device executes the plurality of partial calculations. Selection for selecting a calculation processing device that satisfies the stability condition information when executing the partial calculation from among the plurality of calculation processing devices based on the stability information Means, a partial calculation requesting means for causing each of the plurality of partial calculations to be performed by a calculation processing device selected in association with the partial calculation by the selection means, and a partial calculation received from the plurality of calculation processing devices. Processing result output means for outputting a result set as a result of the calculation processing, and each of the plurality of calculation processing devices includes partial calculation processing means for processing a partial calculation requested by the calculation requesting device; And a processing result transmitting means for transmitting the processing result of the partial calculation to the calculation requesting device.

(項目19) 前記安定性情報取得手段は、各計算処理装置における前記安定性情報として、当該計算処理装置が電池又は発電機による無停電電源装置により管理されているか否かを示す情報を取得する項目18記載の分散コンピューティングシステム。
(項目20) 前記計算要求装置は、前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段を更に有し、前記安定性情報取得手段は、各計算処理装置における前記安定性情報として、当該計算処理装置が設けられた地域に供給される電気の安定性を示す情報を取得する項目18記載の分散コンピューティングシステム。
(項目21) 前記計算要求装置は、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段を更に有し、前記条件情報取得手段は、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を更に取得し、前記選択手段は、更に前記電力処理指標情報に基づいて、更に前記電力量条件情報を満たす計算処理装置を選択する項目18記載の分散コンピューティングシステム。
(項目22) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置であって、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段とを備える計算要求装置。
(Item 19) The stability information acquisition unit acquires, as the stability information in each calculation processing device, information indicating whether the calculation processing device is managed by an uninterruptible power supply using a battery or a generator. Item 19. A distributed computing system according to Item 18.
(Item 20) The calculation requesting apparatus further includes area information acquisition means for acquiring area information indicating which of the plurality of calculation processing apparatuses is provided in a plurality of predetermined areas. 19. The distributed computing according to item 18, wherein the stability information acquisition means acquires, as the stability information in each calculation processing device, information indicating the stability of electricity supplied to an area where the calculation processing device is provided. system.
(Item 21) The calculation requesting apparatus further includes power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the plurality of calculation processing apparatuses, The condition information acquisition unit further acquires power amount condition information indicating a condition to be satisfied by an amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations, and the selection unit further includes the power 19. The distributed computing system according to item 18, wherein a computing processing device that further satisfies the power amount condition information is selected based on processing index information.
(Item 22) A calculation requesting apparatus for causing a plurality of calculation processing apparatuses to execute a plurality of partial calculations constituting a predetermined calculation process, and for each of the plurality of calculation processing apparatuses, a predetermined calculation processing amount Power processing index information acquisition means for acquiring power processing index information indicating the power consumption per unit, and the partial calculation compared with the case where each of the plurality of partial calculations is processed with another partial calculation in the same calculation processing device Power consumption index information generating means for generating power consumption index information indicating the amount of power required for the processing, and a condition to be satisfied by the amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations Condition information acquisition means for acquiring power amount condition information, and the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations. A selection unit that selects a calculation processing device that satisfies the power amount condition information when performing calculation based on the power processing index information and the power consumption index information, and each of the plurality of partial calculations is the selection unit. A processing result for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing and a partial calculation requesting unit to be executed by the calculation processing device selected in association with the partial calculation A calculation requesting device comprising output means.

(項目23) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置であって、前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段とを備える計算要求装置。
(項目24) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを動作させる制御方法であって、前記コンピュータにより、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得段階と、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成段階と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得段階と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択段階と、前記複数の部分計算のそれぞれを、前記選択段階において当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求段階と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力段階とを備える制御方法。
(Item 23) A calculation requesting apparatus that causes a plurality of calculation processing apparatuses to execute a plurality of partial calculations constituting a predetermined calculation process, and for each of the plurality of calculation processing apparatuses, Stability information acquisition means for acquiring stability information indicating the stability of supplied power, and conditions for the stability of electricity received when the plurality of calculation processing devices execute the plurality of partial calculations Condition information acquisition means for acquiring stability condition information and a calculation process that satisfies the stability condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations A selection means for selecting a device based on the stability information, and a calculation process in which each of the plurality of partial calculations is selected in association with the partial calculation by the selection means A calculation requesting device comprising: partial calculation requesting means to be executed by the apparatus; and processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
(Item 24) A control method for causing a computer to operate as a calculation requesting device that causes a plurality of calculation processing devices to execute a plurality of partial calculations constituting predetermined calculation processing, respectively, wherein the plurality of calculations are performed by the computer. For each of the processing devices, a power processing index information acquisition stage for acquiring power processing index information indicating power consumption per predetermined calculation processing amount, and for each of the plurality of partial calculations, in the same calculation processing device, other parts A power consumption index information generation stage for generating power consumption index information indicating the amount of power required for the partial calculation process compared to the case where the calculation is processed, and when the plurality of calculation processing devices execute the plurality of partial calculations A condition information acquisition stage for acquiring power amount condition information indicating a condition to be satisfied by a power amount to be consumed, and the plurality of partial calculations The calculation processing device that satisfies the power amount condition information when the partial calculation is executed among the plurality of calculation processing devices is selected based on the power processing index information and the power consumption index information. A selection step, a partial calculation request step for causing each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation in the selection step, and a portion received from the plurality of calculation processing devices A control method comprising: a process result output stage for outputting a set of calculation results as a result of the calculation process.

(項目25) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置として、コンピュータを動作させる制御方法であって、前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得段階と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得段階と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択段階と、前記複数の部分計算のそれぞれを、前記選択段階において当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求段階と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力段階とを備える制御方法。
(項目26) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを機能させるプログラムであって、前記コンピュータを、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段として機能させるプログラム。
(Item 25) A control method for operating a computer as a calculation requesting device for causing a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing, respectively, comprising: For each, a stability information acquisition stage for acquiring stability information indicating the stability of power supplied to the calculation processing device, and supply when the plurality of calculation processing devices execute the plurality of partial calculations In the condition information acquisition stage for acquiring the stability condition information indicating the condition of the electrical stability, in association with each of the plurality of partial calculations, when executing the partial calculation among the plurality of calculation processing devices A selection step of selecting a calculation processing device that satisfies the stability condition information based on the stability information, and each of the plurality of partial calculations in the selection step A processing result output for outputting a partial calculation request stage to be executed by the calculation processing device selected in association with the partial calculation and a result of the partial calculation received from the plurality of calculation processing devices as a result of the calculation processing A control method comprising:
(Item 26) A program for causing a computer to function as a calculation requesting device that causes a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing, respectively, the computer including the plurality of calculation processing Power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the devices, and another partial calculation in the same calculation processing device for each of the plurality of partial calculations When the plurality of calculation processing devices execute the plurality of partial calculations, and the power consumption index information generating means for generating power consumption index information indicating the amount of power required for the partial calculation processing compared to Condition information acquisition means for acquiring power amount condition information indicating a condition to be satisfied by power consumption, and the plurality of partial calculations In association with each of the plurality of calculation processing devices, a calculation processing device that satisfies the power amount condition information when executing the partial calculation is selected based on the power processing index information and the power consumption index information. A selection means, a partial calculation request means for causing the calculation processing device selected in association with the partial calculation by the selection means to perform each of the partial calculations, and the partial calculation received from the plurality of calculation processing devices. A program that causes a set of the results to be output as a processing result output means for outputting the result set as a result of the calculation processing.

(項目27) 複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを機能させるプログラムであって、前記コンピュータを、前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段として機能させるプログラム。
(項目28) 項目26又は項目27記載のプログラムを記録した記録媒体。
(Item 27) A program that causes a computer to function as a calculation requesting device that causes a plurality of calculation processing devices to execute a plurality of partial calculations that constitute a predetermined calculation processing, respectively, the computer including the plurality of calculation processing Stability information acquisition means for acquiring stability information indicating the stability of power supplied to the calculation processing device for each of the devices, and supplied when the plurality of calculation processing devices execute the plurality of partial calculations A condition information acquisition means for acquiring stability condition information indicating a condition of the stability of electricity received, and executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations Selection means for selecting a calculation processing device satisfying the stability condition information based on the stability information, and each of the plurality of partial calculations, A set of partial calculation request means for causing the calculation processing device selected in association with the partial calculation by the selection means and a result of partial calculation received from the plurality of calculation processing devices to be output as a result of the calculation processing A program that functions as a processing result output means.
(Item 28) A recording medium on which the program according to item 26 or 27 is recorded.

図1は、分散コンピューティングシステム10のブロック図を示す。FIG. 1 shows a block diagram of a distributed computing system 10. 図2は、計算要求装置20のブロック図を示す。FIG. 2 shows a block diagram of the calculation requesting device 20. 図3は、計算処理装置30−1のブロック図を示す。FIG. 3 is a block diagram of the calculation processing device 30-1. 図4は、分散コンピューティングシステム10が計算処理を実行する動作フローを示す。FIG. 4 shows an operation flow in which the distributed computing system 10 executes calculation processing. 図5は、分散コンピューティングシステム10における図4に続く動作フローを示す。FIG. 5 shows an operation flow subsequent to FIG. 4 in the distributed computing system 10. 図6は、S485における動作フローの詳細を示す。FIG. 6 shows the details of the operation flow in S485. 図7は、計算処理700の詳細を示す。FIG. 7 shows details of the calculation process 700. 図8は、計算要求装置20のハードウェア構成の一例を示す。FIG. 8 shows an example of the hardware configuration of the calculation requesting device 20.

符号の説明Explanation of symbols

10 分散コンピューティングシステム
20 計算要求装置
30 計算処理装置
35 処理装置グループ
40 下階層管理装置
45 管理装置グループ
50 上階層管理装置
200 電力処理指標情報取得手段
205 安定性情報取得手段
210 計算機環境データベース
215 部分計算要求手段
220 要求履歴情報格納手段
225 消費電力指標情報生成手段
230 消費電力指標情報格納手段
240 計算内容解析手段
250 条件情報取得手段
260 地域情報取得手段
270 電力料金情報生成手段
275 選択手段
280 処理結果出力手段
300 部分計算処理手段
310 処理結果送信手段
320 実消費量送信手段
330 部分計算再割当手段
700 計算処理
DESCRIPTION OF SYMBOLS 10 Distributed computing system 20 Calculation request | requirement apparatus 30 Calculation processing apparatus 35 Processing apparatus group 40 Lower hierarchy management apparatus 45 Management apparatus group 50 Upper hierarchy management apparatus 200 Power processing index information acquisition means 205 Stability information acquisition means 210 Computer environment database 215 part Calculation request means 220 Request history information storage means 225 Power consumption index information generation means 230 Power consumption index information storage means 240 Calculation content analysis means 250 Condition information acquisition means 260 Area information acquisition means 270 Power charge information generation means 275 Selection means 280 Processing results Output means 300 Partial calculation processing means 310 Processing result transmission means 320 Actual consumption transmission means 330 Partial calculation reassignment means 700 Calculation processing

Claims (28)

予め定められた計算処理を構成する複数の部分計算をそれぞれ実行する複数の計算処理装置と、前記複数の計算処理装置に部分計算を要求する計算要求装置とを備える分散コンピューティングシステムであって、
前記計算要求装置は、
前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、
前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
を有し、
前記複数の計算処理装置のそれぞれは、
前記計算要求装置から要求された部分計算を処理する部分計算処理手段と、
前記部分計算の処理結果を前記計算要求装置に送信する処理結果送信手段と
を有する分散コンピューティングシステム。
A distributed computing system comprising: a plurality of calculation processing devices that respectively execute a plurality of partial calculations constituting a predetermined calculation process; and a calculation requesting device that requests partial calculations from the plurality of calculation processing devices,
The calculation requesting device is:
Power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the plurality of calculation processing devices;
For each of the plurality of partial calculations, power consumption index information generating means for generating power consumption index information indicating the amount of power required for the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device When,
Condition information acquisition means for acquiring power amount condition information indicating a condition to be satisfied by the amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations;
Corresponding to each of the plurality of partial calculations, a calculation processing device that satisfies the power amount condition information when executing the partial calculation among the plurality of calculation processing devices, the power processing index information and the power consumption index A selection means for selecting based on the information;
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
Processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing;
Each of the plurality of calculation processing devices includes:
Partial calculation processing means for processing the partial calculation requested from the calculation requesting device;
A distributed computing system comprising processing result transmission means for transmitting the processing result of the partial calculation to the calculation requesting device.
前記電力処理指標情報取得手段は、各計算処理装置の前記電力処理指標情報として、当該計算処理装置のCPU、ハードディスクドライブ、及び入出力装置の少なくとも一について、所定の処理量当たりの消費電力を示す性能情報を取得し、
前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要するCPUの演算量、ハードディスクドライブへのアクセス量、及び入出力装置の使用量の少なくとも一を示す処理内容情報を、前記消費電力指標情報として生成する
請求項1記載の分散コンピューティングシステム。
The power processing index information acquisition unit indicates power consumption per predetermined processing amount for at least one of the CPU, the hard disk drive, and the input / output device of the calculation processing device as the power processing index information of each calculation processing device. Get performance information
The power consumption index information generating means, for each of the plurality of partial calculations, to the hard disk drive, the amount of computation of the CPU required for the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device The distributed computing system according to claim 1, wherein processing content information indicating at least one of an access amount and an input / output device usage amount is generated as the power consumption index information.
前記計算要求装置は、
前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段と、
前記複数の計算処理装置のそれぞれについて、当該計算処理装置の消費電力当たりの電力料金を示す電力料金情報を、前記地域情報に基づいて生成する電力料金情報生成手段と
を更に有し、
前記選択手段は、前記電力量条件情報を満たす計算処理装置を、更に前記電力料金情報に基づいて選択する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device is:
Area information acquisition means for acquiring area information indicating which of the plurality of calculation processing devices is provided in a plurality of predetermined areas;
For each of the plurality of calculation processing devices, it further comprises power rate information generating means for generating power rate information indicating a power rate per power consumption of the calculation processing device based on the regional information,
The distributed computing system according to claim 1, wherein the selection unit further selects a calculation processing device that satisfies the power amount condition information based on the power rate information.
前記電力料金情報生成手段は、前記計算処理が行われる時間帯及び前記地域情報により定まる地域のタイムゾーンに基づいて、前記複数の計算処理装置のそれぞれに対応付けて前記電気料金情報を生成し、
前記選択手段は、前記複数の部分計算のそれぞれを実行させる計算処理装置として、計算処理装置が設けられる地域における前記部分計算要求手段が前記部分計算を要求する時刻が夜間である計算処理装置を、当該時刻が昼間である計算処理装置より優先して選択する
請求項3記載の分散コンピューティングシステム。
The power rate information generation means generates the electricity rate information in association with each of the plurality of calculation processing devices based on a time zone in which the calculation process is performed and a time zone of the region determined by the region information,
The selection means is a calculation processing device that executes each of the plurality of partial calculations, a calculation processing device in which the partial calculation requesting means in the area where the calculation processing device is provided requests the partial calculation at night, The distributed computing system according to claim 3, wherein the time is selected with priority over a computing device that is daytime.
前記計算要求装置は、前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段を更に有し、
前記条件情報取得手段が、前記電力量条件情報として、所定の地域に設けられた複数の計算処理装置における単位時間当たりに消費する電力の上限を定める電力上限値を取得した場合において、
前記選択手段は、前記所定の地域における複数の計算処理装置が前記複数の部分計算を処理することにより単位時間当たりに消費する電力が、前記電力上限値以下である場合に、当該複数の部分計算のそれぞれに対応付けて、前記所定の地域における複数の計算処理装置を選択する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device further includes region information acquisition means for acquiring region information indicating which of the plurality of calculation processing devices is provided in a plurality of predetermined regions,
In the case where the condition information acquisition means acquires a power upper limit value that defines an upper limit of power consumed per unit time in a plurality of calculation processing devices provided in a predetermined area as the power amount condition information.
The selection unit is configured to output the plurality of partial calculations when a plurality of calculation processing devices in the predetermined area process the plurality of partial calculations and power consumed per unit time is equal to or less than the power upper limit value. The distributed computing system according to claim 1, wherein a plurality of computing devices in the predetermined area are selected in association with each of the plurality of computing devices.
前記複数の部分計算を処理させる計算処理装置として、同一の地域における複数の計算処理装置が選択された場合に、前記部分計算要求手段は、同一の地域における一の計算処理装置に部分計算を開始させる時間及び当該地域における他の計算処理装置に部分計算を開始させる時間を異ならせるべく、前記複数の部分計算のそれぞれを実行開始させるタイミングを調節する
請求項5記載の分散コンピューティングシステム。
When a plurality of calculation processing devices in the same region are selected as the calculation processing devices for processing the plurality of partial calculations, the partial calculation requesting unit starts partial calculation in one calculation processing device in the same region. The distributed computing system according to claim 5, wherein the timing for starting execution of each of the plurality of partial calculations is adjusted so that the time for starting and the time for starting the partial calculation by another calculation processing device in the region are different.
前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算に含まれるインストラクション数を解析する計算内容解析手段を更に有し、
前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較してインストラクション数が多い場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device further includes, for each of the plurality of partial calculations, a calculation content analysis unit that analyzes the number of instructions included in the partial calculation.
The power consumption index information generating means, for each of the plurality of partial calculations, when the partial calculation has a larger number of instructions than the other partial calculations, the partial calculation is consumed in comparison with the other partial calculations. The distributed computing system according to claim 1, wherein power consumption index information indicating that the amount of power is large is generated.
前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置がアクセスされるアクセス回数を解析する計算内容解析手段を更に有し、
前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較して前記アクセス回数が多い場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device further includes, for each of the plurality of partial calculations, a calculation content analysis unit that analyzes the number of accesses to which the input / output device is accessed in the partial calculation processing.
The power consumption index information generating means, for each of the plurality of partial calculations, when the partial calculation is larger in number of accesses compared to other partial calculations, the partial calculation is compared with other partial calculations. The distributed computing system according to claim 1, wherein power consumption index information indicating that the power consumption is large is generated.
前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算の処理において入出力装置が転送する転送データのサイズを解析する計算内容解析手段を更に有し、
前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算が他の部分計算と比較して前記転送データのサイズが大きい場合に、当該部分計算が他の部分計算と比較して消費電力量が大きい旨を示す消費電力指標情報を生成する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device further includes, for each of the plurality of partial calculations, a calculation content analysis unit that analyzes a size of transfer data transferred by the input / output device in the partial calculation processing.
The power consumption index information generating unit compares the partial calculation with each of the plurality of partial calculations when the size of the transfer data is larger than that of the partial calculation. The distributed computing system according to claim 1, wherein power consumption index information indicating that the power consumption is large is generated.
前記消費電力指標情報生成手段は、前記複数の部分計算のそれぞれについて、当該部分計算と同一の種類の処理であって、当該部分計算より処理時間が短い他の処理を実行した場合に消費する電力量に基づいて、消費電力指標情報を生成する
請求項1記載の分散コンピューティングシステム。
The power consumption index information generating means consumes power when each of the plurality of partial calculations is executed in the same type of process as the partial calculation and having a shorter processing time than the partial calculation. The distributed computing system according to claim 1, wherein power consumption index information is generated based on the amount.
前記計算要求装置は、前記複数の部分計算のそれぞれについて、当該部分計算が前記計算処理におけるクリティカルパスに含まれるか否かを解析する計算内容解析手段を更に有し、
前記選択手段は、前記電力量条件情報を満たす計算処理装置のうち、前記クリティカルパスに含まれない部分計算に対応付けて選択する計算処理装置と比較して、前記電力処理指標情報の示す消費電力量がより大きくかつ処理速度がより速い計算処理装置を前記クリティカルパスに含まれる部分計算に対応付けて選択する
請求項1記載の分散コンピューティングシステム。
The calculation requesting apparatus further includes, for each of the plurality of partial calculations, a calculation content analysis unit that analyzes whether the partial calculation is included in a critical path in the calculation process,
The selection means is a power consumption indicated by the power processing index information as compared with a calculation processing device selected in association with a partial calculation not included in the critical path among the calculation processing devices satisfying the power amount condition information. The distributed computing system according to claim 1, wherein a computing device having a larger amount and a faster processing speed is selected in association with a partial calculation included in the critical path.
前記計算処理装置は、前記部分計算処理手段が部分計算を処理した場合に消費した電力量を示す電力実消費量情報を、当該部分計算を識別する情報に対応付けて、前記計算要求装置に送信する実消費量送信手段を更に有し、
前記電力処理指標情報取得手段は、当該部分計算当たりの当該電力実消費量情報を、前記電力処理指標情報として前記実消費量送信手段から取得する
請求項1記載の分散コンピューティングシステム。
The calculation processing device transmits actual power consumption information indicating the amount of power consumed when the partial calculation processing means has processed the partial calculation to the calculation requesting device in association with information for identifying the partial calculation. And further having an actual consumption amount transmitting means,
The distributed computing system according to claim 1, wherein the power processing index information acquisition unit acquires the actual power consumption information per partial calculation from the actual consumption transmission unit as the power processing index information.
前記計算要求装置は、部分計算の種類と、当該部分計算の消費電力指標情報とを対応付けて格納する消費電力指標情報格納手段を更に有し、
前記複数の部分計算のそれぞれについて、当該部分計算の種類が前記消費電力指標情報格納手段に格納されている場合において、前記消費電力指標情報生成手段は、当該部分計算の種類に対応付けられた消費電力指標情報を前記消費電力指標情報格納手段から選択することにより、当該部分計算の消費電力指標情報を生成する
請求項1記載の分散コンピューティングシステム。
The calculation requesting device further includes power consumption index information storage means for storing the type of partial calculation and the power consumption index information of the partial calculation in association with each other,
For each of the plurality of partial calculations, when the type of the partial calculation is stored in the power consumption index information storage unit, the power consumption index information generation unit is configured to use the consumption associated with the type of partial calculation. The distributed computing system according to claim 1, wherein the power consumption index information of the partial calculation is generated by selecting power index information from the power consumption index information storage unit.
前記計算要求装置は、当該計算要求装置が既に行わせた計算処理の種類に、当該計算処理を行った計算処理装置の組を識別する情報を対応付けた情報を格納する要求履歴情報格納手段を更に有し、
前記部分計算要求手段は、実行するべき計算処理の種類に基づいて、計算処理の当該種類に対応付けられた計算処理装置の組を識別する情報を、前記要求履歴情報格納手段から検索し、検索した当該計算処理装置の組に当該計算処理を行わせる、
請求項1記載の分散コンピューティングシステム。
The calculation requesting device includes request history information storage means for storing information in which information for identifying a set of calculation processing devices that have performed the calculation processing is associated with a type of calculation processing that has already been performed by the calculation requesting device. In addition,
The partial calculation requesting unit searches the request history information storage unit for information for identifying a set of calculation processing devices associated with the type of calculation processing based on the type of calculation processing to be executed. Causing the set of calculation processing devices to perform the calculation processing,
The distributed computing system of claim 1.
前記部分計算要求手段は、より長い処理時間を要する部分計算を、より短い処理時間を要する部分計算より早く開始させる
請求項1記載の分散コンピューティングシステム。
The distributed computing system according to claim 1, wherein the partial calculation request unit starts a partial calculation that requires a longer processing time earlier than a partial calculation that requires a shorter processing time.
前記計算処理装置は、
当該計算処理装置が設けられた地域の総消費電力が、当該地域における最大供給可能電力のうち予め定められた割合に達したと判断した場合に、前記部分計算処理手段において処理する部分計算を、当該地域とは異なる地域に設けられた他の計算処理装置において実行させる部分計算再割当手段
を更に有する請求項1記載の分散コンピューティングシステム。
The calculation processing device includes:
When it is determined that the total power consumption in the area where the calculation processing device is provided has reached a predetermined ratio of the maximum suppliable power in the area, the partial calculation processed in the partial calculation processing means, 2. The distributed computing system according to claim 1, further comprising a partial calculation reassignment unit that is executed in another calculation processing device provided in an area different from the area.
前記複数の計算処理装置を分類した複数の処理装置グループのそれぞれに対応して設けられ、当該処理装置グループにおける各計算処理装置の電力処理指標情報を管理する下階層管理装置と、
複数の前記下階層管理装置を分類した複数の管理装置グループのそれぞれに対応して設けられ、当該管理装置グループにおける各下階層管理装置が管理する電力処理指標情報の最大値及び最小値の間の値である電力処理総合情報を管理する上階層管理装置と
を更に備え、
前記電力処理指標情報取得手段は、前記上階層管理装置から前記電力処理総合情報を、前記下階層管理装置から前記電力処理指標情報をそれぞれ取得し、
前記選択手段は、管理する電力処理総合情報の何れかが前記電力量条件情報を満たす上階層管理装置を選択し、当該上階層管理装置により管理される下階層管理装置のうち、管理する電力処理指標情報の何れかが前記電力量条件情報を満たす下階層管理装置を選択し、当該下階層管理装置により管理される計算処理装置のうち、前記電力量条件を満たす計算処理装置を選択する
請求項1記載の分散コンピューティングシステム。
A lower tier management device provided corresponding to each of a plurality of processing device groups into which the plurality of processing devices are classified, and managing power processing index information of each calculation processing device in the processing device group;
Between the maximum value and the minimum value of the power processing index information provided corresponding to each of the plurality of management device groups into which the plurality of lower layer management devices are classified, and managed by each lower layer management device in the management device group Further comprising an upper layer management device for managing power processing comprehensive information that is a value,
The power processing index information acquisition unit acquires the power processing comprehensive information from the upper tier management apparatus, and acquires the power processing index information from the lower tier management apparatus, respectively.
The selection unit selects an upper tier management device in which any of the managed power processing comprehensive information satisfies the power amount condition information, and manages the power processing to be managed among the lower tier management devices managed by the upper tier management device 5. A lower tier management device that satisfies any of the index information satisfies the power amount condition information, and selects a calculation processing device that satisfies the power amount among the calculation processing devices managed by the lower tier management device. 2. The distributed computing system according to 1.
予め定められた計算処理を構成する複数の部分計算をそれぞれ実行する複数の計算処理装置と、前記複数の計算処理装置に部分計算を要求する計算要求装置とを備える分散コンピューティングシステムであって、
前記計算要求装置は、
前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
を有し、
前記複数の計算処理装置のそれぞれは、
前記計算要求装置から要求された部分計算を処理する部分計算処理手段と、
前記部分計算の処理結果を前記計算要求装置に送信する処理結果送信手段と
を有する分散コンピューティングシステム。
A distributed computing system comprising: a plurality of calculation processing devices that respectively execute a plurality of partial calculations constituting a predetermined calculation process; and a calculation requesting device that requests partial calculations from the plurality of calculation processing devices,
The calculation requesting device is:
Stability information acquisition means for acquiring stability information indicating the stability of power supplied to the calculation processing device for each of the plurality of calculation processing devices;
Condition information acquisition means for acquiring stability condition information indicating a stability condition of electricity received when the plurality of calculation processing devices execute the plurality of partial calculations;
A selection that selects a calculation processing device that satisfies the stability condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations based on the stability information. Means,
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
Processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing;
Each of the plurality of calculation processing devices includes:
Partial calculation processing means for processing the partial calculation requested from the calculation requesting device;
A distributed computing system comprising processing result transmission means for transmitting the processing result of the partial calculation to the calculation requesting device.
前記安定性情報取得手段は、各計算処理装置における前記安定性情報として、当該計算処理装置が電池又は発電機による無停電電源装置により管理されているか否かを示す情報を取得する
請求項18記載の分散コンピューティングシステム。
The stability information acquisition unit acquires information indicating whether or not the calculation processing device is managed by an uninterruptible power supply using a battery or a generator as the stability information in each calculation processing device. Distributed computing system.
前記計算要求装置は、前記複数の計算処理装置のそれぞれが、予め定められた複数の地域のうち何れに設けられているかを示す地域情報を取得する地域情報取得手段を更に有し、
前記安定性情報取得手段は、各計算処理装置における前記安定性情報として、当該計算処理装置が設けられた地域に供給される電気の安定性を示す情報を取得する
請求項18記載の分散コンピューティングシステム。
The calculation requesting device further includes region information acquisition means for acquiring region information indicating which of the plurality of calculation processing devices is provided in a plurality of predetermined regions,
The distributed computing according to claim 18, wherein the stability information acquisition unit acquires information indicating stability of electricity supplied to an area where the calculation processing device is provided, as the stability information in each calculation processing device. system.
前記計算要求装置は、前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段を更に有し、
前記条件情報取得手段は、前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を更に取得し、
前記選択手段は、更に前記電力処理指標情報に基づいて、更に前記電力量条件情報を満たす計算処理装置を選択する
請求項18記載の分散コンピューティングシステム。
The calculation requesting device further includes power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the plurality of calculation processing devices,
The condition information acquisition unit further acquires power amount condition information indicating a condition to be satisfied by an amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations.
The distributed computing system according to claim 18, wherein the selection unit further selects a calculation processing device that further satisfies the power amount condition information based on the power processing index information.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置であって、
前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、
前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
を備える計算要求装置。
A calculation requesting device for causing a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing,
Power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the plurality of calculation processing devices;
For each of the plurality of partial calculations, power consumption index information generating means for generating power consumption index information indicating the amount of power required for the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device When,
Condition information acquisition means for acquiring power amount condition information indicating a condition to be satisfied by the amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations;
Corresponding to each of the plurality of partial calculations, a calculation processing device that satisfies the power amount condition information when executing the partial calculation among the plurality of calculation processing devices, the power processing index information and the power consumption index A selection means for selecting based on the information;
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
A calculation requesting device comprising processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置であって、
前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
を備える計算要求装置。
A calculation requesting device for causing a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing,
Stability information acquisition means for acquiring stability information indicating the stability of power supplied to the calculation processing device for each of the plurality of calculation processing devices;
Condition information acquisition means for acquiring stability condition information indicating a stability condition of electricity received when the plurality of calculation processing devices execute the plurality of partial calculations;
A selection that selects a calculation processing device that satisfies the stability condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations based on the stability information. Means,
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
A calculation requesting device comprising processing result output means for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを動作させる制御方法であって、
前記コンピュータにより、
前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得段階と、
前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成段階と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得段階と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択段階と、
前記複数の部分計算のそれぞれを、前記選択段階において当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求段階と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力段階と
を備える制御方法。
A control method for operating a computer as a calculation requesting device for causing a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing, respectively,
By the computer
For each of the plurality of calculation processing devices, a power processing index information acquisition step of acquiring power processing index information indicating power consumption per predetermined calculation processing amount;
For each of the plurality of partial calculations, a power consumption index information generation stage that generates power consumption index information indicating the amount of power required for the process of the partial calculation compared to the case where another partial calculation is processed in the same calculation processing device When,
A condition information acquisition stage for acquiring power amount condition information indicating a condition to be satisfied by an amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations;
Corresponding to each of the plurality of partial calculations, a calculation processing device that satisfies the power amount condition information when executing the partial calculation among the plurality of calculation processing devices, the power processing index information and the power consumption index A selection stage to select based on information;
A partial calculation request step for causing each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation in the selection step;
A control method comprising: a processing result output stage for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置として、コンピュータを動作させる制御方法であって、
前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得段階と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得段階と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択段階と、
前記複数の部分計算のそれぞれを、前記選択段階において当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求段階と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力段階と
を備える制御方法。
A control method for operating a computer as a calculation requesting device for causing a plurality of calculation processing devices to execute a plurality of partial calculations constituting a predetermined calculation processing, respectively,
For each of the plurality of calculation processing devices, a stability information acquisition step of acquiring stability information indicating the stability of power supplied to the calculation processing device;
A condition information acquisition step of acquiring stability condition information indicating a condition of stability of electricity received when the plurality of calculation processing devices execute the plurality of partial calculations;
A selection that selects a calculation processing device that satisfies the stability condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations based on the stability information. Stages,
A partial calculation request step for causing each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation in the selection step;
A control method comprising: a processing result output stage for outputting a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを機能させるプログラムであって、
前記コンピュータを、
前記複数の計算処理装置のそれぞれについて、所定の計算処理量当たりの消費電力を示す電力処理指標情報を取得する電力処理指標情報取得手段と、
前記複数の部分計算のそれぞれについて、同一の計算処理装置において他の部分計算を処理した場合と比較した当該部分計算の処理に要する電力量を示す消費電力指標情報を生成する消費電力指標情報生成手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に消費する電力量が満たすべき条件を示す電力量条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記電力量条件情報を満たす計算処理装置を、前記電力処理指標情報及び前記消費電力指標情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
して機能させるプログラム。
A program that causes a computer to function as a calculation requesting device that causes a plurality of calculation processing devices to execute a plurality of partial calculations constituting predetermined calculation processing,
The computer,
Power processing index information acquisition means for acquiring power processing index information indicating power consumption per predetermined calculation processing amount for each of the plurality of calculation processing devices;
For each of the plurality of partial calculations, power consumption index information generating means for generating power consumption index information indicating the amount of power required for the partial calculation compared with the case where another partial calculation is processed in the same calculation processing device When,
Condition information acquisition means for acquiring power amount condition information indicating a condition to be satisfied by the amount of power consumed when the plurality of calculation processing devices execute the plurality of partial calculations;
Corresponding to each of the plurality of partial calculations, a calculation processing device that satisfies the power amount condition information when executing the partial calculation among the plurality of calculation processing devices, the power processing index information and the power consumption index A selection means for selecting based on the information;
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
A program that functions as a processing result output unit that outputs a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
複数の計算処理装置に、予め定められた計算処理を構成する複数の部分計算をそれぞれ実行させる計算要求装置としてコンピュータを機能させるプログラムであって、
前記コンピュータを、
前記複数の計算処理装置のそれぞれについて、当該計算処理装置に供給される電力の安定性を示す安定性情報を取得する安定性情報取得手段と、
前記複数の計算処理装置が前記複数の部分計算を実行する場合に供給を受ける電気の安定性の条件を示す安定性条件情報を取得する条件情報取得手段と、
前記複数の部分計算のそれぞれに対応付けて、前記複数の計算処理装置のうち当該部分計算を実行する場合に前記安定性条件情報を満たす計算処理装置を、前記安定性情報に基づいて選択する選択手段と、
前記複数の部分計算のそれぞれを、前記選択手段により当該部分計算に対応付けて選択された計算処理装置に行わせる部分計算要求手段と、
前記複数の計算処理装置から受け取った部分計算の結果の組を、前記計算処理の結果として出力する処理結果出力手段と
して機能させるプログラム。
A program that causes a computer to function as a calculation requesting device that causes a plurality of calculation processing devices to execute a plurality of partial calculations constituting predetermined calculation processing,
The computer,
Stability information acquisition means for acquiring stability information indicating the stability of power supplied to the calculation processing device for each of the plurality of calculation processing devices;
Condition information acquisition means for acquiring stability condition information indicating a stability condition of electricity received when the plurality of calculation processing devices execute the plurality of partial calculations;
A selection that selects a calculation processing device that satisfies the stability condition information when executing the partial calculation among the plurality of calculation processing devices in association with each of the plurality of partial calculations based on the stability information. Means,
A partial calculation requesting unit that causes each of the plurality of partial calculations to be performed by the calculation processing device selected in association with the partial calculation by the selection unit;
A program that functions as a processing result output unit that outputs a set of partial calculation results received from the plurality of calculation processing devices as a result of the calculation processing.
請求項26又は請求項27記載のプログラムを記録した記録媒体。   A recording medium on which the program according to claim 26 or 27 is recorded.
JP2003290814A 2003-08-08 2003-08-08 Distributed computing system Expired - Fee Related JP3896352B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2003290814A JP3896352B2 (en) 2003-08-08 2003-08-08 Distributed computing system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2003290814A JP3896352B2 (en) 2003-08-08 2003-08-08 Distributed computing system

Publications (2)

Publication Number Publication Date
JP2005063066A true JP2005063066A (en) 2005-03-10
JP3896352B2 JP3896352B2 (en) 2007-03-22

Family

ID=34368722

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2003290814A Expired - Fee Related JP3896352B2 (en) 2003-08-08 2003-08-08 Distributed computing system

Country Status (1)

Country Link
JP (1) JP3896352B2 (en)

Cited By (16)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2006344162A (en) * 2005-06-10 2006-12-21 Mitsubishi Electric Corp Parallel computer
JP2008047126A (en) * 2006-08-15 2008-02-28 Internatl Business Mach Corp <Ibm> Affinity dispatching load balancer with precise cpu consumption data
JP2009252056A (en) * 2008-04-09 2009-10-29 Hitachi Ltd Method and device for operation management of information-processing system
JP2010039513A (en) * 2008-07-31 2010-02-18 Internatl Business Mach Corp <Ibm> System and method for estimating power consumption
US7774630B2 (en) 2006-05-22 2010-08-10 Hitachi, Ltd. Method, computing system, and computer program for reducing power consumption of a computing system by relocating jobs and deactivating idle servers
JP2011087355A (en) * 2009-10-13 2011-04-28 Hitachi Ltd Distributed computer system and method for operating the same
EP2330505A1 (en) * 2008-09-17 2011-06-08 Hitachi, Ltd. Operation management method of information processing system
JP2011518393A (en) * 2008-04-21 2011-06-23 アダプティブ コンピューティング エンタープライジズ インク System and method for managing energy consumption in a computing environment
EP2343649A1 (en) * 2008-10-30 2011-07-13 Hitachi, Ltd. Operation management apparatus of information processing system
JP2011243119A (en) * 2010-05-20 2011-12-01 Fujitsu Ltd Power leveling method, system and program
JP2013501998A (en) * 2009-08-13 2013-01-17 エンパイア テクノロジー ディベロップメント エルエルシー Task scheduling based on financial impact
US8516441B2 (en) 2007-03-08 2013-08-20 Fujitsu Semiconductor Limited Software optimization device and software optimization method
JP5596343B2 (en) * 2007-04-13 2014-09-24 日本電気株式会社 Virtual computer system and optimization method thereof
JP2015537309A (en) * 2012-12-28 2015-12-24 インテル コーポレイション Power optimization for distributed computing systems
US9405348B2 (en) 2008-04-21 2016-08-02 Adaptive Computing Enterprises, Inc System and method for managing energy consumption in a compute environment
CN117971509A (en) * 2024-04-01 2024-05-03 上海燧原科技股份有限公司 Heterogeneous computing power cluster operation performance optimization method, heterogeneous computing power cluster operation performance optimization device, heterogeneous computing power cluster operation performance optimization equipment and medium

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH10187636A (en) * 1996-12-24 1998-07-21 Nec Corp Power-consumption reducing cluster system
JP2000214238A (en) * 1999-01-22 2000-08-04 Toshiba Corp Device and method for calculating battery drive expected time
JP2000267766A (en) * 1999-03-12 2000-09-29 Nec Corp Power consumption management system
JP2001503170A (en) * 1996-09-16 2001-03-06 ザ リサーチ ファウンデーション オブ ステイト ユニヴァーシティ オブ ニューヨーク Load distribution controller to optimize financial costs
JP2002287857A (en) * 2001-03-23 2002-10-04 Yuasa Corp Uninterruptive power supply and battery replacement promotion system
JP2002292977A (en) * 2001-03-30 2002-10-09 Minolta Co Ltd Imaging apparatus, system and program for limiting power consumption

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2001503170A (en) * 1996-09-16 2001-03-06 ザ リサーチ ファウンデーション オブ ステイト ユニヴァーシティ オブ ニューヨーク Load distribution controller to optimize financial costs
JPH10187636A (en) * 1996-12-24 1998-07-21 Nec Corp Power-consumption reducing cluster system
JP2000214238A (en) * 1999-01-22 2000-08-04 Toshiba Corp Device and method for calculating battery drive expected time
JP2000267766A (en) * 1999-03-12 2000-09-29 Nec Corp Power consumption management system
JP2002287857A (en) * 2001-03-23 2002-10-04 Yuasa Corp Uninterruptive power supply and battery replacement promotion system
JP2002292977A (en) * 2001-03-30 2002-10-09 Minolta Co Ltd Imaging apparatus, system and program for limiting power consumption

Cited By (27)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2006344162A (en) * 2005-06-10 2006-12-21 Mitsubishi Electric Corp Parallel computer
US7774630B2 (en) 2006-05-22 2010-08-10 Hitachi, Ltd. Method, computing system, and computer program for reducing power consumption of a computing system by relocating jobs and deactivating idle servers
US7783909B2 (en) 2006-05-22 2010-08-24 Hitachi, Ltd. Method, computing system, and computer program for reducing power consumption of a computing system by relocating jobs and deactivating idle servers
JP2008047126A (en) * 2006-08-15 2008-02-28 Internatl Business Mach Corp <Ibm> Affinity dispatching load balancer with precise cpu consumption data
US8516441B2 (en) 2007-03-08 2013-08-20 Fujitsu Semiconductor Limited Software optimization device and software optimization method
US9104494B2 (en) 2007-04-13 2015-08-11 Nec Corporation Virtual computer system and its optimization method
JP5596343B2 (en) * 2007-04-13 2014-09-24 日本電気株式会社 Virtual computer system and optimization method thereof
JP4724730B2 (en) * 2008-04-09 2011-07-13 株式会社日立製作所 Information processing system operation management method, operation management program, operation management apparatus, and information processing system
JP2009252056A (en) * 2008-04-09 2009-10-29 Hitachi Ltd Method and device for operation management of information-processing system
US9405348B2 (en) 2008-04-21 2016-08-02 Adaptive Computing Enterprises, Inc System and method for managing energy consumption in a compute environment
US9411393B2 (en) 2008-04-21 2016-08-09 Adaptive Computing Enterprises, Inc. System and method for managing energy consumption in a compute environment
JP2011518393A (en) * 2008-04-21 2011-06-23 アダプティブ コンピューティング エンタープライジズ インク System and method for managing energy consumption in a computing environment
US9026807B2 (en) 2008-04-21 2015-05-05 Adaptive Computing Enterprises, In. System and method for managing energy consumption in a compute environment
JP2010039513A (en) * 2008-07-31 2010-02-18 Internatl Business Mach Corp <Ibm> System and method for estimating power consumption
EP2330505A1 (en) * 2008-09-17 2011-06-08 Hitachi, Ltd. Operation management method of information processing system
JP4751962B2 (en) * 2008-09-17 2011-08-17 株式会社日立製作所 Operation management method of information processing system
JPWO2010032501A1 (en) * 2008-09-17 2012-02-09 株式会社日立製作所 Operation management method of information processing system
US8145927B2 (en) 2008-09-17 2012-03-27 Hitachi, Ltd. Operation management method of information processing system
EP2330505A4 (en) * 2008-09-17 2012-08-15 Hitachi Ltd Operation management method of information processing system
US8127298B2 (en) 2008-10-30 2012-02-28 Hitachi, Ltd. Operations management apparatus of information-processing system
EP2343649A4 (en) * 2008-10-30 2012-08-22 Hitachi Ltd Operation management apparatus of information processing system
EP2343649A1 (en) * 2008-10-30 2011-07-13 Hitachi, Ltd. Operation management apparatus of information processing system
JP2013501998A (en) * 2009-08-13 2013-01-17 エンパイア テクノロジー ディベロップメント エルエルシー Task scheduling based on financial impact
JP2011087355A (en) * 2009-10-13 2011-04-28 Hitachi Ltd Distributed computer system and method for operating the same
JP2011243119A (en) * 2010-05-20 2011-12-01 Fujitsu Ltd Power leveling method, system and program
JP2015537309A (en) * 2012-12-28 2015-12-24 インテル コーポレイション Power optimization for distributed computing systems
CN117971509A (en) * 2024-04-01 2024-05-03 上海燧原科技股份有限公司 Heterogeneous computing power cluster operation performance optimization method, heterogeneous computing power cluster operation performance optimization device, heterogeneous computing power cluster operation performance optimization equipment and medium

Also Published As

Publication number Publication date
JP3896352B2 (en) 2007-03-22

Similar Documents

Publication Publication Date Title
JP3896352B2 (en) Distributed computing system
Arshad et al. Utilizing power consumption and SLA violations using dynamic VM consolidation in cloud data centers
US8402140B2 (en) Methods and apparatus for coordinated energy management in virtualized data centers
US9557792B1 (en) Datacenter power management optimizations
US10146289B2 (en) Power system utilizing processor core performance state control
US8473768B2 (en) Power control apparatus and method for cluster system
US9436256B2 (en) Dynamic CPU voltage regulator phase shedding
US20120030356A1 (en) Maximizing efficiency in a cloud computing environment
WO2023015788A1 (en) Serverless computing resource allocation system for energy consumption optimization
Rajabzadeh et al. Energy-aware framework with Markov chain-based parallel simulated annealing algorithm for dynamic management of virtual machines in cloud data centers
Li et al. Energy-efficient and QoS-aware model based resource consolidation in cloud data centers
Zhang et al. An Energy and SLA‐Aware Resource Management Strategy in Cloud Data Centers
Dias et al. A systematic literature review on virtual machine consolidation
He et al. Energy-efficient framework for virtual machine consolidation in cloud data centers
Xu et al. Energy-Aware Resource Management in Cloud Computing Considering Load Balance.
Terzopoulos et al. Performance evaluation of a real-time grid system using power-saving capable processors
KR102129389B1 (en) Method and Apparatus for VM placement based on multi-objective in cloud computing environment
Deiab et al. Energy efficiency in cloud computing
US8281159B1 (en) Systems and methods for managing power usage based on power-management information from a power grid
CN117827429A (en) Heterogeneous computing power scene-oriented data processing method and system
Fan et al. GreenSleep: a multi-sleep modes based scheduling of servers for cloud data center
Cai et al. Greensprint: Effective computational sprinting in green data centers
US9052904B1 (en) System and method for determining whether to reschedule malware scans based on power-availability information for a power grid and power-usage information for the scans
CN105068871B (en) The control method and device of calculation resources
Rezai et al. Energy aware resource management of cloud data centers

Legal Events

Date Code Title Description
A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20060727

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20060801

A521 Written amendment

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20061027

TRDD Decision of grant or rejection written
A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

Effective date: 20061212

RD14 Notification of resignation of power of sub attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7434

Effective date: 20061212

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20061218

R150 Certificate of patent or registration of utility model

Free format text: JAPANESE INTERMEDIATE CODE: R150

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20091222

Year of fee payment: 3

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20101222

Year of fee payment: 4

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20101222

Year of fee payment: 4

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20111222

Year of fee payment: 5

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20111222

Year of fee payment: 5

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20121222

Year of fee payment: 6

LAPS Cancellation because of no payment of annual fees