JPH11338834A - 同期型並列処理システムおよび同期型並列処理方法 - Google Patents
同期型並列処理システムおよび同期型並列処理方法Info
- Publication number
- JPH11338834A JPH11338834A JP14409798A JP14409798A JPH11338834A JP H11338834 A JPH11338834 A JP H11338834A JP 14409798 A JP14409798 A JP 14409798A JP 14409798 A JP14409798 A JP 14409798A JP H11338834 A JPH11338834 A JP H11338834A
- Authority
- JP
- Japan
- Prior art keywords
- processing
- data
- data processing
- computers
- processing units
- 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.)
- Pending
Links
- 230000001360 synchronised effect Effects 0.000 title claims abstract description 38
- 238000003672 processing method Methods 0.000 title claims description 6
- 230000002159 abnormal effect Effects 0.000 claims abstract description 9
- 238000009826 distribution Methods 0.000 claims description 21
- 238000002360 preparation method Methods 0.000 claims description 10
- 238000003745 diagnosis Methods 0.000 claims 1
- 238000000034 method Methods 0.000 description 36
- 230000008569 process Effects 0.000 description 34
- 230000010365 information processing Effects 0.000 description 15
- 230000004044 response Effects 0.000 description 7
- 230000006872 improvement Effects 0.000 description 6
- 238000010586 diagram Methods 0.000 description 5
- 238000007781 pre-processing Methods 0.000 description 4
- 230000008859 change Effects 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 238000004519 manufacturing process Methods 0.000 description 2
- 230000003139 buffering effect Effects 0.000 description 1
- 238000004904 shortening Methods 0.000 description 1
Landscapes
- Multi Processors (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
(57)【要約】
【課題】関連性を有する複数個の処理単位を含んだデー
タ処理を複数台のコンピュータで並列に実行する同期型
並列処理システムを提供する。 【解決方法】データ処理要求の受け付け窓口となるコン
ピュータａは、まず、要求されたデータ処理に含まれる
複数個の処理単位（処理（１）〜（４））それぞれを独
立して実行するために必要となる情報を準備し、その準
備した情報を添付して、コンピュータｃ〜ｆそれぞれに
処理単位を分配する。そして、コンピュータａは、分配
した処理単位すべての正常終了が報告されたかどうか診
断し、すべての正常終了が報告された場合には、コンピ
ュータｂで動作するデータベースシステムに対し、その
データ処理に関するデータ更新の確定を指示する。ま
た、いずれかの異常終了が報告された場合には、コンピ
ュータｂで動作するデータベースシステムに対し、その
データ処理に関するデータ更新の破棄を指示する。
タ処理を複数台のコンピュータで並列に実行する同期型
並列処理システムを提供する。 【解決方法】データ処理要求の受け付け窓口となるコン
ピュータａは、まず、要求されたデータ処理に含まれる
複数個の処理単位（処理（１）〜（４））それぞれを独
立して実行するために必要となる情報を準備し、その準
備した情報を添付して、コンピュータｃ〜ｆそれぞれに
処理単位を分配する。そして、コンピュータａは、分配
した処理単位すべての正常終了が報告されたかどうか診
断し、すべての正常終了が報告された場合には、コンピ
ュータｂで動作するデータベースシステムに対し、その
データ処理に関するデータ更新の確定を指示する。ま
た、いずれかの異常終了が報告された場合には、コンピ
ュータｂで動作するデータベースシステムに対し、その
データ処理に関するデータ更新の破棄を指示する。
Description
【０００１】
【発明の属する技術分野】この発明は、たとえば預金支
払い処理や在庫移動処理などといった、関連性を有する
複数個の処理単位を含んだデータ処理を複数台のコンピ
ュータで並列に実行する同期型並列処理システムおよび
同システムに適用される同期型並列処理方法に関する。
払い処理や在庫移動処理などといった、関連性を有する
複数個の処理単位を含んだデータ処理を複数台のコンピ
ュータで並列に実行する同期型並列処理システムおよび
同システムに適用される同期型並列処理方法に関する。
【０００２】
【従来の技術】近年のコンピュータの普及は目覚まし
く、様々な業種で情報の電子化が進められており、この
電子化された情報を処理するデータ処理システムが種々
開発され運用されている。
く、様々な業種で情報の電子化が進められており、この
電子化された情報を処理するデータ処理システムが種々
開発され運用されている。
【０００３】一般に、このようなデータ処理システムで
要求されるデータ処理には、複数個の処理単位が含まれ
ることが多く、かつ、これら複数個の処理単位それぞれ
で実行されるデータ更新の確定／破棄は、その処理単位
が帰属するデータ処理ごとに統一されていなければなら
ないため、データ処理能力を向上させるべく、複数台の
コンピュータを用いてデータ処理システムを構築する場
合には、たとえば図５に示すように、データ更新の整合
性を確保すべき処理単位群（Ａ処理〜Ｅ処理）を組と
し、この組単位で振り分けを実施することによって、整
合性を確保しつつ負荷分散を実現するといった形態が採
られることが多い。
要求されるデータ処理には、複数個の処理単位が含まれ
ることが多く、かつ、これら複数個の処理単位それぞれ
で実行されるデータ更新の確定／破棄は、その処理単位
が帰属するデータ処理ごとに統一されていなければなら
ないため、データ処理能力を向上させるべく、複数台の
コンピュータを用いてデータ処理システムを構築する場
合には、たとえば図５に示すように、データ更新の整合
性を確保すべき処理単位群（Ａ処理〜Ｅ処理）を組と
し、この組単位で振り分けを実施することによって、整
合性を確保しつつ負荷分散を実現するといった形態が採
られることが多い。
【０００４】この図５に示したシステムは、ａ〜ｎの複
数台のコンピュータがネットワークによって疎結合され
た分散処理システムであり、コンピュータａが、データ
処理要求の受け付け窓口となって要求されたデータ処理
を複数台のコンピュータｃ〜ｎに振り分ける。また、コ
ンピュータｂは、これらのデータ処理の実行によって更
新されるデータを一元的に管理する。そして、コンピュ
ータｃ〜ｎは、コンピュータａから自身宛てに振り分け
られたデータ処理（Ａ処理〜Ｅ処理）を実行するととも
に、その実行結果をコンピュータａに報告する。なお、
この図５に示したシステムでは、コンピュータｃ〜ｎで
実行される処理単位間（たとえばＡ処理とＢ処理との
間）の引き継ぎを、インターフェースデータを介在させ
ることで実行する。また、ここでいう引き継ぎとは、後
工程の処理単位を実行するために必要な情報を前工程の
処理単位が提供することをいう。
数台のコンピュータがネットワークによって疎結合され
た分散処理システムであり、コンピュータａが、データ
処理要求の受け付け窓口となって要求されたデータ処理
を複数台のコンピュータｃ〜ｎに振り分ける。また、コ
ンピュータｂは、これらのデータ処理の実行によって更
新されるデータを一元的に管理する。そして、コンピュ
ータｃ〜ｎは、コンピュータａから自身宛てに振り分け
られたデータ処理（Ａ処理〜Ｅ処理）を実行するととも
に、その実行結果をコンピュータａに報告する。なお、
この図５に示したシステムでは、コンピュータｃ〜ｎで
実行される処理単位間（たとえばＡ処理とＢ処理との
間）の引き継ぎを、インターフェースデータを介在させ
ることで実行する。また、ここでいう引き継ぎとは、後
工程の処理単位を実行するために必要な情報を前工程の
処理単位が提供することをいう。
【０００５】そして、コンピュータａは、要求されたデ
ータ処理の振り分け先であるコンピュータｃ〜ｎからの
結果報告に応答して、そのデータ処理に関するデータ更
新の確定／破棄をコンピュータｂに指示する。これによ
り、データ処理に含まれる複数個の処理単位それぞれで
実行されるデータ更新の確定／破棄の統一を確保しつつ
負荷分散が実現されることになる。
ータ処理の振り分け先であるコンピュータｃ〜ｎからの
結果報告に応答して、そのデータ処理に関するデータ更
新の確定／破棄をコンピュータｂに指示する。これによ
り、データ処理に含まれる複数個の処理単位それぞれで
実行されるデータ更新の確定／破棄の統一を確保しつつ
負荷分散が実現されることになる。
【０００６】一方、図６には、インターフェースデータ
を介在させることに代えて、前工程の処理単位が後工程
の処理単位を起動することによって処理単位間の引き継
ぎを実行する形態のデータ処理システムが示されてい
る。
を介在させることに代えて、前工程の処理単位が後工程
の処理単位を起動することによって処理単位間の引き継
ぎを実行する形態のデータ処理システムが示されてい
る。
【０００７】この図６に示したシステムは、ａ〜ｇの複
数台のコンピュータがネットワークによって疎結合され
た分散処理システムであり、コンピュータａが、データ
処理要求の受け付け窓口となってコンピュータｃのＡ処
理を起動する。次に、コンピュータｃのＡ処理は、その
処理が正常終了した際に、さらにコンピュータｄのＢ処
理を起動する。このとき、コンピュータｃのＡ処理は、
たとえば起動時パラメータなどを用いることによって、
コンピュータｄのＢ処理との間の引き継ぎを実行する。
同様に、コンピュータｄのＢ処理はコンピュータｅのＣ
処理を、コンピュータｅのＣ処理はコンピュータｆのＤ
処理を、コンピュータｆのＤ処理はコンピュータｇのＥ
処理を、その処理が正常終了した際に起動していく。そ
して、コンピュータａは、コンピュータｃ〜ｇからの結
果報告に応答して、そのデータ処理に関するデータ更新
の確定／破棄をコンピュータｂに指示する。これによ
り、図５に示したデータ処理システムと同様、データ処
理に含まれる複数個の処理単位それぞれで実行されるデ
ータ更新の確定／破棄の統一を確保しつつ負荷分散が実
現されることになる。
数台のコンピュータがネットワークによって疎結合され
た分散処理システムであり、コンピュータａが、データ
処理要求の受け付け窓口となってコンピュータｃのＡ処
理を起動する。次に、コンピュータｃのＡ処理は、その
処理が正常終了した際に、さらにコンピュータｄのＢ処
理を起動する。このとき、コンピュータｃのＡ処理は、
たとえば起動時パラメータなどを用いることによって、
コンピュータｄのＢ処理との間の引き継ぎを実行する。
同様に、コンピュータｄのＢ処理はコンピュータｅのＣ
処理を、コンピュータｅのＣ処理はコンピュータｆのＤ
処理を、コンピュータｆのＤ処理はコンピュータｇのＥ
処理を、その処理が正常終了した際に起動していく。そ
して、コンピュータａは、コンピュータｃ〜ｇからの結
果報告に応答して、そのデータ処理に関するデータ更新
の確定／破棄をコンピュータｂに指示する。これによ
り、図５に示したデータ処理システムと同様、データ処
理に含まれる複数個の処理単位それぞれで実行されるデ
ータ更新の確定／破棄の統一を確保しつつ負荷分散が実
現されることになる。
【０００８】
【発明が解決しようとする課題】ところで、図５および
図６に示したような形態のデータ処理システムは、要求
されたデータ処理を大量に実行するための分散処理シス
テムとしては有効に機能しているが、要求されたデータ
処理それぞれの応答時間を短縮するための並列処理シス
テムとしては有効に機能していないといった問題があっ
た。
図６に示したような形態のデータ処理システムは、要求
されたデータ処理を大量に実行するための分散処理シス
テムとしては有効に機能しているが、要求されたデータ
処理それぞれの応答時間を短縮するための並列処理シス
テムとしては有効に機能していないといった問題があっ
た。
【０００９】また、要求されたデータ処理に含まれる複
数個の処理単位が情報を引き継ぎながら多段階に実行さ
れているため、いずれかの処理単位での改良が後工程の
処理単位に影響してしまい、仕様変更などに柔軟に対応
することができないといった問題があった。
数個の処理単位が情報を引き継ぎながら多段階に実行さ
れているため、いずれかの処理単位での改良が後工程の
処理単位に影響してしまい、仕様変更などに柔軟に対応
することができないといった問題があった。
【００１０】この発明はこのような実情に鑑みてなされ
たものであり、関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムおよび同システムに適用される
同期型並列処理方法を提供することを目的とする。
たものであり、関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムおよび同システムに適用される
同期型並列処理方法を提供することを目的とする。
【００１１】
【課題を解決するための手段】前述した目的を達成する
ために、この発明は、まず、前処理として、要求された
データ処理に含まれる複数個の処理単位それぞれを独立
して実行するために必要となる情報をすべて準備し、そ
の準備した情報を添付して、そのデータ処理に含まれる
複数個の処理単位を複数台のコンピュータに分配するよ
うにしたものである。そして、この発明は、その分配し
た複数個の処理単位すべての正常終了が報告されたとき
に、複数台のコンピュータそれぞれで実行されたそのデ
ータ処理に関するデータ更新の確定をデータベースシス
テムに指示し、一方、分配した複数個の処理単位の中の
いずれかの異常終了が報告されたときには、複数台のコ
ンピュータそれぞれで実行されたそのデータ処理に関す
るデータ更新の破棄をデータベースシステムに指示する
ようにしたものである。
ために、この発明は、まず、前処理として、要求された
データ処理に含まれる複数個の処理単位それぞれを独立
して実行するために必要となる情報をすべて準備し、そ
の準備した情報を添付して、そのデータ処理に含まれる
複数個の処理単位を複数台のコンピュータに分配するよ
うにしたものである。そして、この発明は、その分配し
た複数個の処理単位すべての正常終了が報告されたとき
に、複数台のコンピュータそれぞれで実行されたそのデ
ータ処理に関するデータ更新の確定をデータベースシス
テムに指示し、一方、分配した複数個の処理単位の中の
いずれかの異常終了が報告されたときには、複数台のコ
ンピュータそれぞれで実行されたそのデータ処理に関す
るデータ更新の破棄をデータベースシステムに指示する
ようにしたものである。
【００１２】すなわち、この発明によれば、要求された
データ処理を大量に実行するための分散処理システムと
して機能するだけでなく、要求されたデータ処理それぞ
れの応答時間を短縮するための並列処理システムとして
も有効に機能する同期型並列処理システムが実現される
ことになる。
データ処理を大量に実行するための分散処理システムと
して機能するだけでなく、要求されたデータ処理それぞ
れの応答時間を短縮するための並列処理システムとして
も有効に機能する同期型並列処理システムが実現される
ことになる。
【００１３】また、この発明によれば、要求されたデー
タ処理に含まれる複数個の処理単位それぞれが独立して
実行されるため、すべての処理単位をコンポーネント化
することが可能となり、いずれかの処理単位での改良を
他の処理単位に影響させることもなく、仕様変更などに
も柔軟に対応することができるようになる。
タ処理に含まれる複数個の処理単位それぞれが独立して
実行されるため、すべての処理単位をコンポーネント化
することが可能となり、いずれかの処理単位での改良を
他の処理単位に影響させることもなく、仕様変更などに
も柔軟に対応することができるようになる。
【００１４】
【発明の実施の形態】以下、図面を参照してこの発明の
実施の形態を説明する。図１は、この発明の実施形態に
係る同期型並列処理システムの概略構成および機能ブロ
ックを示す図である。
実施の形態を説明する。図１は、この発明の実施形態に
係る同期型並列処理システムの概略構成および機能ブロ
ックを示す図である。
【００１５】図１に示すように、この実施形態のコンピ
ュータシステムは、ａ〜ｆの複数台のコンピュータがネ
ットワークによって疎結合された分散処理システムであ
り、コンピュータａが、データ処理要求の受け付け窓口
となっている。なお、この要求されるデータ処理には、
関連性を有する複数個の処理単位（処理（１）〜処理
（４））が含まれるものとする。また、コンピュータｂ
では、この要求されたデータ処理の実行によって更新さ
れるデータを一元的に管理するデータベースシステムが
動作する。そして、コンピュータｃ〜ｆでは、この要求
されるデータ処理に含まれる複数個の処理単位（処理
（１）〜処理（４））の中のいずれかの処理単位が実行
される。具体的には、コンピュータｃでは処理（１）
が、コンピュータｄでは処理（２）が、コンピュータｅ
では処理（３）が、コンピュータｆでは処理（４）が、
それぞれ実行される。
ュータシステムは、ａ〜ｆの複数台のコンピュータがネ
ットワークによって疎結合された分散処理システムであ
り、コンピュータａが、データ処理要求の受け付け窓口
となっている。なお、この要求されるデータ処理には、
関連性を有する複数個の処理単位（処理（１）〜処理
（４））が含まれるものとする。また、コンピュータｂ
では、この要求されたデータ処理の実行によって更新さ
れるデータを一元的に管理するデータベースシステムが
動作する。そして、コンピュータｃ〜ｆでは、この要求
されるデータ処理に含まれる複数個の処理単位（処理
（１）〜処理（４））の中のいずれかの処理単位が実行
される。具体的には、コンピュータｃでは処理（１）
が、コンピュータｄでは処理（２）が、コンピュータｅ
では処理（３）が、コンピュータｆでは処理（４）が、
それぞれ実行される。
【００１６】この実施形態の同期型並列処理システムで
は、データ処理要求をコンピュータａが受け付けると、
まず、コンピュータａで、この要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））それ
ぞれを独立して実行するために必要となる情報を準備す
る。このコンピュータａによる準備工程が、この発明の
第１の特徴点とするところであり、この準備処理が終了
すると、コンピュータａは、その準備した情報を添付し
て、コンピュータｃ〜ｆそれぞれに処理単位（処理
（１）〜（４））を分配、すなわち、処理単位（処理
（１）〜（４））の実行を依頼する。
は、データ処理要求をコンピュータａが受け付けると、
まず、コンピュータａで、この要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））それ
ぞれを独立して実行するために必要となる情報を準備す
る。このコンピュータａによる準備工程が、この発明の
第１の特徴点とするところであり、この準備処理が終了
すると、コンピュータａは、その準備した情報を添付し
て、コンピュータｃ〜ｆそれぞれに処理単位（処理
（１）〜（４））を分配、すなわち、処理単位（処理
（１）〜（４））の実行を依頼する。
【００１７】一方、この分配を受けたコンピュータｃ〜
ｆでは、添付された情報を用いて自身が担当する処理単
位（処理（１）〜（４））を他の処理単位からは独立さ
せて実行し、その結果をコンピュータａに報告する。
ｆでは、添付された情報を用いて自身が担当する処理単
位（処理（１）〜（４））を他の処理単位からは独立さ
せて実行し、その結果をコンピュータａに報告する。
【００１８】ここで、コンピュータａでは、分配した処
理単位（処理（１）〜（４））すべての正常終了がコン
ピュータｃ〜ｆから報告されたかどうか診断する。この
コンピュータａによる診断工程が、この発明の第２の特
徴点とするところであり、すべての正常終了が報告され
た場合には、コンピュータｂで動作するデータベースシ
ステムに対して、そのデータ処理に関するデータ更新の
確定（ＤＢ実更新）を指示する。また、いずれかの異常
終了が報告された場合には、コンピュータｂで動作する
データベースシステムに対して、そのデータ処理に関す
るデータ更新の破棄（ＤＢ解除）を指示する。
理単位（処理（１）〜（４））すべての正常終了がコン
ピュータｃ〜ｆから報告されたかどうか診断する。この
コンピュータａによる診断工程が、この発明の第２の特
徴点とするところであり、すべての正常終了が報告され
た場合には、コンピュータｂで動作するデータベースシ
ステムに対して、そのデータ処理に関するデータ更新の
確定（ＤＢ実更新）を指示する。また、いずれかの異常
終了が報告された場合には、コンピュータｂで動作する
データベースシステムに対して、そのデータ処理に関す
るデータ更新の破棄（ＤＢ解除）を指示する。
【００１９】このように、コンピュータａが、要求され
たデータ処理に含まれる複数個の処理単位（処理（１）
〜（４））それぞれを独立して実行するために必要とな
る情報を準備する工程と、分配した処理単位（処理
（１）〜（４））すべての正常終了が報告されたかどう
か診断する工程とをもつことにより、この実施形態の同
期型並列処理システムは、要求されたデータ処理を大量
に実行するための分散処理システムとして機能するだけ
でなく、要求されたデータ処理それぞれの応答時間を短
縮するための並列処理システムとしても有効に機能する
こととなり、また、要求されたデータ処理に含まれる複
数個の処理単位（処理（１）〜（４））それぞれで実行
されるデータ更新の確定／破棄の統一を損なうこともな
い。さらに、すべての処理単位（処理（１）〜（４））
を独立させることにより、処理単位のコンポーネント化
を図ることができ、いずれかの処理単位での改良を他の
処理単位に影響させることもないため、仕様変更などに
も柔軟に対応することが可能となる。
たデータ処理に含まれる複数個の処理単位（処理（１）
〜（４））それぞれを独立して実行するために必要とな
る情報を準備する工程と、分配した処理単位（処理
（１）〜（４））すべての正常終了が報告されたかどう
か診断する工程とをもつことにより、この実施形態の同
期型並列処理システムは、要求されたデータ処理を大量
に実行するための分散処理システムとして機能するだけ
でなく、要求されたデータ処理それぞれの応答時間を短
縮するための並列処理システムとしても有効に機能する
こととなり、また、要求されたデータ処理に含まれる複
数個の処理単位（処理（１）〜（４））それぞれで実行
されるデータ更新の確定／破棄の統一を損なうこともな
い。さらに、すべての処理単位（処理（１）〜（４））
を独立させることにより、処理単位のコンポーネント化
を図ることができ、いずれかの処理単位での改良を他の
処理単位に影響させることもないため、仕様変更などに
も柔軟に対応することが可能となる。
【００２０】次に、図２を参照して、この同期型並列処
理システムが要求されたデータ処理に含まれる複数個の
処理単位それぞれで実行されるデータ更新の確定／破棄
の統一を確保するための手法の一例を説明する。
理システムが要求されたデータ処理に含まれる複数個の
処理単位それぞれで実行されるデータ更新の確定／破棄
の統一を確保するための手法の一例を説明する。
【００２１】データ処理要求の受け付け窓口として動作
するコンピュータａでは、この要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））それ
ぞれを独立して実行するために必要となる情報を準備す
る準備処理に対して、その帰属元のデータ処理が識別可
能なトランザクション番号を付与する（たとえば、図２
のＴＲ１００−０）。そして、この準備処理でデータ更
新を行なうときには、その付与されたトランザクション
番号をコンピュータｂのデータベースシステムに通知す
る。また、コンピュータａは、要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））をコ
ンピュータｃ〜ｆに分配する際に、さらにその複数個の
処理単位（処理（１）〜（４））それぞれに対して、そ
の帰属元のデータ処理が識別可能なトランザクション番
号を付与する（たとえば、図２のＴＲ１００−１，ＴＲ
１００−２，ＴＲ１００−３，ＴＲ１００−４）。
するコンピュータａでは、この要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））それ
ぞれを独立して実行するために必要となる情報を準備す
る準備処理に対して、その帰属元のデータ処理が識別可
能なトランザクション番号を付与する（たとえば、図２
のＴＲ１００−０）。そして、この準備処理でデータ更
新を行なうときには、その付与されたトランザクション
番号をコンピュータｂのデータベースシステムに通知す
る。また、コンピュータａは、要求されたデータ処理に
含まれる複数個の処理単位（処理（１）〜（４））をコ
ンピュータｃ〜ｆに分配する際に、さらにその複数個の
処理単位（処理（１）〜（４））それぞれに対して、そ
の帰属元のデータ処理が識別可能なトランザクション番
号を付与する（たとえば、図２のＴＲ１００−１，ＴＲ
１００−２，ＴＲ１００−３，ＴＲ１００−４）。
【００２２】そして、コンピュータｃ〜ｆでも同様に、
分配された処理単位（処理（１）〜（４））の実行に伴
なってデータ更新を行なうときは、その付与されたトラ
ンザクション番号をコンピュータｂのデータベースシス
テムに通知する。
分配された処理単位（処理（１）〜（４））の実行に伴
なってデータ更新を行なうときは、その付与されたトラ
ンザクション番号をコンピュータｂのデータベースシス
テムに通知する。
【００２３】一方、コンピュータｂのデータベースシス
テムでは、通知されたトランザクション番号を、（デー
タベースに反映されていないバッファリング中の）更新
データのアドレスとともに更新管理テーブル１１に格納
しておく。そして、コンピュータａからデータ更新を確
定させる旨の指示がトランザクション番号とともに送信
されてきたときに、そのトランザクション番号に対応す
る更新データをデータベースに反映させる。また、コン
ピュータａからデータ更新を破棄する旨の指示がトラン
ザクション番号とともに送信されてきたときには、その
トランザクション番号に対応する更新データをデータベ
ースに反映させることなく破棄する。
テムでは、通知されたトランザクション番号を、（デー
タベースに反映されていないバッファリング中の）更新
データのアドレスとともに更新管理テーブル１１に格納
しておく。そして、コンピュータａからデータ更新を確
定させる旨の指示がトランザクション番号とともに送信
されてきたときに、そのトランザクション番号に対応す
る更新データをデータベースに反映させる。また、コン
ピュータａからデータ更新を破棄する旨の指示がトラン
ザクション番号とともに送信されてきたときには、その
トランザクション番号に対応する更新データをデータベ
ースに反映させることなく破棄する。
【００２４】逆に、コンピュータａでは、分配した処理
単位（処理（１）〜（４））すべての正常終了がコンピ
ュータｃ〜ｆから報告された際、コンピュータｂで動作
するデータベースシステムに対してそのデータ処理に関
するデータ更新の確定を指示するとき、および、分配し
た処理単位（処理（１）〜（４））の中のいずれかの異
常終了が報告された際、コンピュータｂで動作するデー
タベースシステムに対してそのデータ処理に関するデー
タ更新の破棄を指示するときに、そのデータ処理に属す
る処理単位（準備処理，処理（１）〜（４））に付与し
たトランザクション番号（またはそのトランザクション
番号を特定可能な番号）をデータベースシステムに送信
することになる。
単位（処理（１）〜（４））すべての正常終了がコンピ
ュータｃ〜ｆから報告された際、コンピュータｂで動作
するデータベースシステムに対してそのデータ処理に関
するデータ更新の確定を指示するとき、および、分配し
た処理単位（処理（１）〜（４））の中のいずれかの異
常終了が報告された際、コンピュータｂで動作するデー
タベースシステムに対してそのデータ処理に関するデー
タ更新の破棄を指示するときに、そのデータ処理に属す
る処理単位（準備処理，処理（１）〜（４））に付与し
たトランザクション番号（またはそのトランザクション
番号を特定可能な番号）をデータベースシステムに送信
することになる。
【００２５】このように、コンピュータａ〜ｆそれぞれ
がトランザクション番号を用いて連係して動作すること
により、この実施形態の同期型並列処理システムでは、
要求されたデータ処理に属する複数個の処理単位それぞ
れでのデータ更新の確定／破棄の統一を確保する。
がトランザクション番号を用いて連係して動作すること
により、この実施形態の同期型並列処理システムでは、
要求されたデータ処理に属する複数個の処理単位それぞ
れでのデータ更新の確定／破棄の統一を確保する。
【００２６】図３は、この実施形態の同期型並列処理シ
ステムを預金支払い処理に適用した例を示すものであ
る。この預金支払い処理は、口座情報処理、支店勘定処
理、個人情報処理および家族情報処理といった４つの処
理単位を含んでなるが、この実施形態の同期型並列処理
システムを適用した場合には、前処理として、さらに支
払い処理のための準備処理という処理単位を追加する。
この支払い処理のための準備処理は、口座情報処理、支
店勘定処理、個人情報処理および家族情報処理を独立し
て実行するために必要となる情報を準備する処理であ
り、具体的には、たとえば、口座番号を基に、支店勘
定、個人情報および家族情報のキーを求める。
ステムを預金支払い処理に適用した例を示すものであ
る。この預金支払い処理は、口座情報処理、支店勘定処
理、個人情報処理および家族情報処理といった４つの処
理単位を含んでなるが、この実施形態の同期型並列処理
システムを適用した場合には、前処理として、さらに支
払い処理のための準備処理という処理単位を追加する。
この支払い処理のための準備処理は、口座情報処理、支
店勘定処理、個人情報処理および家族情報処理を独立し
て実行するために必要となる情報を準備する処理であ
り、具体的には、たとえば、口座番号を基に、支店勘
定、個人情報および家族情報のキーを求める。
【００２７】この支払い処理のための準備処理の存在に
よって、本来の口座情報処理、支店勘定処理、個人情報
処理および家族情報処理を独立して実行することがで
き、預金支払い処理の応答時間は大幅に短縮されること
になる。
よって、本来の口座情報処理、支店勘定処理、個人情報
処理および家族情報処理を独立して実行することがで
き、預金支払い処理の応答時間は大幅に短縮されること
になる。
【００２８】また、口座情報処理、支店勘定処理、個人
情報処理および家族情報処理それぞれで実行されたデー
タ更新の確定／破棄は、診断処理の存在によって、一括
して処理されるため、その統一を損なうことがない。
情報処理および家族情報処理それぞれで実行されたデー
タ更新の確定／破棄は、診断処理の存在によって、一括
して処理されるため、その統一を損なうことがない。
【００２９】さらに、口座情報処理、支店勘定処理、個
人情報処理および家族情報処理それぞれをコンポーネン
ト化することができるため、いずれかの改良の影響を他
に及ぼすことがない。
人情報処理および家族情報処理それぞれをコンポーネン
ト化することができるため、いずれかの改良の影響を他
に及ぼすことがない。
【００３０】また、図４は、この実施形態の同期型並列
処理システムを在庫移動処理に適用した例を示すもので
ある。この在庫移動処理は、出庫物流処理、出庫商流処
理、入庫物流処理および入庫商流処理といった４つの処
理単位を含んでなるが、この実施形態の同期型並列処理
システムを適用した場合には、前処理として、さらに在
庫移動処理のための準備処理という処理単位を追加す
る。この在庫移動処理のための準備処理は、出庫物流処
理、出庫商流処理、入庫物流処理および入庫商流処理を
独立して実行するために必要となる情報を準備する処理
であり、具体的には、たとえば、移動倉庫データを基
に、出庫側の倉庫関連情報および入庫側の倉庫関連情報
のキーを求める。
処理システムを在庫移動処理に適用した例を示すもので
ある。この在庫移動処理は、出庫物流処理、出庫商流処
理、入庫物流処理および入庫商流処理といった４つの処
理単位を含んでなるが、この実施形態の同期型並列処理
システムを適用した場合には、前処理として、さらに在
庫移動処理のための準備処理という処理単位を追加す
る。この在庫移動処理のための準備処理は、出庫物流処
理、出庫商流処理、入庫物流処理および入庫商流処理を
独立して実行するために必要となる情報を準備する処理
であり、具体的には、たとえば、移動倉庫データを基
に、出庫側の倉庫関連情報および入庫側の倉庫関連情報
のキーを求める。
【００３１】この在庫移動処理のための準備処理の存在
によって、本来の出庫物流処理、出庫商流処理、入庫物
流処理および入庫商流処理を独立して実行することがで
き、在庫移動処理の応答時間は大幅に短縮されることに
なる。
によって、本来の出庫物流処理、出庫商流処理、入庫物
流処理および入庫商流処理を独立して実行することがで
き、在庫移動処理の応答時間は大幅に短縮されることに
なる。
【００３２】また、出庫物流処理、出庫商流処理、入庫
物流処理および入庫商流処理それぞれで実行されたデー
タ更新の確定／破棄は、診断処理の存在によって、一括
して処理されるため、その統一を損なうことがない。
物流処理および入庫商流処理それぞれで実行されたデー
タ更新の確定／破棄は、診断処理の存在によって、一括
して処理されるため、その統一を損なうことがない。
【００３３】さらに、出庫物流処理、出庫商流処理、入
庫物流処理および入庫商流処理それぞれをコンポーネン
ト化することができるため、いずれかの改良の影響を他
に及ぼすことがない。
庫物流処理および入庫商流処理それぞれをコンポーネン
ト化することができるため、いずれかの改良の影響を他
に及ぼすことがない。
【００３４】なお、前述した同期型並列処理システムで
は、コンピュータａに準備工程を設けた場合を例に説明
したが、たとえば、要求されるデータ処理が準備処理を
必要としないような場合などには、診断工程を設けるの
みでも有効である。また、前述した同期型並列処理シス
テムでは、コンピュータｃ〜ｆそれぞれが、一つの処理
単位を実行する場合を例に説明したが、同一コンピュー
タ上で複数個の処理単位を実行しても構わない。
は、コンピュータａに準備工程を設けた場合を例に説明
したが、たとえば、要求されるデータ処理が準備処理を
必要としないような場合などには、診断工程を設けるの
みでも有効である。また、前述した同期型並列処理シス
テムでは、コンピュータｃ〜ｆそれぞれが、一つの処理
単位を実行する場合を例に説明したが、同一コンピュー
タ上で複数個の処理単位を実行しても構わない。
【００３５】
【発明の効果】以上詳述したように、この発明によれ
ば、前処理として、要求されたデータ処理に含まれる複
数個の処理単位それぞれを独立して実行するために必要
となる情報をすべて準備し、この準備した情報を添付し
て、そのデータ処理に含まれる複数個の処理単位を複数
台のコンピュータに分配し、また、この分配した複数個
の処理単位すべての正常終了が報告されたときに、複数
台のコンピュータそれぞれで実行されたそのデータ処理
に関するデータ更新の確定をデータベースシステムに指
示し、一方、分配した複数の処理単位の中のいずれかの
異常終了が報告されたときには、複数台のコンピュータ
それぞれで実行されたそのデータ処理に関するデータ更
新の破棄をデータベースシステムに指示することから、
要求されたデータ処理を大量に実行するための分散処理
システムとして機能するだけでなく、要求されたデータ
処理それぞれの応答時間を短縮するための並列処理シス
テムとしても有効に機能する同期型並列処理システムが
実現されることになる。
ば、前処理として、要求されたデータ処理に含まれる複
数個の処理単位それぞれを独立して実行するために必要
となる情報をすべて準備し、この準備した情報を添付し
て、そのデータ処理に含まれる複数個の処理単位を複数
台のコンピュータに分配し、また、この分配した複数個
の処理単位すべての正常終了が報告されたときに、複数
台のコンピュータそれぞれで実行されたそのデータ処理
に関するデータ更新の確定をデータベースシステムに指
示し、一方、分配した複数の処理単位の中のいずれかの
異常終了が報告されたときには、複数台のコンピュータ
それぞれで実行されたそのデータ処理に関するデータ更
新の破棄をデータベースシステムに指示することから、
要求されたデータ処理を大量に実行するための分散処理
システムとして機能するだけでなく、要求されたデータ
処理それぞれの応答時間を短縮するための並列処理シス
テムとしても有効に機能する同期型並列処理システムが
実現されることになる。
【００３６】また、要求されたデータ処理に含まれる複
数個の処理単位それぞれが独立して実行されることか
ら、すべての処理単位をコンポーネント化することが可
能となり、いずれかの処理単位での改良を他の処理単位
に影響させることもなく、仕様変更などにも柔軟に対応
することができるようになる。
数個の処理単位それぞれが独立して実行されることか
ら、すべての処理単位をコンポーネント化することが可
能となり、いずれかの処理単位での改良を他の処理単位
に影響させることもなく、仕様変更などにも柔軟に対応
することができるようになる。
【図１】この発明の実施形態に係る同期型並列処理シス
テムの概略構成および機能ブロックを示す図。
テムの概略構成および機能ブロックを示す図。
【図２】同実施形態の同期型並列処理システムが要求さ
れたデータ処理に含まれる複数個の処理単位それぞれで
実行されるデータ更新の確定／破棄の統一を確保するた
めの手法の一例を説明するための図。
れたデータ処理に含まれる複数個の処理単位それぞれで
実行されるデータ更新の確定／破棄の統一を確保するた
めの手法の一例を説明するための図。
【図３】同実施形態の同期型並列処理システムを預金引
き出し処理に適用した例を示す図。
き出し処理に適用した例を示す図。
【図４】同実施形態の同期型並列処理システムを在庫移
動処理に適用した例を示す図。
動処理に適用した例を示す図。
【図５】従来のデータ処理システムの構築形態を例示す
る第１の図。
る第１の図。
【図６】従来のデータ処理システムの構築形態を例示す
る第２の図。
る第２の図。
ａ，ｃ〜ｎ…データ処理コンピュータ ｂ…データベースサーバコンピュータ １１…更新管理テーブル
Claims (5)
- 【請求項１】 関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムであって、前記データ処理の実
行によって更新されるデータを一元的に管理するデータ
ベースシステムを備えた同期型並列処理システムにおい
て、 前記データ処理に含まれる複数個の処理単位それぞれを
独立して実行するために必要となる情報を準備する準備
手段と、 前記準備手段により準備された情報を添付して前記デー
タ処理に含まれる複数個の処理単位を前記複数台のコン
ピュータに分配する分配手段と、 前記分配手段により分配された前記データ処理に含まれ
る複数個の処理単位すべての正常終了が報告されたとき
に、前記複数台のコンピュータそれぞれで実行されたそ
のデータ処理に関するデータ更新の確定を前記データベ
ースシステムに指示し、前記分配手段により分配された
前記データ処理に含まれる複数個の処理単位の中のいず
れかの異常終了が報告されたときに、前記複数台のコン
ピュータそれぞれで実行されたそのデータ処理に関する
データ更新の破棄を前記データベースシステムに指示す
る診断手段と、 を具備することを特徴とする同期型並列処理システム。 - 【請求項２】 関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムであって、前記データ処理の実
行によって更新されるデータを一元的に管理するデータ
ベースシステムを備えた同期型並列処理システムにおい
て、 前記データ処理に含まれる複数個の処理単位を前記複数
台のコンピュータに分配する分配手段と、 前記分配手段により分配された前記データ処理に含まれ
る複数個の処理単位すべての正常終了が報告されたとき
に、前記複数台のコンピュータそれぞれで実行されたそ
のデータ処理に関するデータ更新の確定を前記データベ
ースシステムに指示し、前記分配手段により分配された
前記データ処理に含まれる複数個の処理単位の中のいず
れかの異常終了が報告されたときに、前記複数台のコン
ピュータそれぞれで実行されたそのデータ処理に関する
データ更新の破棄を前記データベースシステムに指示す
る診断手段と、 を具備することを特徴とする同期型並列処理システム。 - 【請求項３】 前記分配手段は、前記分配する複数個の
処理単位それぞれに帰属元のデータ処理が識別可能な識
別子を付与する手段を有し、 前記診断手段は、前記分配手段により付与された識別子
を用いて前記データベースシステムに対してデータ更新
の確定および破棄を指示する手段を有することを特徴と
する請求項１または２記載の同期型並列処理システム。 - 【請求項４】 関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムであって、前記データ処理の実
行によって更新されるデータを一元的に管理するデータ
ベースシステムを備えた同期型並列処理システムに適用
される同期型並列処理方法において、 前記データ処理に含まれる複数個の処理単位それぞれを
独立して実行するために必要となる情報を準備する工程
と、 前記準備された情報を添付して前記データ処理に含まれ
る複数個の処理単位を前記複数台のコンピュータに分配
する工程と、 前記分配された前記データ処理に含まれる複数個の処理
単位すべての正常終了が報告されたときに、前記複数台
のコンピュータそれぞれで実行されたそのデータ処理に
関するデータ更新の確定を前記データベースシステムに
指示し、前記分配された前記データ処理に含まれる複数
個の処理単位の中のいずれかの異常終了が報告されたと
きに、前記複数台のコンピュータそれぞれで実行された
そのデータ処理に関するデータ更新の破棄を前記データ
ベースシステムに指示する工程と、 からなることを特徴とする同期型並列処理方法。 - 【請求項５】 関連性を有する複数個の処理単位を含ん
だデータ処理を複数台のコンピュータで並列に実行する
同期型並列処理システムであって、前記データ処理の実
行によって更新されるデータを一元的に管理するデータ
ベースシステムを備えた同期型並列処理システムに適用
される同期型並列処理方法において、 前記データ処理に含まれる複数個の処理単位を前記複数
台のコンピュータに分配する工程と、 前記分配された前記データ処理に含まれる複数個の処理
単位すべての正常終了が報告されたときに、前記複数台
のコンピュータそれぞれで実行されたそのデータ処理に
関するデータ更新の確定を前記データベースシステムに
指示し、前記分配された前記データ処理に含まれる複数
個の処理単位の中のいずれかの異常終了が報告されたと
きに、前記複数台のコンピュータそれぞれで実行された
そのデータ処理に関するデータ更新の破棄を前記データ
ベースシステムに指示する工程と、 からなることを特徴とする同期型並列処理方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP14409798A JPH11338834A (ja) | 1998-05-26 | 1998-05-26 | 同期型並列処理システムおよび同期型並列処理方法 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP14409798A JPH11338834A (ja) | 1998-05-26 | 1998-05-26 | 同期型並列処理システムおよび同期型並列処理方法 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JPH11338834A true JPH11338834A (ja) | 1999-12-10 |
Family
ID=15354139
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP14409798A Pending JPH11338834A (ja) | 1998-05-26 | 1998-05-26 | 同期型並列処理システムおよび同期型並列処理方法 |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JPH11338834A (ja) |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7958014B2 (en) | 2001-05-10 | 2011-06-07 | International Business Machines Corporation | Method and apparatus for building commercial distributed computing networks via computer cost subsidization |
| JP2012073975A (ja) * | 2010-09-30 | 2012-04-12 | Hitachi Ltd | 計算機システム及びそのデータ処理方法 |
| JP2013513887A (ja) * | 2009-12-15 | 2013-04-22 | インテル コーポレイション | バッファリングストアを利用してトランザクションを高速化するための機構 |
-
1998
- 1998-05-26 JP JP14409798A patent/JPH11338834A/ja active Pending
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7958014B2 (en) | 2001-05-10 | 2011-06-07 | International Business Machines Corporation | Method and apparatus for building commercial distributed computing networks via computer cost subsidization |
| JP2013513887A (ja) * | 2009-12-15 | 2013-04-22 | インテル コーポレイション | バッファリングストアを利用してトランザクションを高速化するための機構 |
| JP2012073975A (ja) * | 2010-09-30 | 2012-04-12 | Hitachi Ltd | 計算機システム及びそのデータ処理方法 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US5363121A (en) | Multiple protocol communication interface for distributed transaction processing | |
| US6081826A (en) | System using environment manager with resource table in each computer for managing distributed computing resources managed for each application | |
| JP5841177B2 (ja) | マルチサーバ予約システムにおける同期化メカニズムのための方法及びシステム | |
| US7328213B2 (en) | Transaction processing method, transaction control apparatus and program thereof | |
| JPH0793272A (ja) | 資源の同期点管理を実行する装置および方法 | |
| JPH04229335A (ja) | コミット手順の最適化方法 | |
| JPH087690B2 (ja) | コミット手順におけるエラー・コードおよびエラー記述情報の処理装置および方法 | |
| US5960178A (en) | Queue system and method for point-to-point message passing having a separate table for storing message state and identifier of processor assigned to process the message | |
| JPH0793271A (ja) | 作業ユニットに合わせてコミット範囲を調整するコンピュータ・システム | |
| CN112328406B (zh) | 一种基于tcc的微服务分布式事务系统以及业务处理方法 | |
| JP2005521945A (ja) | 共通作業キュー環境における最適格サーバ | |
| CN115185787A (zh) | 处理事务日志的方法及装置 | |
| KR19990043986A (ko) | 업무 인계 시스템 | |
| EP1006443A2 (en) | A method of and an apparatus for conventing an event of a distributed application and recording madia for storing the method | |
| JPH11194929A (ja) | クライアント・サーバ型システムにおけるクライアント側プログラム管理方式 | |
| JPH06243077A (ja) | 分散トランザクション処理方式 | |
| JPS59111564A (ja) | 巡回式２フエ−ズコミツトメント制御方式 | |
| JPH11353197A (ja) | 共有プール資源制御方式 | |
| US20050036483A1 (en) | Method and system for managing programs for web service system | |
| CN100553271C (zh) | 在计算机系统中建立协作服务的方法 | |
| JP2776733B2 (ja) | サービス状態管理方式 | |
| JPH04102134A (ja) | 遅延更新処理方式 | |
| JPH10229445A (ja) | インテリジェントネットワークのオペレーションシステム | |
| JPH05334163A (ja) | 複数システム間共用メモリ排他制御方式 | |
| US9026657B2 (en) | Method and system for provisioning telecommunication services and equipment using sequential or parallel processing |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Effective date: 20050517 Free format text: JAPANESE INTERMEDIATE CODE: A621 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20070412 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20070508 |
|
| A521 | Written amendment |
Effective date: 20070706 Free format text: JAPANESE INTERMEDIATE CODE: A523 |
|
| A02 | Decision of refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A02 Effective date: 20070821 |