JPH0895810A - バッチジョブ実行方式 - Google Patents

Abstract

(57)【要約】 【目的】 バッチジョブを構成するジョブステップ間の
データ伝達に一時ファイルの代わりに主記憶上のデータ
伝達用バッファを使用させ、複数ジョブステップを同時
並列に処理する。 【構成】 ジョブステップ7-1 が出力に、ジョブステッ
プ7-2 が入力にそれぞれ使用する共通の一時ファイルの
代わりに主記憶上に先入り先出し形式のデータ伝達用バ
ッファ5-1 を用意する。ステップ並列実行管理部４はジ
ョブステップ7-1,7-2 に別々のプロセス6-1,6-2 を割り
当てて並行して動作させる。送信データ管理部１は、プ
ロセス6-1 から一時ファイルに対する書き込み要求があ
ったときに出力データをデータ伝達用バッファ5-1 に順
次にキューイングし、プロセス6-2から一時ファイルに
対する読み込み要求があったときにデータ伝達用バッフ
ァ5-1 にキューイングされたデータを順次に取り出して
プロセス6-2 に伝達する。

Description

【発明の詳細な説明】

【０００１】

【産業上の利用分野】本発明は計算機のバッチジョブ実
行方式に関し、特にジョブステップ間で一時ファイルを
介してデータの伝達を行う複数のジョブステップを、そ
の一時ファイルの代わりに主記憶上のデータ伝達用バッ
ファを使用させて同時に並行して動作させるようにした
バッチジョブ実行方式に関する。

【０００２】

【従来の技術】従来、複数のジョブステップから構成さ
れるバッチジョブの実行は、それを構成するジョブステ
ップを記述順に順次一つずつ実行することで行われてい
る。

【０００３】また、複数のジョブステップから構成され
るバッチジョブの実行において、先行するジョブステッ
プで生成されたデータを後続のジョブステップで処理す
る場合、一時ファイルを使用してジョブステップ間でデ
ータの伝達を行っている。一時ファイルとしては、磁気
ディスク媒体上のファイル以外に、その入出力速度を向
上するために電子ディスク媒体上のファイルが使用され
る場合がある。

【０００４】

【発明が解決しようとする課題】ところで、ジョブの実
行速度を速める手法の一つに、オンライントランザクシ
ョンを処理するリアルタイムジョブにおいて採用されて
いるマルチタスキング手法がある。即ち、各トランザク
ションの処理を別々のプロセスで並行して処理する手法
である。しかしながら、このマルチタスキング手法はバ
ッチジョブに対しては余り利用されていない。その理由
の一つは、本来バッチジョブは逐次性の強い処理を目的
としていたという事情があったからである。

【０００５】しかしながら、例えばＰという計算処理と
Ｑという計算処理とがあり、それらの計算が互いに独立
に行える場合、Ｐという計算処理とＱという計算処理と
を行う１つのジョブステップを１つのプロセスで実行す
るよりも、Ｐという計算処理を行うプロセスとＱという
計算処理を行うプロセスとの２つのプロセスで並行処理
する方が計算結果が早く得られる。つまり、バッチジョ
ブにおいてもマルチタスキング手法が有効な場合があ
る。

【０００６】同様に、上記のＰという計算処理を行うジ
ョブステップと、Ｑという計算処理を行うジョブステッ
プとがある場合、ジョブステップの実行を逐次的に実行
するのではなく、双方のジョブステップに別々のプロセ
スを割り当てて並列して実行させることも考えられる。

【０００７】しかしながら、上記の何れの場合も各ジョ
ブステップでの計算処理が互いに独立に行えるので問題
はないが、先行するジョブステップで生成されたデータ
を後続のジョブステップで処理するようなバッチジョブ
の場合、従来はデータ伝達用に一時ファイルを使用して
いた為に実質的にジョブステップは並行処理されない。
即ち、一時ファイルは、ファイルの構造上の問題によ
り、全てのデータが書き出され、そのファイルが完成し
てからでないと、データの読み込みができないため、先
行するジョブステップが全てのデータを一時ファイルに
書き出した後に、後続するジョブステップがその読み込
みを開始することになり、ジョブステップの実行が逐次
的に成らざるを得ないからである。

【０００８】そこで本発明の目的は、一時ファイルの代
わりに主記憶上に個々のデータを先入れ先出し形式で格
納するデータ伝達用のバッファを設け、先行するジョブ
ステップと後続のジョブステップとが非同期に個々のデ
ータ単位にデータ伝達し得るようにすることにより、複
数のジョブステップを実質的に同時に並行して動作させ
ることを可能として、バッチジョブの実行時間を短縮し
得るようにしたバッチジョブ実行方式を提供することに
ある。

【０００９】

【課題を解決するための手段】本発明は上記の目的を達
成するために、複数個のデータを処理して個々のデータ
毎の処理済データを順次に一時ファイルに出力する第１
のジョブステップと、前記一時ファイルから個々の処理
済データを順次に入力して処理する第２のジョブステッ
プとを含むバッチジョブの実行方式において、前記第１
のジョブステップと前記第２のジョブステップとにそれ
ぞれ別々のプロセスを割り当てて並行して動作させるス
テップ並列実行管理部と、前記一時ファイルの代わりに
主記憶上に設けられた先入れ先出し形式のデータ伝達用
バッファと、前記第１のジョブステップに割り当てられ
たプロセスから前記一時ファイルに対する書き込み要求
があったときに出力データを前記データ伝達用バッファ
に順次にキューイングし、前記第２のジョブステップに
割り当てられたプロセスから前記一時ファイルに対する
読み込み要求があったときに前記データ伝達用バッファ
にキューイングされたデータを順次に取り出して前記第
２のジョブステップに割り当てられたプロセスに伝達す
る送信データ管理部とを備えている。

【００１０】また、障害発生時等に主記憶上のデータ伝
達用バッファの内容を復元できるようにするために、デ
ータ伝達用バッファの内容の履歴を前記プロセスの動作
と並行して永久ファイルに退避する送信データ退避部を
備えている。そして、障害発生等の原因によりジョブの
実行が停止した後、途中終了したジョブステップの先頭
からジョブを再実行する際、送信データ復旧部が、途中
終了したジョブステップが入力に使用していた一時ファ
イルであって正常終了したジョブステップが出力に使用
していた一時ファイルに対応するデータ伝達用バッファ
の内容の履歴を前記永久ファイルから読み出し、前記正
常終了したジョブステップが出力した全てのデータを格
納したデータ伝達用バッファを主記憶上に復元するよう
にしている。

【００１１】

【作用】本発明のバッチジョブ実行方式においては、一
時ファイルの代わりに主記憶上に先入り先出し形式のデ
ータ伝達用バッファが設けられ、ステップ並列実行管理
部が、複数個のデータを処理して個々のデータ毎の処理
済データを順次に出力する第１のジョブステップと、こ
の第１のジョブステップから出力された個々の処理済デ
ータを順次に処理する第２のジョブステップとにそれぞ
れ別々のプロセスを割り当てて並行して動作させ、送信
データ管理部が、第１のジョブステップに割り当てられ
たプロセスから前記一時ファイルに対する書き込み要求
があったときに出力データを前記データ伝達用バッファ
に順次にキューイングし、前記第２のジョブステップに
割り当てられたプロセスから前記一時ファイルに対する
読み込み要求があったときに前記データ伝達用バッファ
にキューイングされたデータを順次に取り出して前記第
２のジョブステップに割り当てられたプロセスに伝達す
る。

【００１２】

【実施例】次に本発明の実施例について図面を参照して
詳細に説明する。

【００１３】図１は本発明のバッチジョブ実行方式の一
実施例のブロック図であり、１は送信データ管理部、２
は送信データ退避部、３は送信データ復旧部、４はジョ
ブ管理手段１１およびプロセス管理手段１２を含むステ
ップ並列実行管理部、５−１〜５−３は主記憶上のデー
タ伝達用バッファ、６−１〜６−３はプロセス、７はバ
ッチジョブ、７−１〜７−３はバッチジョブ７を構成す
るジョブステップ、８は磁気ディスク媒体等の外部記憶
媒体上の永久ファイル、９はデータ管理部、１０はリス
タート制御部、１３は不揮発性の制御テーブルである。
このような構成要素は、マルチプロセッサ計算機の如き
複数のプロセスを同時に並行して実行することができる
複数プロセス処理機能搭載計算機上に搭載される。

【００１４】図２はバッチジョブ７のジョブステップ７
−１〜７−３で行う処理例の説明図である。同図に示す
ように、ジョブステップ７−１は、複数個のデータＡ１
〜ＡＮを順次に処理して、個々のデータ毎に処理済デー
タＢ１〜ＢＮおよび処理済データＣ１〜ＣＮを生成し、
前者のデータＢ１〜ＢＮは一時ファイルＸに格納し、後
者のデータＣ１〜ＣＮは一時ファイルＹに格納する。ジ
ョブステップ７−２は、一時ファイルＸからデータＢ１
〜ＢＮを順次に入力して処理し、個々のデータ毎に処理
済データＤ１〜ＤＮを生成して一時ファイルＺに格納す
る。ジョブステップ７−３は一時ファイルＹおよび一時
ファイルＺから処理済データＣ１〜ＣＮ，Ｄ１〜ＤＮを
順次に入力して処理する。本実施例では、このような一
時ファイルＸ，Ｙ，Ｚを介してデータ授受し合う３つの
ジョブステップ７−１〜７−３を並列に動作させようと
するものである。

【００１５】図３は各ジョブステップ７−１〜７−３の
ＪＣＬ記述例を示す。ジョブステップ７−１は一時ファ
イルＸ，Ｙを使用するので、そのＪＣＬ記述には一時フ
ァイルＸ，Ｙに関するアサイン文＄ＡＳＳＩＧＮがあ
り、ジョブステップ７−２は一時ファイルＸ，Ｚを使用
するので、そのＪＣＬ記述には一時ファイルＸ，Ｚに関
するアサイン文＄ＡＳＳＩＧＮがある。また、ジョブス
テップ７−３は一時ファイルＹ，Ｚを使用するので、そ
のＪＣＬ記述には一時ファイルＹ，Ｚに関するアサイン
文＄ＡＳＳＩＧＮがある。更に、ジョブステップ７−１
のＪＣＬ記述中には、当該ジョブステップ７−１とその
直後のジョブステップ７−２とを並列に動作させること
を指示する文＄ＰＡＲＡＬＬＥＬがあり、ジョブステッ
プ７−２のＪＣＬ記述中には、当該ジョブステップ７−
２とその直後のジョブステップ７−３とを並列に動作さ
せることを指示する文＄ＰＡＲＡＬＬＥＬがある。な
お、ジョブステップ７−３のＪＣＬ記述中には文＄ＰＡ
ＲＡＬＬＥＬはない。

【００１６】図４はジョブステップ７−１の処理の一例
を示すフローチャートである。同図に示すように、先
ず、一時ファイルＸ，Ｙをオープンし（Ｓ１）、次にＳ
ＹＳＩＮファイル等から図２に示したデータＡ１〜ＡＮ
を１データずつ入力し（Ｓ２）、所定のデータ処理を行
う（Ｓ４）。そして、処理結果のデータを一時ファイル
Ｘに書き出し（Ｓ５）、再びステップＳ２で入力したデ
ータに対しステップＳ４とは別のデータ処理を行って
（Ｓ６）、その結果のデータを一時ファイルＹに書き出
す（Ｓ７）。以上を最後のデータＡＮまで実行すると
（Ｓ３でＹＥＳ）、一時ファイルＸ，Ｙをクローズし
（Ｓ８）、処理を終了する。

【００１７】図５はジョブステップ７−２の処理の一例
を示すフローチャートである。先ず、一時ファイルＸ，
Ｚをオープンし（Ｓ１１）、次に一時ファイルＸからデ
ータＢ１〜ＢＮを１つずつ入力し（Ｓ１２）、所定のデ
ータ処理を行う（Ｓ１４）。次に、その結果のデータを
一時ファイルＺに書き込む（Ｓ１５）。以上を一時ファ
イルＸの最後のデータＢＮまで実行すると（Ｓ１３でＹ
ＥＳ）、一時ファイルＸ，Ｚをクローズし（Ｓ１６）、
処理を終了する。

【００１８】図６はジョブステップ７−３の処理の一例
を示すフローチャートである。先ず、一時ファイルＹ，
Ｚをオープンし（Ｓ２１）、次に一時ファイルＹ，Ｚか
らデータＣ１〜ＣＮ，Ｄ１〜ＤＮを１つずつ入力し（Ｓ
２２，Ｓ２４）、所定のデータ処理を行う（Ｓ２５）。
そして、その結果のデータを例えばＳＹＳＯＵＴファイ
ル等に出力する（Ｓ２６）。以上を一時ファイルＹの最
後のデータＣＮまで実行すると（Ｓ２３でＹＥＳ）、一
時ファイルＹ，Ｚをクローズし（Ｓ２７）、処理を終了
する。

【００１９】図７はステップ並列実行管理部４のジョブ
管理手段１１の処理例を示すフローチャートである。同
図に示すようにジョブ管理手段１１は、バッチジョブ７
のジョブステップ記述（ＪＣＬ記述）をその先頭より順
に入力し（Ｓ３１）、入力したジョブステップ記述を解
析して前処理を実行する（Ｓ３３）。この前処理では、
当該ジョブステップに必要な資源の確保等の処理が行わ
れる。このとき本実施例では、一時ファイルのアサイン
文＄ＡＳＳＩＧＮが現れたとき、実際に一時ファイルを
確保するのではなく、それに代わって主記憶上にデータ
伝達用バッファを確保する。また、どの一部ファイルに
対しどのデータ伝達用バッファを割り当てたかを示す情
報を作成し、制御テーブル１３に設定する。次に、当該
ジョブステップを実行するためのプロセスを割り当て、
プロセス管理手段１２に対しそのプロセスの実行を指示
する（Ｓ３４）。次に、当該ジョブステップ記述中に＄
ＰＡＲＡＬＬＥＬ文が存在するか否かを調べることよ
り、後続ジョブステップの並列実行が指示されているか
否かを調べ（Ｓ３５）、指示されていればステップＳ３
１に戻って次のジョブステップ記述について上記と同様
な処理を繰り返す。

【００２０】他方、並列実行が指示されていないジョブ
ステップ記述を処理し終えた場合（Ｓ３５でＮＯ）、上
記実行を開始させたジョブステップ対応のプロセスの実
行終了を待ち合わせ（Ｓ３６）、何れかのプロセスが終
了すると、その終了したプロセスに対応するジョブステ
ップの後処理を行う（Ｓ３７）。この後処理では、その
ジョブステップが使用していた資源の解放等を行う。但
し、他のジョブステップと共用される資源であるデータ
伝達用バッファの解放はジョブの終了時までは解放され
ない。次に、他のジョブステップ対応のプロセスのうち
実行中のプロセスが残っているか否かを判別し（Ｓ３
８）、残っていればその終了を待ち合わせるためにステ
ップＳ３６へ進む。残っていなければ、ステップＳ３１
に戻って、後続のジョブステップ記述を処理する。

【００２１】図１に示されるデータ伝達用バッファ５−
１〜５−３は上記のジョブ管理手段１１によって一時フ
ァイルの代わりに主記憶上に確保されたもので、データ
伝達用バッファ５−１は一時ファイルＸに、データ伝達
用バッファ５−２は一時ファイルＹに、データ伝達用バ
ッファ５−３は一時ファイルＺに対応している。このよ
うな関係は、図８に示すように制御テーブル１３に保持
される。なお、制御テーブル１３にはステータスを登録
する欄があり、この欄に送信データ管理部１によってど
の一時ファイルがどのプロセスによって使用中であるか
等のステータスが設定される。

【００２２】図９はデータ伝達用バッファ５−１〜５−
３の構成例を示すブロック図であり、各々のデータ伝達
用バッファ５−１〜５−３はキュー５１１，５２１，５
３１を有している。データ伝達用バッファ５−１へのデ
ータ書き込み時、書き込まれたデータの主記憶上のアド
レスを示すポインタがキュー５１１にキューイングさ
れ、データの読み出し時には、キュー５１１からポイン
タがデキューイングされ、そのポインタが指し示すデー
タが読み出し要求元に伝達される。他のデータ伝達用バ
ッファ５−２，５−３も同様の構成を有している。

【００２３】図１０〜図１３は送信データ管理部１の処
理例を示すフローチャートである。図１０に示すよう
に、送信データ管理部１は実行中のプロセスから一時フ
ァイルに対するオープン要求があると、制御テーブル１
３中のオープン要求された一時ファイルに対応するステ
ータス欄に、その要求元が使用中である旨を登録する
（Ｓ４１）。また図１１に示すように、実行中のプロセ
スから一時ファイルに対するクローズ要求があると、制
御テーブル１３中のクローズ要求された一時ファイルに
対応するステータス欄に、その要求元が使用を終えた旨
を記述する（Ｓ５１）。

【００２４】更に図１２に示すように、送信データ管理
部１は実行中のプロセスから一時ファイルに対するデー
タ出力要求があると、制御テーブル１３を参照して出力
要求された一時ファイルに対応するデータ伝達用バッフ
ァを認識し（Ｓ６１）、出力要求されたデータを１オブ
ジェクトとして上記のデータ伝達用バッファに格納する
（Ｓ６２）。また、図１の送信データ退避部２に、格納
先のデータ伝達用バッファ名と格納したデータとを含む
履歴データを通知する（Ｓ６３）。

【００２５】また図１３に示すように、送信データ管理
部１は実行中のプロセスから一時ファイルに対するデー
タ入力要求があると、制御テーブル１３を参照して入力
要求された一時ファイルに対応するデータ伝達用バッフ
ァを認識し（Ｓ７１）、そのデータ伝達用バッファから
１つのデータを取り出して要求元に伝達する（Ｓ７
３）。このとき、データ伝達用バッファに１つもデータ
が格納されていないときは（Ｓ７２でＮＯ）、制御テー
ブル１３中のそのデータ伝達用バッファに対応するステ
ータス欄の記述に基づき、入力要求元プロセス以外のプ
ロセス（即ち、データ出力元のプロセス）がそのデータ
伝達用バッファの使用を終えたか否かを調べ（Ｓ７
４）、使用を終えていなければ所定時間だけ待ち合わせ
て（Ｓ７５）、再び処理Ｓ７２から再試行する。他方、
他のプロセスが使用を終えていれば、全てのデータを伝
達し終えたことになるので、入力要求元にデータ終了を
通知する（Ｓ７６）。

【００２６】図１４は送信データ退避部２の処理例を示
すフローチャートである。同図に示すように送信データ
退避部２は、送信データ管理部１から履歴データが通知
されると、その履歴データを永久ファイル８に書き込む
（Ｓ８１）。従って、永久ファイル８には図１５に示す
ようにデータ伝達用バッファ名およびデータを含む履歴
データが順次格納されることになる。

【００２７】図１６はリスタート制御部１０の処理例を
示すフローチャートである。同図に示すようにリスター
ト制御部１０は、途中終了したジョブステップの入力用
であって、それを出力用に使用しているジョブステップ
が正常終了している一時ファイルを認識し、それに対応
するデータ伝達用バッファを主記憶に確保し（Ｓ９
１）、そのデータ伝達用バッファの格納データを復元す
るよう送信データ復旧部３に要求する（Ｓ９２）。そし
て、途中終了したジョブステップの先頭からジョブを再
実行するようステップ並列実行管理部４に指示を出す
（Ｓ９３）。

【００２８】図１７は送信データ復旧部３の処理例を示
すフローチャートである。同図に示すように送信データ
復旧部３は、永久ファイル８から復元するデータ伝達用
バッファ名を含む履歴データを全て抽出し（Ｓ１０
１）、抽出した履歴データ中のデータを、復元するデー
タ伝達用バッファに格納する（Ｓ１０２）。

【００２９】以下、上述のように構成された本実施例の
動作を説明する。

【００３０】図３に示したようなジョブ記述が与えられ
てジョブの実行が指示されると、ステップ並列実行管理
部４のジョブ管理手段１１はジョブ記述の先頭文から順
に解析を開始する。そして、先頭のジョブステップ記述
を入力すると（図７のＳ３１）、ジョブステップ実行前
処理を行う（Ｓ３３）。今、先頭のジョブステップがジ
ョブステップ７−１であった場合、その記述中には一時
ファイルＸ，Ｙのアサイン文が存在するため、一時ファ
イルＸに代えてデータ伝達用バッファ５−１が主記憶上
に確保され、一時ファイルＹに代えてデータ伝達用バッ
ファ５−２が主記憶上に確保される。また、一時ファイ
ルＸがデータ伝達用バッファ５−１に対応し、一時ファ
イルＹがデータ伝達用バッファ５−２に対応しているこ
とが図８に示すように制御テーブル１３に登録される。
ジョブステップ実行の前処理が終了すると、次にそのジ
ョブステップ７−１に１つのプロセスが割り当てられ、
プロセス管理手段１２に対しプロセスの実行が指示され
る（Ｓ３４）。今、ジョブステップ７−１に対してプロ
セス６−１が割り当てられたとすると、以後、プロセス
管理手段１２の管理の下で、ジョブステップ７−１がプ
ロセス６−１として実行されることになる。

【００３１】ジョブ管理手段１１は、次にジョブステッ
プ７−１の記述中に＄ＰＡＲＡＬＬＥＬ文が存在するか
否かを調べる（Ｓ３５）。図３の場合、存在するので、
ジョブ管理手段１１は次のジョブステップ７−２のジョ
ブステップ記述を入力し（Ｓ３１）、それを解析して前
処理を行う（Ｓ３３）。ここでは一時ファイルＸ，Ｚが
宣言されているので、それに代わるデータ伝達用バッフ
ァを主記憶上に確保する。但し、一時ファイルＸは既に
データ伝達用バッファ５−１として確保済なので、一時
ファイルＺに代えて使用するデータ伝達用バッファ５−
３のみを主記憶上に確保する。また、一時ファイルＺが
データ伝達用バッファ５−３に対応することを図８に示
すように制御テーブル１３に設定する。そして、ジョブ
ステップ７−２に１つのプロセスを割り当て、プロセス
管理手段１２の管理の下に実行させる（Ｓ３４）。従っ
て、ジョブステップ７−２にプロセス６−２が割り当て
られたとすると、ジョブステップ７−２がプロセス６−
２として実行されることになる。

【００３２】ジョブ管理手段１１は、次にジョブステッ
プ７−２の記述中に＄ＰＡＲＡＬＬＥＬ文が存在するの
で、次のジョブステップ７−３のジョブステップ記述を
入力し（Ｓ３１）、それを解析して前処理を行う（Ｓ３
３）。ここでは一時ファイルＹ，Ｚが宣言されている
が、それらに対応するデータ伝達用バッファ５−２，５
−３は既に確保済なので、新たなデータ伝達用バッファ
の確保は行わない。そして、ジョブステップ７−３に１
つのプロセス、即ちプロセス６−３を割り当て、プロセ
ス管理手段１２の管理の下に実行させる（Ｓ３４）。

【００３３】次にジョブ管理手段１１は、ジョブステッ
プ７−３の記述中に＄ＰＡＲＡＬＬＥＬ文が存在するか
否か調べるが（Ｓ３５）、図３の例では存在しないの
で、プロセス６−１〜６−３の実行終了を待ち合わせる
（Ｓ３６）。

【００３４】以上の結果、図４に示すような処理を行う
ジョブステップ７−１と、図５に示すような処理を行う
ジョブステップ７−２と、図６に示すような処理を行う
ジョブステップ７−３との３つのジョブステップが同時
に並行して実行されることになる。

【００３５】さて、ジョブステップ７−１の実行体であ
るプロセス６−１の図４の処理において、一時ファイル
Ｘ，Ｙに対するオープン要求があると（Ｓ１）、それ
が、ファイル処理全般についてのＯＳ機能部であるデー
タ管理部９に伝達される。データ管理部９はオープン要
求対象のファイル名が制御テーブル１３に登録されてい
るか否かを調べ、登録されている場合には制御を送信デ
ータ管理部１に渡す。登録されていないファイルについ
ては従来と同様に処理される。このような切り分けは、
クローズ要求時およびデータ入出力要求時にも行われ
る。従って、一時ファイルＸ，Ｙに対するオープン要求
が出された場合、制御が送信データ管理部１に渡り、送
信データ管理部１は図１０に示す処理を実行することに
より、制御テーブル１３中の一時ファイルＸ，Ｙに対応
するステータス欄に、プロセス６−１が使用中である旨
を設定する。

【００３６】プロセス６−１の処理が進み、図２に示し
た先頭の入力データＡ１の処理済結果であるデータＢ１
を一時ファイルＸへ出力する要求を出すと、制御が送信
データ管理部１に渡り、送信データ管理部１は、図１２
に示すように、制御テーブル１３から一時ファイルＸに
対応するデータ伝達用バッファ５−１を認識し（Ｓ６
１）、出力要求されたデータＢ１をデータ伝達用バッフ
ァ５−１にキューイングする（Ｓ６２）。即ち、図９に
示すように、データＢ１を主記憶上に書き込むと共に、
そのアドレスを示すポインタをキュー５１１にキューイ
ングする。そして、格納先のデータ伝達用バッファ名と
格納したデータＢ１とを含む履歴データを送信データ退
避部２に通知する。送信データ退避部２は通知された履
歴データを図１５に示すように永久ファイル８に格納す
る（図１４のＳ８１）。

【００３７】またプロセス６−１がデータＡ１を処理し
て得たデータＣ１を一時ファイルＹへ出力する要求を出
すと、送信データ管理部１は、制御テーブル１３から一
時ファイルＹに対応するデータ伝達用バッファ５−２を
認識し、図９に示すようにデータＣ１を主記憶上に書き
込むと共に、そのアドレスを示すポインタをキュー５２
１にキューイングする。そして、格納先のデータ伝達用
バッファ名と格納したデータＣ１とを含む履歴データを
送信データ退避部２に通知し、送信データ退避部２はこ
の履歴データを永久ファイル８に格納する。

【００３８】他方、プロセス６−１と並行して動作して
いるプロセス６−２において、一時ファイルＸ，Ｚに対
するオープン要求があると（図５のＳ１１）、送信デー
タ管理部１は制御テーブル１３の一時ファイルＸ，Ｚに
対応するステータス欄に、プロセス６−２が使用中であ
る旨を設定する。また、プロセス６−１の処理が進み、
一時ファイルＸからのデータ入力要求があると（Ｓ１
２）、送信データ管理部１は、図１３に示すように、制
御テーブル１３を参照して一時ファイルＸに対応するデ
ータ伝達用バッファ５−１を認識し（Ｓ７１）、そこに
キューイングされているデータを１つ取り出してプロセ
ス６−２に伝達する（Ｓ７３）。即ち、図９のキュー５
１１からポインタを１つデキューイングし、それが指示
するデータＢ１をプロセス６−２に伝達する。ここで、
プロセス６−１が最初のデータＢ１を出力する前にプロ
セス６−２が入力を要求した場合、データ伝達用バッフ
ァ５−１には１つもデータが存在しないため、図１３の
Ｓ７２でＮＯと判定される。このときは、制御テーブル
１３のデータ伝達用バッファ５−１に対応するステータ
ス欄が調べられ、要求元であるプロセス６−２以外のプ
ロセス６−１が未だ使用中であることが確認され、所定
時間の待ち合わせ後にプロセス６−２からの入力要求が
再処理される。この結果、プロセス６−１からデータＢ
１が出力されると、それがプロセス６−２に伝達される
ことになる。

【００３９】またプロセス６−２がデータＢ１を処理し
て得たデータＤ１を一時ファイルＺに出力する要求を出
すと、送信データ管理部１は一時ファイルＺに対応する
データ伝達用バッファ５−３にデータＤ１を格納する。
また、この格納されたデータＤ１を含む履歴データが送
信データ退避部２によって永久ファイル８に格納され
る。

【００４０】更にプロセス６−１，６−２と並行して動
作しているプロセス６−３から一時ファイルＹ，Ｚのオ
ープン要求があった場合、一時ファイルＹ，Ｚからのデ
ータ入力要求があった場合も、前述と同様の処理が行わ
れ、データ伝達用バッファ５−２，５−３から取り出さ
れたデータがプロセス６−３に伝達される。

【００４１】さて、プロセス６−１が図２に示す最後の
データＡＮまで処理し終えたことから、一時ファイル
Ｘ，Ｙのクローズ要求を出すと、送信データ管理部１
は、制御テーブル１３中の一時ファイルＸ，Ｙに対応す
るステータス欄に、プロセス６−１が使用を終えた旨の
記述を登録する。

【００４２】またプロセス６−２が図２に示す最後のデ
ータＢＮを処理し終え、一時ファイルＸからの次のデー
タの入力要求を行うと、送信データ管理部１は一時ファ
イルＸに対応するデータ伝達用バッファ５−１からデー
タを取り出そうとするが、最後のデータＢＮまで伝達し
終わったので、最早取り出すべきデータは存在しない。
このため、送信データ管理部１は図１３のＳ７３からＳ
７４へ進み、制御テーブル１３中のデータ伝達用バッフ
ァ５−１に対応するステータス欄を調べる。この時点で
は、プロセス６−１が使用を終えた旨の記述が登録され
ているため、送信データ管理部１は、全てのデータを伝
達し終えた為にデータ伝達用バッファ５−１が空になっ
ていたものと判断し、要求元のプロセス６−２にデータ
が終了した旨を通知する（Ｓ７６）。これにより、プロ
セス６−２は最後のデータまで処理し終えたことを判別
し（図５のＳ１３）、一時ファイルＸ，Ｚのクローズを
要求し、処理を終える。

【００４３】プロセス６−３が最後の入力データＣＮを
処理し終えた後の動作も、前述したプロセス６−２の場
合と同じである。

【００４４】以上のようにして、データ伝達用バッファ
５−１〜５−３を使用して非同期にデータ伝達し合いな
がら、３つのプロセス６−１〜６−３、つまり３つの連
続するジョブステップ７−１〜７−３が並行して実行さ
れる。

【００４５】バッチジョブ７はその最後のジョブステッ
プまで正常に実行し終えると、終了する。但し、何れか
のジョブステップの実行途中で障害が発生し、処理の続
行が不可能になると、ジョブの実行は異常終了する。こ
のようなときは、途中終了したジョブステップの先頭か
らジョブを再実行する必要がある。本実施例では、一時
ファイルの代わりに主記憶上のデータ伝達用バッファを
使用しているので、障害発生後の再立ち上げ時に主記憶
上のデータ伝達用バッファの内容は消失する。しかしな
がら、送信データ退避部２によって永久ファイル８に送
信データの履歴が保存されているため、送信データ復旧
部３によって復旧することが可能である。以下、この点
について説明する。

【００４６】リスタート制御部１０は、リスタート制御
の一環として、異常終了したジョブの情報を調べて途中
終了したジョブステップを認識し、この途中終了したジ
ョブステップが入力に使用している一時ファイルであっ
て、それを出力用に使用するジョブステップが正常終了
している一時ファイルに対応するデータ伝達用バッファ
を図８の制御テーブル１３から調べる。そして、図１６
に示すように、そのデータ伝達用バッファを主記憶上に
確保し（Ｓ９１）、そのデータ伝達用バッファ名を送信
データ復旧部３に通知して復元を要求する（Ｓ９２）。
また、制御テーブル１３中の当該確保したデータ伝達用
バッファに関連する部分のみを残して他は消去し、新た
な制御テーブル１３を作成する。送信データ復旧部３
は、図１７に示すように、永久ファイル８から、通知さ
れたデータ伝達用バッファ名を含む履歴データを全て抽
出し（Ｓ１０１）、この抽出した履歴データ中のデータ
を、復元要求された主記憶上のデータ伝達バッファに格
納する（Ｓ１０２）。その後、リスタート制御部１０
は、途中終了したジョブステップの先頭からジョブを再
実行するようステップ並列実行管理部４に指示する（Ｓ
９３）。

【００４７】従って、例えばジョブステップ７−１〜７
−３が並行して実行されている状態で、ジョブステップ
７−１のみが正常に終了し、ジョブステップ７−２，７
−３が途中終了した場合、途中終了したジョブステップ
７−２，７−３が入力に使用している一時ファイルであ
って、それを出力用に使用するジョブステップが正常終
了している一時ファイルは、一時ファイルＸと一時ファ
イルＹなので、それらに対応するデータ伝達用バッファ
５−１，５−２が主記憶上に確保され、送信データ復旧
部３により、永久ファイル８に格納されているデータ伝
達用バッファ５−１の全ての履歴データが抽出されてそ
の中のデータがデータ伝達用バッファ５−１に格納さ
れ、また永久ファイル８に格納されているデータ伝達用
バッファ５−１の全ての履歴データが抽出されてその中
のデータがデータ伝達用バッファ５−２に格納される。
そして、ジョブステップ７−２からジョブが再実行され
る。

【００４８】以上本発明の実施例について説明したが、
本発明は以上の実施例にのみ限定されずその他各種の付
加変更が可能である。例えば、後続のジョブステップを
並列に実行すべき指示を直前のジョブステップ記述中に
１つのジョブステップ文（＄ＰＡＲＡＬＬＥＬ）として
挿入したが、ジョブステップ記述間に挿入するようにし
ても良い。また、後続のジョブステップ記述の先頭の＄
ＳＴＥＰ文中に直前のジョブステップとの同時実行を指
示するパラメータを挿入するようにしても良い。

【００４９】

【発明の効果】以上説明した本発明のバッチジョブ実行
方式によれば、以下のような効果を得ることができる。

【００５０】ジョブステップ間のデータ伝達用に、個々
のデータを独立してキューイング，デキューイングでき
る主記憶上のデータ伝達用バッファを使用したので、一
時ファイルを使用した場合のように先行するジョブステ
ップが全てのデータを出力した後に後続のジョブステッ
プがデータの読み出しを開始しなければならないような
制約がなくなり、先行するジョブステップが個々の処理
済データを出力する毎に、その処理済データを後続のジ
ョブステップが読み込むことができ、複数のジョブステ
ップを実質的に同時に並行して動作させることが可能と
なる。これにより、バッチジョブ全体の実行時間を短縮
することができる。

【００５１】一時ファイルの代わりに主記憶上のデータ
伝達用バッファを使用すると、障害発生時等のデータ消
失が問題となるが、送信データ退避部を備える構成で
は、プロセスの動作と並行してデータ伝達用バッファの
内容の履歴を永久ファイルに退避するので、データ消失
を防止できる。そして、送信データ復旧部を備える構成
では、途中終了したジョブステップが入力用に使用する
一時ファイルに対応するデータ伝達用バッファの内容を
主記憶上に復元することができ、ジョブの再実行に要す
る時間を短縮することができる。

【図面の簡単な説明】

【図１】本発明の一実施例のブロック図である。

【図２】ジョブステップ７−１〜７−３の処理例の説明
図である。

【図３】ジョブステップ７−１〜７−３のＪＣＬ記述例
を示す図である。

【図４】ジョブステップ７−１の処理の一例を示すフロ
ーチャートである。

【図５】ジョブステップ７−２の処理の一例を示すフロ
ーチャートである。

【図６】ジョブステップ７−３の処理の一例を示すフロ
ーチャートである。

【図７】ステップ並列実行管理部のジョブ管理手段の処
理例を示すフローチャートである。

【図８】制御テーブルの内容例を示す図である。

【図９】データ伝達用バッファ５−１〜５−３の構成例
を示すブロック図である。

【図１０】送信データ管理部のファイルオープン要求時
の処理例を示すフローチャートである。

【図１１】送信データ管理部のファイルクローズ要求時
の処理例を示すフローチャートである。

【図１２】送信データ管理部のデータ出力要求時の処理
例を示すフローチャートである。

【図１３】送信データ管理部のデータ入力要求時の処理
例を示すフローチャートである。

【図１４】送信データ退避部の処理例を示すフローチャ
ートである。

【図１５】永久ファイルの内容例を示す図である。

【図１６】リスタート制御部の処理例を示すフローチャ
ートである。

【図１７】送信データ復旧部の処理例を示すフローチャ
ートである。

【符号の説明】

１…送信データ管理部 ２…送信データ退避部 ３…送信データ復旧部 ４…ステップ並列実行管理部 ５−１〜５−３…データ伝達用バッファ ６−１〜６−３…プロセス ７…バッチジョブ ７−１〜７−３…ジョブステップ ８…永久ファイル ９…データ管理部 １０…リスタート制御部 １１…ジョブ管理手段 １２…プロセス管理手段 １３…制御テーブル

Claims (3)

【特許請求の範囲】
1. 【請求項１】 複数個のデータを処理して個々のデータ
   毎の処理済データを順次に一時ファイルに出力する第１
   のジョブステップと、前記一時ファイルから個々の処理
   済データを順次に入力して処理する第２のジョブステッ
   プとを含むバッチジョブの実行方式において、 前記第１のジョブステップと前記第２のジョブステップ
   とにそれぞれ別々のプロセスを割り当てて並行して動作
   させるステップ並列実行管理部と、 前記一時ファイルの代わりに主記憶上に設けられた先入
   れ先出し形式のデータ伝達用バッファと、 前記第１のジョブステップに割り当てられたプロセスか
   ら前記一時ファイルに対する書き込み要求があったとき
   に出力データを前記データ伝達用バッファに順次にキュ
   ーイングし、前記第２のジョブステップに割り当てられ
   たプロセスから前記一時ファイルに対する読み込み要求
   があったときに前記データ伝達用バッファにキューイン
   グされたデータを順次に取り出して前記第２のジョブス
   テップに割り当てられたプロセスに伝達する送信データ
   管理部とを備えることを特徴とするバッチジョブ実行方
   式。
2. 【請求項２】 前記データ伝達用バッファの内容の履歴
   を前記プロセスの動作と並行して永久ファイルに退避す
   る送信データ退避部を備えることを特徴とする請求項１
   記載のバッチジョブ実行方式。
3. 【請求項３】 障害発生等の原因によりジョブの実行が
   停止した後、途中終了したジョブステップの先頭からジ
   ョブを再実行する際、途中終了したジョブステップが入
   力に使用していた一時ファイルであって正常終了したジ
   ョブステップが出力に使用していた一時ファイルに対応
   するデータ伝達用バッファの内容の履歴を前記永久ファ
   イルから読み出し、前記正常終了したジョブステップが
   出力した全てのデータを格納したデータ伝達用バッファ
   を主記憶上に復元する送信データ復旧部を備えることを
   特徴とする請求項２記載のバッチジョブ実行方式。