JP5876406B2 - Process execution device and process execution method - Google Patents
Process execution device and process execution method Download PDFInfo
- Publication number
- JP5876406B2 JP5876406B2 JP2012266281A JP2012266281A JP5876406B2 JP 5876406 B2 JP5876406 B2 JP 5876406B2 JP 2012266281 A JP2012266281 A JP 2012266281A JP 2012266281 A JP2012266281 A JP 2012266281A JP 5876406 B2 JP5876406 B2 JP 5876406B2
- Authority
- JP
- Japan
- Prior art keywords
- batch
- execution
- completion information
- unit
- storage unit
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims description 243
- 230000008569 process Effects 0.000 title claims description 227
- 238000001994 activation Methods 0.000 claims description 208
- 230000004913 activation Effects 0.000 claims description 205
- 230000004044 response Effects 0.000 description 30
- 238000012544 monitoring process Methods 0.000 description 24
- 238000004891 communication Methods 0.000 description 22
- 238000010586 diagram Methods 0.000 description 12
- 230000006870 function Effects 0.000 description 5
- 230000005540 biological transmission Effects 0.000 description 4
- 230000002159 abnormal effect Effects 0.000 description 3
- 238000012806 monitoring device Methods 0.000 description 3
- 238000001514 detection method Methods 0.000 description 2
- 230000007246 mechanism Effects 0.000 description 1
- 230000002093 peripheral effect Effects 0.000 description 1
Images
Landscapes
- Programmable Controllers (AREA)
Description
本発明は、処理実行装置、処理実行方法に関する。 The present invention relates to a process execution device and a process execution method.
近年、ネットワークに接続された複数のコンピュータによる情報システムが用いられている。このような情報システムでは、各コンピュータには用途に応じたアプリケーションプログラムが配備されている。 In recent years, an information system using a plurality of computers connected to a network has been used. In such an information system, each computer is provided with an application program corresponding to the application.
例えば、特許文献1に記載の技術では、ジョブ管理装置のマネージャープログラムが、複数の第1〜第3の計算機に配備されている各アプリケーションプログラム(以下、ジョブ、またはバッチともいう)の起動、実行制御、および監視などを行っている。特許文献1に記載の技術では、第1の計算機にジョブA1が配置され、第2の計算機にはジョブA2が配置され、第3の計算機にはジョブA3が配備されている。また、特許文献1に記載の技術では、ジョブ管理装置のマネージャープログラムは、ジョブの実行順番やジョブの起動時刻などの設定情報を有している。
For example, in the technique described in
特許文献1に記載の技術では、ジョブ管理装置のマネージャープログラムが、設定情報に応じて第1の計算機に配備されているジョブA1を実行する。そして、特許文献1に記載の技術では、ジョブ管理装置のマネージャープログラムが、ジョブA1が終了後、ジョブA1の出力をジョブA2へ入力し、ジョブA2を起動する。
In the technique described in
しかしながら、特許文献1に記載の技術では、ジョブ管理装置が各計算機に配備されているジョブを起動、実行制御および監視している。このため、特許文献1に記載の技術では、ジョブ管理装置が必要なため、情報システムのコストが高いという課題があった。
However, in the technique described in
本発明は上記の点に鑑みてなされたものであり、情報システムのコストを削減する処理実行装置、処理実行方法を提供することを目的としている。 The present invention has been made in view of the above points, and an object thereof is to provide a processing execution apparatus and a processing execution method that reduce the cost of an information system.
(1)上記目的を達成するため、本発明の一態様に係る処理実行装置は、自処理実行装置が実行する自処理と並列処理される他の処理実行装置による他処理の実行が完了したことを示す実行完了情報に基づいて、並列処理される前記自処理と前記他処理とを含む前段処理の実行が完了しているか否かを判定し、前記前段処理に含まれるすべての処理が完了していると判定した場合に、前記前段処理の後に実行される後段処理を起動する判定部を備えることを特徴としている。 (1) In order to achieve the above object, the processing execution device according to one aspect of the present invention has completed execution of other processing by another processing execution device that is processed in parallel with the own processing executed by the own processing execution device. On the basis of the execution completion information indicating whether or not the execution of the preceding process including the self process and the other process to be processed in parallel is completed, and all the processes included in the preceding process are completed. A determination unit that activates a post-stage process executed after the pre-stage process.
(2)また、本発明の一態様に係る処理実行装置において、前記判定部は、前記自処理の実行の完了を前記判定の開始条件にして、前記前段処理に含まれるすべての処理の実行が完了しているか否かを判定するようにしてもよい。 (2) In the processing execution apparatus according to the aspect of the present invention, the determination unit may execute all the processes included in the preceding stage process with the completion of the execution of the own process as a start condition of the determination. You may make it determine whether it is completed.
(3)また、本発明の一態様に係る処理実行装置において、前記自処理の実行が完了したときに、当該自処理の実行が完了したことを示す前記実行完了情報を記憶部に書き込む実行完了情報書込部を備え、前記判定部は、前記記憶部に記憶されている前記実行完了情報を読み出し、読み出した前記実行完了情報に基づいて、前記前段処理に含まれるすべての処理の実行が完了しているか否かを判定するようにしてもよい。 (3) Further, in the process execution device according to one aspect of the present invention, when the execution of the own process is completed, the execution completion of writing the execution completion information indicating that the execution of the own process is completed in the storage unit An information writing unit, wherein the determination unit reads the execution completion information stored in the storage unit, and based on the read execution completion information, execution of all the processes included in the preceding process is completed You may make it determine whether it is doing.
(4)また、本発明の一態様に係る処理実行装置において、前記実行完了情報書込部は、前段処理の実行が完了したとき、予め定められる書込み順序に基づいて前記実行完了情報を前記記憶部に書き込むようにしてもよい。 (4) In the processing execution apparatus according to the aspect of the present invention, the execution completion information writing unit stores the execution completion information based on a predetermined writing order when the execution of the previous stage processing is completed. You may make it write in a part.
(5)また、本発明の一態様に係る処理実行装置において、前記前段処理の開始時に起動回数を計数する起動カウンタを備え、前記実行完了情報書込部は、前段処理の実行が完了したときに、前記実行完了情報と前記起動カウンタが計数した起動回数とを関連づけて前記記憶部に書き込むようにしてもよい。 (5) In the processing execution apparatus according to an aspect of the present invention, the processing execution apparatus includes a startup counter that counts the number of startups at the start of the preceding stage processing, and the execution completion information writing unit completes the execution of the preceding stage processing. In addition, the execution completion information and the number of activations counted by the activation counter may be associated and written to the storage unit.
(6)また、本発明の一態様に係る処理実行装置において、前記判定部は、前記記憶部に記憶されている自装置の起動回数と同じ値の前記起動回数に関連づけられている前記実行完了情報を読み出し、読み出した前記実行完了情報に基づいて、複数の前記前段処理の実行が完了しているか否かを判定するようにしてもよい。 (6) Moreover, in the process execution device according to one aspect of the present invention, the determination unit completes the execution associated with the number of activations having the same value as the number of activations of the own device stored in the storage unit. Information may be read out, and it may be determined based on the read execution completion information whether or not execution of a plurality of the preceding processes has been completed.
(7)上記目的を達成するため、本発明の一態様に係る処理実行方法は、判定部が、自処理実行装置が実行する自処理と並列処理される他の処理実行装置による他処理の実行が完了したことを示す実行完了情報に基づいて、並列処理される前記自処理と前記他処理とを含む前段処理の実行が完了しているか否かを判定し、前記前段処理に含まれるすべての処理が完了していると判定した場合に、前記前段処理の後に実行される後段処理を起動する判定手順を有することを特徴とする。 (7) In order to achieve the above object, in the process execution method according to one aspect of the present invention, the determination unit executes another process by another process execution apparatus that is processed in parallel with the own process executed by the own process execution apparatus. Based on the execution completion information indicating that the processing is completed, it is determined whether or not the execution of the preceding process including the own process and the other process that are processed in parallel is completed, and all of the included in the preceding process When it is determined that the process has been completed, a determination procedure for starting a subsequent process executed after the preceding process is provided.
本発明の態様(1)および(7)によれば、複数のバッチが並列に処理されていた場合であっても、判定部が互いにバッチが終了したか判定し、すべてのバッチが終了したと判定した場合に、判定した判定部が、次のバッチを起動するようにした。この結果、バッチ管理装置が不要になり情報システムのコストを削減できる。
本発明の態様(2)によれば、自処理の実行の完了を判定の開始条件にするため、前段処理に含まれるすべての処理の実行が完了しているか否かの判定を常時行うことが不要になり処理装置の処理実行負荷を低減できる。
本発明の態様(3)によれば、複数のバッチが並列に処理されていた場合であっても、判定部が互いにバッチが終了したか否かを記憶部に記憶されている実行完了情報に基づいて判定できる。この結果、バッチの終了を監視するためのバッチ管理装置が不要になり情報システムのコストを削減できる。
According to the aspects (1) and (7) of the present invention, even when a plurality of batches are processed in parallel, the determination unit determines whether or not the batch has ended, and all batches have ended. When determined, the determined determination unit starts the next batch. As a result, the batch management device is not required, and the cost of the information system can be reduced.
According to the aspect (2) of the present invention, since the completion of the execution of the own process is set as the determination start condition, it is always possible to determine whether or not the execution of all the processes included in the preceding process is completed. It becomes unnecessary and the processing execution load of the processing apparatus can be reduced.
According to the aspect (3) of the present invention, even when a plurality of batches are processed in parallel, the execution completion information stored in the storage unit indicates whether or not the determination units have completed batches. It can be determined based on. As a result, a batch management device for monitoring the end of the batch becomes unnecessary, and the cost of the information system can be reduced.
本発明の態様(4)によれば、複数のバッチが並列に処理されて同時に終了した場合であっても、記憶部に実行完了情報を書き込む順番を調停できる。判定部は、互いに記憶部に記憶されている実行完了情報を確認することができる。この結果、バッチ管理装置が不要になり情報システムのコストを削減できる。
本発明の態様(5)および(6)によれば、処理実行装置が各々、起動カウンタを備え、バッチの起動毎に起動回数を加算する。このようにバッチの起動回数をお互いに監視しあうことで、バッチのネット構成が複数回起動されても、起動回数に合わせてネット構成を起動することができる。
According to the aspect (4) of the present invention, even when a plurality of batches are processed in parallel and finished at the same time, the order of writing execution completion information in the storage unit can be arbitrated. The determination units can confirm the execution completion information stored in the storage unit. As a result, the batch management device is not required, and the cost of the information system can be reduced.
According to the aspects (5) and (6) of the present invention, each of the process execution devices includes the activation counter, and adds the activation count for each activation of the batch. By monitoring the number of batch activations in this way, the net configuration can be activated in accordance with the number of activations even when the batch net configuration is activated a plurality of times.
[第1の実施形態]
以下、図面を参照しながら本発明の実施形態について説明する。
図1は、本実施形態に係る処理実行装置および処理実行システムの概略構成例を説明する図である。
図1に示すように、処理実行システム1は、n(nは2以上の整数)台の処理実行装置10−n、および記憶装置20を備えている。処理実行装置10−nは、各々、通信ネットワーク30を介して接続されている。通信ネットワーク30は、有線ネットワーク、または無線ネットワークである。図1に示した例では、処理実行装置10−nが4台(n=4)接続されている例を示したが、処理実行装置10−nの台数は、2台以上であればよい。
[First Embodiment]
Hereinafter, embodiments of the present invention will be described with reference to the drawings.
FIG. 1 is a diagram illustrating a schematic configuration example of a process execution device and a process execution system according to the present embodiment.
As shown in FIG. 1, the
記憶装置20は、記憶部201を備えている。記憶部201には、実行完了情報が記憶されている。なお、記憶部201に記憶されている情報については、図3を参照して後述する。
The
処理実行装置10−nは、各々、操作部101−n、通信部102−n、処理部103−n、判定部104−n、実行完了情報書込部105−nおよび記憶部106−nを備えている。 The processing execution device 10-n includes an operation unit 101-n, a communication unit 102-n, a processing unit 103-n, a determination unit 104-n, an execution completion information writing unit 105-n, and a storage unit 106-n, respectively. I have.
操作部101−nは、処理実行システム1の利用者の操作を検出し、検出した検出結果を処理部103−nに出力する。この検出結果には、記憶部106−nに記憶されているアプリケーションプログラム(ジョブ、またはバッチともいう)の起動指示が含まれている。操作部101−nとは、例えば、キーボード、マウス、タッチパネルセンサを有する表示部等である。ここで、起動指示とは、バッチを起動する指示である。バッチとは、処理目的ごとに区切られた1つの流れのプログラム群である。
通信部102−nは、他の処理実行装置10−nとの通信を、通信ネットワーク30を介して行う。以下、説明の対象としている処理実行装置10−nを自装置(または、自処理実行装置)ともいい、この自装置と通信ネットワーク30を介して情報の送受信を行う他の処理実行装置10−nを他装置ともいう。また、この自装置が実行している処理を自処理ともいい、他装置が実行している処理を他処理ともいう。
The operation unit 101-n detects the operation of the user of the
The communication unit 102-n performs communication with another processing execution device 10-n via the
処理部103−nは、自装置の操作部101−nから入力された起動指示、または他装置の判定部104−nから入力された起動指示に応じて、自装置の記憶部106−nに記憶されているバッチの実行制御を行う。なお、他装置が起動指示を出力する仕組みについては後述する。処理部103−nは、バッチの実行制御の終了後、バッチが終了したことを示すバッチ終了情報を自装置の判定部104−nに出力する。 In response to the activation instruction input from the operation unit 101-n of the own device or the activation instruction input from the determination unit 104-n of the other device, the processing unit 103-n stores in the storage unit 106-n of the own device. Controls execution of stored batches. Note that the mechanism by which the other device outputs the activation instruction will be described later. After the end of the batch execution control, the processing unit 103-n outputs batch end information indicating that the batch has ended to the determination unit 104-n of the own device.
判定部104−nは、自装置の処理部103−nから入力されたバッチ終了情報に応じて、自装置のバッチが終了したと判定する。
ここで、自装置と並列に行う処理を並列処理という。すなわち並列処理とは、異なる2台の処理実行装置10−nが各々、バッチを実行することである。並列処理されるバッチは、例えば1台の処理実行装置10−nが出力した起動指示に応じて実行が開始される第1のバッチと第2のバッチであってもよい。あるいは、第1のバッチと第2のバッチが、1台の処理実行装置10−nが出力した起動指示に応じて実行が開始され、第2のバッチが終了した後、第2のバッチを実行していた処理実行装置10−nが出力した起動指示により第3のバッチが実行される場合、並列処理されるバッチは、第1のバッチと、第3のバッチであってもよい。
The determination unit 104-n determines that the batch of the own device has ended according to the batch end information input from the processing unit 103-n of the own device.
Here, processing performed in parallel with the own apparatus is referred to as parallel processing. In other words, the parallel processing means that two different processing execution devices 10-n each execute a batch. The batches to be processed in parallel may be, for example, a first batch and a second batch whose execution is started in response to a start instruction output from one process execution device 10-n. Alternatively, the first batch and the second batch are executed in response to a start instruction output by one process execution device 10-n, and the second batch is executed after the second batch is completed. When the third batch is executed in accordance with the start instruction output from the processing execution apparatus 10-n that has been executed, the batch to be processed in parallel may be the first batch and the third batch.
判定部104−nは、自装置におけるバッチが終了したと判定した場合、記憶装置20の記憶部201に実行完了情報を書き込む指示を自装置の実行完了情報書込部105−nに対して出力する。ここで、実行完了情報とは、バッチが終了したことを示す情報である。
If the determination unit 104-n determines that the batch in the own device has ended, the determination unit 104-n outputs an instruction to write execution completion information to the
実行完了情報書込部105−nは、判定部104−nから入力された実行完了情報を書き込む指示に応じて、実行完了情報を記憶装置20の記憶部201に書き込む。
The execution completion information writing unit 105-n writes the execution completion information in the
判定部104−nの説明に戻って、判定部104−nは、自装置の記憶部106−nに記憶されている設定情報の中から監視対象のバッチ名を読み出す。判定部104−nは、自装置および並列して処理されている他装置におけるすべてのバッチが終了したか否かを、監視対象のバッチ名と関連づけて記憶部201に記憶されている実行完了情報に基づいて判定する。すなわち、判定部104−nは、自処理の実行の完了を判定の開始条件にして、前段処理に含まれるすべての処理の実行が完了しているか否かを判定する。
判定部104−nは、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定した場合、自装置の記憶部106−nに記憶されている設定情報に応じて次に実行するバッチに対する起動指示を、通信ネットワーク30を介して他の装置に送信する。設定情報に記述されている次に実行するバッチが複数の場合、判定部104−nは、設定情報に記述されている複数のバッチ毎に起動指示を他装置に送信する。なお、設定情報については、図2を参照して後述する。
Returning to the description of the determination unit 104-n, the determination unit 104-n reads the batch name to be monitored from the setting information stored in the storage unit 106-n of the own device. The determination unit 104-n associates with the monitoring target batch name whether or not all batches in the own device and other devices processed in parallel have been completed, and stores the execution completion information. Determine based on. In other words, the determination unit 104-n determines whether or not all the processes included in the preceding process have been executed, with the completion of the execution of the own process as a determination start condition.
If the determination unit 104-n determines that all batches in the own device and the other devices being processed in parallel have been completed, the determination unit 104-n performs the next operation according to the setting information stored in the storage unit 106-n of the own device. The activation instruction for the batch to be executed is transmitted to another device via the
記憶部106−nには、アプリケーションプログラムおよび設定情報が記憶されている。例えば、記憶部106−1には、アプリケーションA(バッチAともいう)が記憶され、記憶部106−2には、アプリケーションB(バッチBともいう)が記憶されている。記憶部106−3には、アプリケーションC(バッチCともいう)が記憶され、記憶部106−4には、アプリケーションD(バッチDともいう)が記憶されている。 The storage unit 106-n stores application programs and setting information. For example, application A (also referred to as batch A) is stored in the storage unit 106-1, and application B (also referred to as batch B) is stored in the storage unit 106-2. The storage unit 106-3 stores application C (also referred to as batch C), and the storage unit 106-4 stores application D (also referred to as batch D).
図2は、本実施形態に係る記憶部106−nに記憶されている設定情報の例を説明する図である。図2に示すように、記憶部106−nには、バッチの実行順番、実行するバッチ、バッチを実行する処理実行装置名、バッチ起動時刻、監視対象のバッチ名、次に実行するバッチ、およびアプリケーションプログラムが関連づけられて記憶されている。設定情報とは、バッチの実行順番、実行するバッチ、バッチを実行する処理実行装置名、バッチ起動時刻、監視対象のバッチ、次に実行するバッチである。
例えば符号301に示すように、記憶部106−nに記憶されている情報は、バッチの実行順番が1であり、実行するバッチがバッチAであり、バッチを実行する処理実行装置名が処理実行装置10−1である。また、バッチ起動時刻が10時00分00秒であり、監視対象のバッチ名がAであり、次に実行するバッチがバッチBとバッチCである。また、記憶部106−nにはバッチAが記憶されている。
FIG. 2 is a diagram illustrating an example of setting information stored in the storage unit 106-n according to the present embodiment. As shown in FIG. 2, the storage unit 106-n includes a batch execution order, a batch to be executed, a name of a process execution device that executes the batch, a batch start time, a batch name to be monitored, a batch to be executed next, and An application program is associated and stored. The setting information includes the batch execution order, the batch to be executed, the name of the process execution device that executes the batch, the batch start time, the batch to be monitored, and the batch to be executed next.
For example, as indicated by
例えば符号302に示すように、記憶部106−nに記憶されている情報は、バッチの実行順番が2であり、実行するバッチがバッチBであり、バッチを実行する処理実行装置名が処理実行装置10−2である。また、バッチ起動時刻は記述無しであり、監視対象のバッチ名がBおよびCであり、次に実行するバッチがバッチDである。また、記憶部106−nにはバッチBが記憶されている。
例えば符号303に示すように、記憶部106−nに記憶されている情報は、バッチの実行順番が2であり、実行するバッチがバッチCであり、バッチを実行する処理実行装置名が処理実行装置10−3である。また、バッチ起動時刻は記述無しであり、監視対象のバッチ名がBおよびCであり、次に実行するバッチがバッチDである。また、記憶部106−nにはバッチCが記憶されている。
For example, as indicated by
For example, as indicated by
例えば符号304に示すように、記憶部106−nに記憶されている情報は、バッチの実行順番が3であり、実行するバッチがバッチDであり、バッチを実行する処理実行装置名が処理実行装置10−4である。また、バッチ起動時刻は記述無しであり、監視対象のバッチ名がDであり、次に実行するバッチは記述無しである。また、記憶部106−nにはバッチDが記憶されている。
なお、図2に示した情報すべてが、各処理実行装置10−nの各記憶部106−nに記憶されていてもよい。あるいは、自装置分の情報のみが記憶部106−nに記憶されていてもよく、例えば符号301に示した情報のみが処理実行装置10−1の記憶部106−1に記憶されていてもよい。
For example, as indicated by
2 may be stored in each storage unit 106-n of each processing execution device 10-n. Alternatively, only the information for the own device may be stored in the storage unit 106-n, and for example, only the information indicated by
図3は、本実施形態に係る記憶装置20に記憶されている情報の例を説明する図である。図3に示すように、記憶装置20の記憶部201には、バッチ名と実行完了情報とが関連づけられて記憶されている。例えば、記憶部201には、バッチ名Aと実行完了情報とが関連づけられて記憶されている。
FIG. 3 is a diagram illustrating an example of information stored in the
図4は、本実施形態に係るバッチの連携を説明する図である。符号401はバッチAであり、符号403はバッチBであり、符号404はバッチCであり、符号407はバッチDである。また、符号402は、判定部104−1が行うバッチ完了判定と次のバッチ起動処理を示し、符号405は、判定部104−2が行うバッチ完了判定と次のバッチ起動処理を示す。符号406は、判定部104−3が行うバッチ完了判定と次のバッチ起動処理を示す。
FIG. 4 is a diagram for explaining cooperation of batches according to the present embodiment.
図4に示すように、まず処理実行装置10−1の処理部103−1は、バッチAを起動する。次に、判定部104−1は、バッチAが終了したか判定し、バッチAが終了した場合、バッチBとバッチCに対する起動指示を処理実行装置10−1と処理実行装置10−2に送信する。
次に、処理実行装置10−2の処理部103−2はバッチBを起動し、処理実行装置10−3の処理部103−3はバッチCを起動する。
次に、判定部104−2と判定部104−3は、互いにバッチが終了したかを判定し、最後にバッチを終了したと判定した方の判定部104が、バッチDに対する起動指示を処理実行装置10−4に送信する。
As illustrated in FIG. 4, the processing unit 103-1 of the process execution device 10-1 first activates the batch A. Next, the determination unit 104-1 determines whether or not the batch A is completed. When the batch A is completed, the activation instruction for the batch B and the batch C is transmitted to the process execution device 10-1 and the process execution device 10-2. To do.
Next, the processing unit 103-2 of the processing execution device 10-2 starts batch B, and the processing unit 103-3 of the processing execution device 10-3 starts batch C.
Next, the determination unit 104-2 and the determination unit 104-3 determine whether or not the batch has ended, and the determination unit 104 that has finally determined that the batch has ended executes the start instruction for the batch D Transmit to device 10-4.
図5は、本実施形態に係る処理実行装置10−n、記憶装置20間の処理のシーケンスの一例である。図5に示した例では、図1に示したように処理実行装置10−1〜10−4、記憶装置20が通信ネットワーク30を介して接続されている。また、処理実行装置10−nの各記憶部106−nには、図2に示した情報が記憶されている。
FIG. 5 is an example of a process sequence between the process execution device 10-n and the
(ステップS1)処理実行装置10−1の処理部103−1は、記憶部106−1に記憶されている設定情報に応じて実行するバッチAを記憶部106−1から読み出す。次に処理部103−1は、読み出したバッチAを起動する。処理部103−1は、ステップS1終了後、処理をステップS2に進める。
(ステップS2)処理部103−1は、バッチAを実行制御する。処理部103−1は、ステップS2終了後、処理をステップS3に進める。
(Step S1) The processing unit 103-1 of the process execution device 10-1 reads out the batch A to be executed according to the setting information stored in the storage unit 106-1 from the storage unit 106-1. Next, the processing unit 103-1 starts the read batch A. The processing unit 103-1 advances the process to step S2 after step S1 ends.
(Step S2) The processing unit 103-1 controls execution of the batch A. After the end of step S2, processing unit 103-1 advances the process to step S3.
(ステップS3)処理部103−1は、バッチAが終了した際、バッチ終了情報を判定部104−1に出力する。次に、判定部104−1は、処理部103−1から入力されたバッチ終了情報に応じてバッチAが終了したと判定する。処理部103−1は、ステップS3終了後、処理をステップS4に進める。
(ステップS4)判定部104−1は、記憶装置20に実行完了情報を書き込む指示を実行完了情報書込部105−1に対して出力する。次に、実行完了情報書込部105−1は、判定部104−1から入力された実行完了情報を書き込む指示に応じて、バッチ名Aと実行完了情報とを関連づけて記憶装置20の記憶部201に書き込む。処理部103−1は、ステップS4終了後、処理をステップS5に進める。
(Step S3) When the batch A is completed, the processing unit 103-1 outputs batch completion information to the determination unit 104-1. Next, the determination unit 104-1 determines that the batch A has ended according to the batch end information input from the processing unit 103-1. The processing unit 103-1 advances the process to step S4 after step S3 ends.
(Step S4) The determination unit 104-1 outputs an instruction to write execution completion information to the
(ステップS5)判定部104−1は、記憶部106−1に記憶されている設定情報のうち、監視対象のバッチ名Aを読み出す。次に、判定部104−1は、バッチ名Aに関連づけられた実行完了情報が記憶部201に記憶されているか否かを確認する。図5に示した例では、監視対象のバッチ名Aに関連づけられた実行完了情報が記憶部201に記憶されている。このため判定部104−1は、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定し、処理をステップS6に進める。
(ステップS6)判定部104−1は、記憶部106−1に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2に送信し、バッチCに対する起動指示を処理実行装置10−3に送信する。
(Step S5) The determination unit 104-1 reads the monitoring target batch name A from the setting information stored in the storage unit 106-1. Next, the determination unit 104-1 checks whether or not the execution completion information associated with the batch name A is stored in the
(Step S6) The determination unit 104-1 transmits an activation instruction for the batch B to the process execution device 10-2 according to the setting information stored in the storage unit 106-1, and processes the activation instruction for the batch C. It transmits to the execution apparatus 10-3.
(ステップS7)処理実行装置10−2の処理部103−2は、処理実行装置10−1から入力されたバッチBに対する起動指示に応じて、記憶部106−2に記憶されている設定情報に基づいてバッチBを読み出す。処理部103−2は、読み出したバッチBを起動する。
(ステップS8)処理実行装置10−3の処理部103−3は、処理実行装置10−1から入力されたバッチCに対する起動指示に応じて、記憶部106−3に記憶されている設定情報に基づいてバッチCを読み出す。処理部103−3は、読み出したバッチCを起動する。これにより、バッチBとバッチCとが並列処理される。
(Step S <b> 7) The processing unit 103-2 of the process execution device 10-2 changes the setting information stored in the storage unit 106-2 according to the activation instruction for the batch B input from the process execution device 10-1. Based on this, batch B is read. The processing unit 103-2 activates the read batch B.
(Step S8) The processing unit 103-3 of the process execution device 10-3 changes the setting information stored in the storage unit 106-3 according to the activation instruction for the batch C input from the process execution device 10-1. Based on this, batch C is read. The processing unit 103-3 activates the read batch C. Thereby, batch B and batch C are processed in parallel.
(ステップS9)処理部103−2は、バッチBを実行制御する。処理部103−2は、ステップS9終了後、処理をステップS11に進める。
(ステップS10)処理部103−3は、バッチCを実行制御する。処理部103−3は、ステップS10終了後、処理をステップS14に進める。
(Step S9) The processing unit 103-2 controls execution of the batch B. The process part 103-2 advances a process to step S11 after completion | finish of step S9.
(Step S10) The processing unit 103-3 controls execution of the batch C. The processing unit 103-3 advances the process to step S14 after step S10 ends.
(ステップS11)処理部103−2は、バッチBが終了した際、バッチ終了情報を判定部104−2に出力する。次に、判定部104−2は、処理部103−2から入力されたバッチ終了情報に応じてバッチBが終了したと判定する。処理部103−2は、ステップS11終了後、処理をステップS12に進める。 (Step S11) When the batch B ends, the processing unit 103-2 outputs the batch end information to the determination unit 104-2. Next, the determination unit 104-2 determines that the batch B has ended according to the batch end information input from the processing unit 103-2. The process part 103-2 advances a process to step S12 after completion | finish of step S11.
(ステップS12)判定部104−2は、バッチBが終了したと判定した場合、記憶部201に実行完了情報を書き込む指示を実行完了情報書込部105−2に対して出力する。次に、実行完了情報書込部105−2は、判定部104−2から入力された実行完了情報を書き込む指示に応じて、バッチ名Bと実行完了情報とを関連づけて記憶部201に書き込む。処理部103−2は、ステップS12終了後、処理をステップS13に進める。
(Step S12) When the determination unit 104-2 determines that the batch B has ended, the determination unit 104-2 outputs an instruction to write execution completion information to the
(ステップS13)判定部104−2は、記憶部106−2に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−2は、監視対象であるバッチ名BとCに各々関連づけられて記憶されている実行完了情報が記憶部201に記憶されているか否か確認する。図5に示した例では、記憶部201に監視対象のバッチ名Bに関連づけられた実行完了情報が記憶されているが、監視対象のバッチ名Cに関連づけられた実行完了情報が記憶されていない。このため判定部104−2は、自装置および並列して処理されている他装置におけるすべてのバッチが終了していないと判定する。
(Step S13) The determination unit 104-2 reads the batch names B and C to be monitored from the setting information stored in the storage unit 106-2. Next, the determination unit 104-2 confirms whether or not the execution completion information stored in association with the batch names B and C to be monitored is stored in the
(ステップS14)処理部103−3は、バッチCが終了した際、バッチ終了情報を判定部104−3に出力する。次に、判定部104−3は、処理部103−3から入力されたバッチ終了情報に応じてバッチCが終了したと判定する。処理部103−3は、ステップS14終了後、処理をステップS15に進める。 (Step S14) When the batch C ends, the processing unit 103-3 outputs the batch end information to the determination unit 104-3. Next, the determination unit 104-3 determines that the batch C has ended according to the batch end information input from the processing unit 103-3. The processing unit 103-3 advances the process to step S15 after step S14 ends.
(ステップS15)判定部104−3は、バッチCが終了したと判定した場合、記憶部201に実行完了情報を書き込む指示を実行完了情報書込部105−3に対して出力する。次に、実行完了情報書込部105−3は、判定部104−3から入力された実行完了情報を書き込む指示に応じて、バッチ名Cと実行完了情報とを関連づけて記憶部201に書き込む。処理部103−3は、ステップS15終了後、処理をステップS16に進める。
(Step S15) When the determination unit 104-3 determines that the batch C has ended, the determination unit 104-3 outputs an instruction to write execution completion information to the
(ステップS16)判定部104−3は、記憶部106−3に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−3は、監視対象であるバッチ名BとCに各々関連づけられて記憶されている実行完了情報が記憶部201に記憶されているか否か確認する。図5に示した例では、記憶部201に監視対象のバッチ名Bに関連づけられた実行完了情報が記憶され、監視対象のバッチ名Cに関連づけられた実行完了情報が記憶されている。このため判定部104−3は、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定する。処理部103−3は、ステップS16終了後、処理をステップS17に進める。
(Step S16) The determination unit 104-3 reads the batch names B and C to be monitored from the setting information stored in the storage unit 106-3. Next, the determination unit 104-3 checks whether or not the execution completion information stored in association with the batch names B and C to be monitored is stored in the
(ステップS17)判定部104−3は、記憶部106−3に記憶されている設定情報に応じて、バッチDに対する起動指示を処理実行装置10−4に送信する。
(ステップS18)処理実行装置10−4の処理部103−4は、処理実行装置10−3から入力されたバッチDに対する起動指示に応じて、記憶部106−4に記憶されている設定情報に基づいてバッチDを読み出す。処理部103−4は、読み出したバッチDを起動する。処理部103−4は、ステップS18終了後、処理をステップS19に進める。
(ステップS19)処理部103−4は、バッチDを実行制御する。
(Step S17) The determination unit 104-3 transmits an activation instruction for the batch D to the process execution device 10-4 in accordance with the setting information stored in the storage unit 106-3.
(Step S <b> 18) The processing unit 103-4 of the process execution device 10-4 changes the setting information stored in the storage unit 106-4 according to the activation instruction for the batch D input from the process execution device 10-3. Based on this, batch D is read out. The processing unit 103-4 activates the read batch D. The process part 103-4 advances a process to step S19 after completion | finish of step S18.
(Step S19) The processing unit 103-4 controls the execution of the batch D.
以上のように、本実施形態の処理実行装置10−nは、前段処理の実行が完了したことを示す実行完了情報に基づいて、複数の前段処理の実行が完了しているか否かを互いに判定し、すべての前段処理が完了していると判定した場合に、前段処理の後に実行される後段処理を起動する判定部104−nを備える。
これにより、複数のバッチが並列に処理されていた場合であっても、判定部104−nが互いにバッチが終了したか判定し、すべてのバッチが終了したと判定した場合に、判定した判定部104−nが、次のバッチを起動するようにした。この結果、バッチ管理装置が不要になり情報システムのコストを削減できる。
As described above, the process execution devices 10-n according to the present embodiment mutually determine whether or not the execution of a plurality of preceding processes has been completed based on the execution completion information indicating that the execution of the preceding processes has been completed. When it is determined that all the pre-stage processing has been completed, a determination unit 104-n that activates the post-stage process that is executed after the pre-stage process is provided.
As a result, even when a plurality of batches are processed in parallel, the determination unit 104-n determines whether the batches have ended with each other, and determines that all the batches have ended. 104-n started the next batch. As a result, the batch management device is not required, and the cost of the information system can be reduced.
また、本実施形態の処理実行装置10−nは、前段処理の実行が完了したとき、実行完了情報を記憶部(201または106−n)に書き込む実行完了情報書込部105−nを備え、判定部104−nは、記憶部(201または106−n)に記憶されている実行完了情報を読み出し、読み出した実行完了情報に基づいて、複数の前段処理の実行が完了しているか否かを互いに判定する。
これにより、複数のバッチが並列に処理されていた場合であっても、判定部104−nが互いにバッチが終了したか否かを記憶装置20の記憶部201に記憶されている実行完了情報に基づいて判定できる。この結果、バッチの終了を監視するためのバッチ管理装置が不要になり情報システムのコストを削減できる。
Further, the processing execution device 10-n of the present embodiment includes an execution completion information writing unit 105-n that writes execution completion information to the storage unit (201 or 106-n) when the execution of the previous stage processing is completed. The determination unit 104-n reads the execution completion information stored in the storage unit (201 or 106-n), and determines whether or not the execution of a plurality of pre-stage processes has been completed based on the read execution completion information. Judge each other.
As a result, even when a plurality of batches are processed in parallel, whether or not the determination units 104-n have completed the batches is stored in the execution completion information stored in the
なお、本実施形態では、各バッチの実行完了情報を、記憶装置20の記憶部201に記憶させる例を説明したが、これに限られない。例えば、実行完了情報書込部105−2は、バッチB終了後、実行終了情報を自装置の記憶部106−2に記憶させるようにしてもよい。そして、判定部104−3は、バッチC終了後、バッチB関連づけられた実行終了情報が記憶部106−2に記憶されているか否かを確認することで、バッチBが終了しているか否かを判定するようにしてもよい。同様に、実行完了情報書込部105−3は、バッチC終了後、実行終了情報を自装置の記憶部106−3に記憶させるようにしてもよい。そして、判定部104−2は、バッチB終了後、バッチCに関連づけられた実行終了情報が記憶部106−3に記憶されているか否かを確認することで、バッチCが終了しているか否かを判定するようにしてもよい。
In the present embodiment, the example in which the execution completion information of each batch is stored in the
なお、図4または図5に示した例において、バッチ終了後、判定部104−nは、各バッチで得られた値を、次のバッチに引き渡すようにしてもよい。例えば、バッチA終了後、判定部104−1は、バッチBを実行する処理実行装置10−2と、バッチCを実行する処理実行装置10−3へバッチAで得られた値を引き渡すようにしてもよい。また、バッチBおよびバッチC終了後、判定部104−2または判定部104−3は、バッチDを実行する処理実行装置10−4へバッチBおよびバッチCで得られた値を引き渡すようにしてもよい。 In the example shown in FIG. 4 or FIG. 5, after the batch is completed, the determination unit 104-n may deliver the value obtained in each batch to the next batch. For example, after the completion of the batch A, the determination unit 104-1 delivers the value obtained in the batch A to the process execution device 10-2 that executes the batch B and the process execution device 10-3 that executes the batch C. May be. Further, after the completion of batch B and batch C, determination unit 104-2 or determination unit 104-3 delivers the values obtained in batch B and batch C to process execution device 10-4 that executes batch D. Also good.
なお、本実施形態では、各バッチが、各処理実行装置10−nの記憶部106−nに記憶されている例を説明したが、これに限られない。例えば、1台の処理実行装置10−1の記憶部106−1にバッチA〜バッチDが記憶されていてもよい。この場合、処理部103−1は、まずバッチAを起動するようにしてもよい。そして、判定部104−1はバッチA終了後に、バッチBとバッチCを起動するようにしてもよい。処理部103−1は、バッチBとバッチCとを並列処理するようにしてもよい。そして、判定部104−1は、バッチBとバッチCとが終了したと判定した後、バッチDを起動するようにしてもよい。 In the present embodiment, the example in which each batch is stored in the storage unit 106-n of each processing execution device 10-n has been described, but the present invention is not limited thereto. For example, batch A to batch D may be stored in the storage unit 106-1 of one processing execution apparatus 10-1. In this case, the processing unit 103-1 may first activate the batch A. And the determination part 104-1 may be made to start the batch B and the batch C after completion of the batch A. The processing unit 103-1 may process batch B and batch C in parallel. Then, the determination unit 104-1 may start the batch D after determining that the batch B and the batch C are completed.
また、バッチが異常終了した場合、処理部103−nは、実行していたバッチを再実行(リラン;Rerun)するようにしてもよい。例えば、バッチの実行途中の所定の位置にコミットポイントを設けるようにしてもよい。ここで、コミットポイントとは、バッチをいくつかに小分けた場合、小分けたバッチが終了したポイントを示す情報である。処理部103−nは、バッチ実行中、実行が終了したコミットポイントを記憶部106−nに記憶させるようにしてもよい。そして、バッチが異常終了した場合、処理部103−nは、記憶部106−nに記憶されているコミットポイントに応じて、異常終了した前の処理からバッチを継続するようにしてもよい。このように、バッチが異常終了した場合であっても、バッチを先頭からすべて再実行しなくてすむため、バッチの実行にかかる時間を軽減することができる。 When the batch is abnormally terminated, the processing unit 103-n may re-execute (Rerun) the batch that has been executed. For example, a commit point may be provided at a predetermined position during the execution of the batch. Here, the commit point is information indicating a point at which the subdivided batch ends when the batch is subdivided into several. The processing unit 103-n may store the commit point that has been executed in the storage unit 106-n during the batch execution. When the batch ends abnormally, the processing unit 103-n may continue the batch from the process before the abnormal end according to the commit point stored in the storage unit 106-n. As described above, even when the batch is abnormally terminated, it is not necessary to re-execute all the batches from the beginning, so that the time required for executing the batch can be reduced.
[第2の実施形態]
第1実施形態では、複数のバッチが並列処理されて、終了するタイミングが異なる例を説明した。本実施形態では、複数のバッチが並列処理されて、終了するタイミングが同じ場合の例を説明する。
[Second Embodiment]
In the first embodiment, an example has been described in which a plurality of batches are processed in parallel and the timings at which the batches end are different. In the present embodiment, an example will be described in which a plurality of batches are processed in parallel and the end timing is the same.
図6は、本実施形態に係る処理実行装置および処理実行システム1Aの概略構成例を説明する図である。
図6に示すように、処理実行システム1Aは、n(nは2以上の整数)台の処理実行装置10−n、および記憶装置20Aを備えている。第1実施形態における処理実行システム1と同じ機能を有する機能部は、同じ符号を用いて説明を省略する。第1実施形態の処理実行システム1とことなる機能部は、記憶装置20Aである。
FIG. 6 is a diagram illustrating a schematic configuration example of the process execution device and the process execution system 1A according to the present embodiment.
As illustrated in FIG. 6, the processing execution system 1A includes n (n is an integer of 2 or more) processing execution devices 10-n and a storage device 20A. The functional units having the same functions as those of the
記憶装置20Aは、記憶部201Aおよび調停部202を備えている。
調停部202は、複数の実行完了情報書込部105−nからアクセスがあった場合、実行完了情報の書き込み順番を調停する。例えば、調停部202は、複数の実行完了情報書込部105−nからアクセスがあった場合、予め定められている書き込み順位に従って、実行完了情報の書き込みを受け付ける。ここで、予め定められている書き込み順位とは、並列処理される複数のバッチに対して予め定めてある順位である。予め定められている書き込み順位は、例えば、処理実行装置10−nに識別情報が割り振られている場合、並列処理されている処理実行装置10−nのうち、識別番号が小さい方を優先する順番であってもよい。
The storage device 20A includes a
When there is an access from a plurality of execution completion information writing units 105-n, the arbitrating
例えば、図4に示したように、バッチBとバッチCが並列処理される場合、予め定められている書き込み順位として、バッチBがバッチCに優先するようにしてもよい。そしてバッチBとバッチCとが同時に終了した場合、調停部202は、実行完了情報書込部105−2からの書き込みを優先して受け付け、バッチ名Bに対応する実行完了情報を記憶部201Aに記憶させる。また、調停部202は、同時にアクセスしてきた実行完了情報書込部105−3に対して、所定の時間後に再アクセスする指示を送信するようにしてもよい。
For example, as shown in FIG. 4, when batch B and batch C are processed in parallel, batch B may have priority over batch C as a predetermined writing order. When batch B and batch C are completed at the same time, the arbitrating
図7は、本実施形態に係る処理実行装置10−n、記憶装置20A間の処理のシーケンスの一例である。図7に示した例では、図1に示したように処理実行装置10−1〜10−4、記憶装置20Aが通信ネットワーク30を介して接続されている。また、処理実行装置10−nの各記憶部106−nには、図2に示した設定情報が記憶されている。
FIG. 7 is an example of a processing sequence between the processing execution device 10-n and the storage device 20A according to the present embodiment. In the example illustrated in FIG. 7, the processing execution devices 10-1 to 10-4 and the
ステップS1〜S10は、第1実施形態と同様に処理を行う。
(ステップS101)判定部104−2は、処理部103−2が出力したバッチ終了情報に応じてバッチBが終了したと判定する。処理部103−2は、ステップS101終了後、処理をステップS102に進める。
(ステップS102)判定部104−2は、バッチBが終了したと判定した場合、記憶装置20Aの記憶部201Aに実行完了情報を書き込む指示を実行完了情報書込部105−2に対して出力する。次に、実行完了情報書込部105−2は、判定部104−2から入力された実行完了情報を書き込む指示に応じて、記憶装置20Aにアクセスする。
Steps S1 to S10 are performed in the same manner as in the first embodiment.
(Step S101) The determination unit 104-2 determines that the batch B has ended according to the batch end information output by the processing unit 103-2. The process part 103-2 advances a process to step S102 after completion | finish of step S101.
(Step S102) When the determination unit 104-2 determines that the batch B has ended, the determination unit 104-2 outputs an instruction to write execution completion information to the
(ステップS103)判定部104−3は、処理部103−3が出力したバッチ終了情報に応じてバッチCが終了したと判定する。処理部103−3は、ステップS103終了後、処理をステップS104に進める。
(ステップS104)判定部104−3は、バッチCが終了したと判定した場合、記憶部201Aに実行完了情報を書き込む指示を実行完了情報書込部105−3に対して出力する。次に、実行完了情報書込部105−3は、判定部104−3から入力された実行完了情報を書き込む指示に応じて、記憶装置20Aにアクセスする。
(Step S103) The determination unit 104-3 determines that the batch C has ended according to the batch end information output by the processing unit 103-3. The processing unit 103-3 advances the process to step S104 after step S103 ends.
(Step S104) When determining that the batch C has ended, the determining unit 104-3 outputs an instruction to write execution completion information to the
(ステップS105)記憶装置20Aの調停部202は、実行完了情報書込部105−2と実行完了情報書込部105−3から同時にアクセスがあった場合、予め定められている書き込み順位に従って、アクセスを受け付ける。図7に示した例では、調停部202は、実行完了情報書込部105−2のアクセスを優先的に受け付ける。
(ステップS106)調停部202は、同時にアクセスしてきた実行完了情報書込部105−3に対して、所定の時間後に再アクセスする指示を送信する。
(Step S105) When the
(Step S106) The
(ステップS107)調停部202は、実行完了情報書込部105−2からのアクセスに応じて、バッチ名Bと実行完了情報とを関連づけて記憶部201Aに記憶させる。
(ステップS108)判定部104−2は、記憶部106−2に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−2は、バッチ名BとBに各々関連づけられた実行完了情報が記憶部201Aに記憶されているか否かを確認する。図7に示した例では、監視対象のバッチ名Bに関連づけられた実行完了情報が記憶部201Aに記憶されているが、監視対象のバッチ名Cに関連づけられた実行完了情報が記憶されていない。このため判定部104−2は、自装置および並列して処理されている他装置におけるすべてのバッチが終了していないと判定する。
(Step S107) In response to the access from the execution completion information writing unit 105-2, the arbitrating
(Step S108) The determination unit 104-2 reads the batch names B and C to be monitored from the setting information stored in the storage unit 106-2. Next, the determination unit 104-2 confirms whether or not the execution completion information associated with each of the batch names B and B is stored in the
(ステップS109)実行完了情報書込部105−3は、所定時間が経過後、実行完了情報を書き込むため記憶装置20Aに再アクセスし、バッチ名Cと実行完了情報とを関連づけて記憶部201Aに書き込む。判定部104−3は、ステップS109終了後、処理をステップS110に進める。
(ステップS110)判定部104−3は、記憶部106−3に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−3は、バッチ名BとBに各々関連づけられた実行完了情報が記憶部201Aに記憶されているか否かを確認する。図7に示した例では、監視対象のバッチ名Bに関連づけられた実行完了情報が記憶部201Aに記憶され、監視対象のバッチ名Cに関連づけられた実行完了情報が記憶されている。このため判定部104−3は、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定する。処理部103−3は、ステップS110終了後、処理をステップS111に進める。
(Step S109) After a predetermined time has elapsed, the execution completion information writing unit 105-3 re-accesses the storage device 20A to write the execution completion information, and associates the batch name C with the execution completion information to the
(Step S110) The determination unit 104-3 reads the batch names B and C to be monitored from the setting information stored in the storage unit 106-3. Next, the determination unit 104-3 checks whether or not the execution completion information associated with each of the batch names B and B is stored in the
(ステップS111)判定部104−3は、記憶部106−3に記憶されている設定情報に応じて、バッチDに対する起動指示を処理実行装置10−4に送信する。
(ステップS112)処理実行装置10−4の処理部103−4は、処理実行装置10−3から入力されたバッチDを起動する起動情報に応じて、記憶部106−4に記憶されている設定情報に基づいてバッチDを読み出す。次に、処理部103−4は、読み出したバッチDを起動する。
(Step S111) The determination unit 104-3 transmits an activation instruction for the batch D to the process execution device 10-4 according to the setting information stored in the storage unit 106-3.
(Step S <b> 112) The processing unit 103-4 of the process execution device 10-4 stores the setting stored in the storage unit 106-4 according to the activation information for starting the batch D input from the process execution device 10-3. The batch D is read based on the information. Next, the processing unit 103-4 activates the read batch D.
なお、本実施形態では、記憶装置20Aが調停部202を備える例を説明したが、これに限られない。調停部は、各処理実行装置10−nが備えていてもよい。例えば、記憶装置20Aに、実行完了情報書込部105−nが同時にアクセスしてきて実行完了情報を書き込めない場合、予め定められている順位で書き込むようにしてもよい。例えば、図7に示したように、実行完了情報書込部105−2と実行完了情報書込部105−3とが記憶装置20Aに同時アクセスした場合、処理実行装置10−2の調停部は、実行完了情報書込部105−2が優先的に実行完了情報を記憶装置20Aに書き込むように調停するようにしてもよい。そして、処理実行装置10−3の調停部は、実行完了情報書込部105−3に対して、所定の時間経過後に記憶装置20Aに再アクセスして、実行完了情報を書き込むように調停するようにしてもよい。
また、調停部202は、例えば、通信ネットワーク30と記憶装置20Aとの間に設けられていてもよい。
In the present embodiment, the example in which the storage device 20A includes the
Further, the arbitrating
また、本実施形態では、調停部202を備えて調停するする例を説明したが、これに限られない。他の実施例を説明する。
例えば、図7において、バッチAが終了した後、判定部104−1は、記憶部106−1に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2に送信し、バッチCに対する起動指示を処理実行装置10−3に送信する。さらに、判定部104−1は、処理実行装置10−2と処理実行装置10−3に対して、トークンを発行するようにしてもよい。この場合、トークンは、処理実行装置10−2と処理実行装置10−3との間を、通信ネットワーク30を介して周回する。処理実行装置10−2と処理実行装置10−3とが、同時にバッチの実行を終えた場合、トークンを有している処理実行装置10−nの実行完了情報書込部105−nのみが、記憶装置20Aにアクセスして実行完了情報を記憶装置20Aに書き込むようにしてもよい。処理実行装置10−2は、実行完了情報の書き込み後、トークンを処理実行装置10−3に送信する。そして、トークンを受信した処理実行装置10−3の実行完了情報書込部105−3は、記憶装置20Aに実行完了情報を書き込むようにしてもよい。
Moreover, although this embodiment demonstrated the example which comprises the
For example, in FIG. 7, after the batch A is completed, the determination unit 104-1 transmits an activation instruction for the batch B to the process execution device 10-2 according to the setting information stored in the storage unit 106-1. Then, an activation instruction for batch C is transmitted to the process execution apparatus 10-3. Furthermore, the determination unit 104-1 may issue a token to the process execution device 10-2 and the process execution device 10-3. In this case, the token circulates between the processing execution device 10-2 and the processing execution device 10-3 via the
また、本実施形態では、記憶部201Aを記憶装置20Aが備える例を説明したが、これに限られない。記憶部201Aは、各処理実行装置10−nの記憶部106−nであってもよい。
In the present embodiment, the example in which the storage device 20A includes the
以上のように、本実施形態の処理実行装置10−nは、実行完了情報書込部105−nは、前段処理の実行が完了したとき予め定められる書込み順序に基づいて実行完了情報を記憶部(201または106−n)に書き込む。
これにより、複数のバッチが並列に処理されて同時に終了した場合であっても、記憶部(201または106−n)に実行完了情報を書き込む順番を調停できる。判定部104−nは、互いに記憶部(201または10−6−n)に記憶されている実行完了情報を確認することができる。この結果、バッチ管理装置が不要になり情報システムのコストを削減できる。
As described above, in the process execution device 10-n according to the present embodiment, the execution completion information writing unit 105-n stores the execution completion information based on the predetermined write order when the execution of the preceding process is completed. Write to (201 or 106-n).
Thereby, even if it is a case where a several batch is processed in parallel and complete | finished simultaneously, the order which writes execution completion information in a memory | storage part (201 or 106-n) can be arbitrated. The determination unit 104-n can mutually confirm the execution completion information stored in the storage unit (201 or 10-6-n). As a result, the batch management device is not required, and the cost of the information system can be reduced.
[第3の実施形態]
第1および第2実施形態では、バッチA〜バッチDが1回ずつ起動される例を説明した。本実施形態では、バッチA〜バッチDが所定の時刻毎に起動される例を説明する。
[Third Embodiment]
In the first and second embodiments, the example in which batch A to batch D are activated once has been described. In the present embodiment, an example in which batch A to batch D are activated at every predetermined time will be described.
図8は、本実施形態に係るバッチの連携の概要を説明する図である。図8(a)は、第1の時刻にバッチAが起動された例であり、図8(b)は、第2の時刻にバッチAが起動された例である。
図8に示した例では、バッチA〜バッチBが所定の時間間隔で定期的に行われる。図8に示した例は、すべてのバッチが異常終了せずに終了した場合の図である。
FIG. 8 is a diagram for explaining the outline of batch cooperation according to the present embodiment. FIG. 8A is an example in which batch A is activated at the first time, and FIG. 8B is an example in which batch A is activated at the second time.
In the example shown in FIG. 8, batch A to batch B are periodically performed at predetermined time intervals. The example shown in FIG. 8 is a diagram in a case where all batches are ended without being ended abnormally.
例えば、図8(a)において、バッチCが異常終了した場合を説明する。この場合、バッチCを実行制御している処理部103−n(図6参照)は、バッチCをリランする。そして、バッチCを実行制御している判定部104−n(図6参照)は、並列処理されているバッチBが終了したか否かを記憶部201A(図6参照)に記憶されている実行完了情報に基づいて確認する。しかしながら、バッチA〜バッチCが定期的に実行されているため、実行完了情報がどの時刻に実行されたバッチによるものか、判定部104−nは判定できない。このため、例えば図8(b)のバッチA〜バッチDの実行において、第1の時刻に起動されたバッチBが終了したことを受けて、判定部104−nがバッチC終了後に、並列処理されているすべてのバッチが終了したと誤判定してしまうこともあり得る。
このため、本実施形態では、起動回数をカウントするカウンタを設けることで、このような誤判定を防ぐ。
For example, a case where batch C ends abnormally in FIG. In this case, the processing unit 103-n (see FIG. 6) that controls execution of the batch C reruns the batch C. Then, the determination unit 104-n (see FIG. 6) that controls execution of the batch C determines whether or not the batch B that is being processed in parallel has ended, and is stored in the
For this reason, in this embodiment, such erroneous determination is prevented by providing a counter that counts the number of activations.
図9は、本実施形態に係る処理実行装置および処理実行システム1Bの概略構成例を説明する図である。
図9に示すように、処理実行システム1Bは、n(nは2以上の整数)台の処理実行装置10−nB、および記憶装置20Bを備えている。処理実行装置10−nBは、各々、通信ネットワーク30を介して接続されている。処理実行装置10−nBは、操作部101−n、通信部102−n、処理部103−n、判定部104−nB、実行完了情報書込部105−nB、記憶部106−nおよび起動カウンタ107−nを備えている。第1および第2実施形態にける処理実行装置10−nとの差異は、判定部104−nB、実行完了情報書込部105−nBおよび起動カウンタ107−nである。
FIG. 9 is a diagram illustrating a schematic configuration example of the process execution device and the
As shown in FIG. 9, the
起動カウンタ107−nは、処理部103−nにより所定の時間毎に初期化される。ここで、初期化とは、例えば0である。所定の時間は、例えば、24時間である。起動カウンタ107−nは、バッチの起動回数を計数する。具体的には、起動カウンタ107−nは、バッチの起動毎に起動回数を1ずつ加算する。この場合、起動カウンタ107−nは、バッチ(すなわち前段処理)の起動時(開始時)に起動回数を1ずつ加算する。なお、起動カウンタ107−nは、バッチの起動毎に起動回数を1ずつ減算してもよい。 The activation counter 107-n is initialized every predetermined time by the processing unit 103-n. Here, the initialization is 0, for example. The predetermined time is, for example, 24 hours. The activation counter 107-n counts the number of batch activations. Specifically, the activation counter 107-n increments the activation count by one for each activation of the batch. In this case, the activation counter 107-n increments the activation count by one when the batch (that is, the preceding process) is activated (at the start). The activation counter 107-n may decrement the activation count by 1 for each activation of the batch.
実行完了情報書込部105−nBは、判定部104−nBから入力された実行完了情報を書き込む指示に応じて、終了したバッチ名と実行完了情報と起動カウンタ107−nの起動回数とを関連づけて記憶装置20Bの記憶部201Bに書き込む。
The execution completion information writing unit 105-nB associates the completed batch name, the execution completion information, and the activation count of the activation counter 107-n in response to the instruction to write the execution completion information input from the determination unit 104-nB. To the
判定部104−nBは、記憶部106―nに記憶されている設定情報に記憶されている並列して処理されている装置におけるすべてのバッチが終了したか否かを、記憶部201Bに記憶されているバッチ名と実行完了情報と起動回数に基づいて判定する。
The determination unit 104-nB stores in the
記憶装置20Bは、記憶部201Bを備える。記憶部201Bには、図10に示すように、起動カウンタ値とバッチ名と実行完了情報とが関連づけられて記憶されている。
The
図10は、本実施形態に係る記憶装置20Bに記憶されている情報の例を説明する図である。図10に示すように、記憶装置20Bの記憶部201Bには、起動回数とバッチ名と実行完了情報とが関連づけられて記憶されている。例えば、記憶部201Bには、起動回数(=1)とバッチ名Aと実行完了情報とが関連づけられて記憶されている。
FIG. 10 is a diagram illustrating an example of information stored in the
図11は、本実施形態に係る複数のバッチの連携の構成の一例を説明する図である。
図11(a)は、第1の時刻に第1のネット構成に含まれるバッチAが起動された例である。ここで、ネット構成とは、図8(a)に示したように、バッチA〜バッチDを含むバッチ群の起動順番およびバッチ間の連携を含む構成である。また、第1のネット構成とは、第1の時刻において起動されるバッチA、およびこれに連携して起動されるバッチB〜バッチDを含むバッチ群の起動順番およびバッチ間の連携の構成である。図11(b)は、第1の時刻とは異なる第2の時刻において、第2のネット構成に含まれるバッチAが起動された例である。ここで、第2のネット構成とは、第1のネット構成に含まれるバッチAの起動時刻とは異なる時刻において起動されるバッチA、およびこれに連携して起動されるバッチB〜バッチDを含むバッチ群である。
FIG. 11 is a diagram for explaining an example of a configuration of cooperation of a plurality of batches according to the present embodiment.
FIG. 11A shows an example in which the batch A included in the first net configuration is activated at the first time. Here, the net configuration is a configuration including the activation order of batch groups including batch A to batch D and cooperation between batches, as shown in FIG. In addition, the first net configuration is a configuration in which batch A is started at the first time, and a batch group including batch B to batch D that are started in conjunction with this, and the linkage between batches. is there. FIG. 11B is an example in which the batch A included in the second net configuration is activated at a second time different from the first time. Here, the second net configuration refers to batch A started at a time different from the start time of batch A included in the first net configuration, and batch B to batch D started in conjunction with this. It is a batch group including.
まず、第1のネット構成に含まれる各バッチに対する処理について説明する。図11(a)に示すように、処理部103−1は起動カウンタ107−1の起動回数に1を加算する。次に、処理部103−1は、記憶部106−1に記憶されている設定情報に基づいて記憶部106−1から読み出したバッチAを起動する。バッチA終了後、実行完了情報書込部105−1Bは、判定部104−1Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Aと実行完了情報と起動回数(=1)を記憶部201Bに書き込む。次に、判定部104−1Bは、記憶部106−1に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2Bに送信し、バッチCに対する起動指示を処理実行装置10−3Bに送信する。この起動指示には、起動カウンタ107−1の値、すなわちバッチAの起動回数を示す情報が含まれている。
First, processing for each batch included in the first net configuration will be described. As illustrated in FIG. 11A, the processing unit 103-1 adds 1 to the number of activations of the activation counter 107-1. Next, the processing unit 103-1 activates the batch A read from the storage unit 106-1 based on the setting information stored in the storage unit 106-1. After completion of the batch A, the execution completion information writing unit 105-1B sets the batch name A, the execution completion information, and the number of activations (= 1) in response to the instruction to write the execution completion information input from the determination unit 104-1B. Write to the
次に、処理部103−2は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−2から読み出したバッチBを起動する。次に、処理部103−2は起動カウンタ107−2の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、1)を設定する。
次に、処理部103−3は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−3から読み出したバッチCを起動する。次に、処理部103−3は起動カウンタ107−3の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、1)を設定する。
バッチB終了後、実行完了情報書込部105−2Bは、判定部104−2Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Bと実行完了情報と起動回数(=1)とを関連づけて記憶部201Bに書き込む。
Next, the processing unit 103-2 activates the batch B read from the storage unit 106-2 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-2 sets the number of activations of the batch A included in the activation instruction (in this example, 1) as the activation number of the activation counter 107-2.
Next, the processing unit 103-3 activates the batch C read from the storage unit 106-3 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-3 sets the number of activations of the batch A included in the activation instruction (in this example, 1) as the activation number of the activation counter 107-3.
After completion of the batch B, the execution completion information writing unit 105-2B receives the batch name B, the execution completion information, the number of activations (= 1), in response to the instruction to write the execution completion information input from the determination unit 104-2B. Are associated and written to the
この図11(a)は、バッチCが正常に終了した場合の例である。この場合、記憶部201Bには、起動回数(=1)とバッチ名Cに関連づけられた実行完了情報が記憶される。
FIG. 11A shows an example when the batch C is normally completed. In this case, the
判定部104−3Bは、記憶部106−3に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−3Bは、起動回数(=1)であり、バッチ名BとCに各々関連づけられた実行完了情報が記憶部201Bに記憶されているか否かを確認する。この場合、記憶部201Bには、起動回数(=1)に関連づけられてバッチ名Bに対応する実行完了情報が記憶され、起動回数(=1)に関連づけられてバッチ名Cに対応する実行完了情報が記憶されている。このため判定部104−3Bは、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定する。
The determination unit 104-3B reads the monitoring target batch names B and C from the setting information stored in the storage unit 106-3. Next, the determination unit 104-3B is the number of activations (= 1), and confirms whether or not the execution completion information associated with each of the batch names B and C is stored in the
次に、判定部104−3Bは、記憶部106−3に記憶されている設定情報に応じて、バッチDに対する起動指示を処理実行装置10−4Bに送信する。この起動指示には、起動カウンタ107−3の値、すなわちバッチCの起動回数を示す情報が含まれている。
次に、処理部103−4は、処理実行装置10−3Bから入力された起動指示に応じて、記憶部106−4から読み出したバッチDを起動する。次に、処理部103−4は起動カウンタ107−4の起動回数に、起動指示に含まれるバッチCの起動回数(この例においては、1)を設定する。
Next, the determination unit 104-3B transmits an activation instruction for the batch D to the process execution device 10-4B according to the setting information stored in the storage unit 106-3. This activation instruction includes information indicating the value of the activation counter 107-3, that is, the number of activations of the batch C.
Next, the processing unit 103-4 activates the batch D read from the storage unit 106-4 in response to the activation instruction input from the process execution device 10-3B. Next, the processing unit 103-4 sets the number of activations of the batch C included in the activation instruction (in this example, 1) as the activation number of the activation counter 107-4.
次に、第2のネット構成に含まれる各バッチに対する処理について説明する。
図11(b)において、処理部103−1は起動カウンタ107−1の起動回数に1を加算する。次に、処理部103−1は、記憶部106−1に記憶されている設定情報に基づいて記憶部106−1から読み出したバッチAを起動する。バッチA終了後、実行完了情報書込部105−1Bは、判定部104−1Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Aと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。次に、判定部104−1Bは、記憶部106−2に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2Bに送信し、バッチCに対する起動指示を処理実行装置10−3Bに送信する。この起動指示には、起動カウンタ107−1の値、バッチAの起動回数を示す情報が含まれている。
Next, processing for each batch included in the second net configuration will be described.
In FIG. 11B, the processing unit 103-1 adds 1 to the number of activations of the activation counter 107-1. Next, the processing unit 103-1 activates the batch A read from the storage unit 106-1 based on the setting information stored in the storage unit 106-1. After completion of the batch A, the execution completion information writing unit 105-1B determines the batch name A, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-1B. The data are written in the
次に、処理部103−2は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−2から読み出したバッチBを起動する。次に、処理部103−2は起動カウンタ107−2の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、2)を設定する。
次に、処理部103−3は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−3から読み出したバッチCを起動する。次に、処理部103−3は起動カウンタ107−3の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、2)を設定する。
バッチB終了後、実行完了情報書込部105−2Bは、判定部104−2Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Bと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。
Next, the processing unit 103-2 activates the batch B read from the storage unit 106-2 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-2 sets the number of activations of the batch A included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-2.
Next, the processing unit 103-3 activates the batch C read from the storage unit 106-3 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-3 sets the number of activations of batch A included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-3.
After completion of the batch B, the execution completion information writing unit 105-2B determines the batch name B, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-2B. The data are written in the
バッチC終了後、実行完了情報書込部105−3Bは、判定部104−3Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Cと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。
判定部104−3Bは、記憶部106−3に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−3Bは、起動回数(=2)であり、バッチ名BとCに各々関連づけられた実行完了情報が記憶部201Bに記憶されているか否かを確認する。この場合、記憶部201Bには、起動回数(=2)に関連づけられてバッチ名Bに対応する実行完了情報が記憶され、起動回数(=2)に関連づけられてバッチ名Cに対応する実行完了情報が記憶されている。このため判定部104−3Bは、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定する。
After completion of the batch C, the execution completion information writing unit 105-3B determines the batch name C, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-3B. The data are written in the
The determination unit 104-3B reads the monitoring target batch names B and C from the setting information stored in the storage unit 106-3. Next, the determination unit 104-3B is the number of activations (= 2), and confirms whether execution completion information associated with each of the batch names B and C is stored in the
次に、判定部104−3Bは、記憶部106−3に記憶されている設定情報に応じて、バッチDに対する起動指示を処理実行装置10−4Bに送信する。この起動指示には、起動カウンタ107−3の値、すなわちバッチCの起動回数を示す情報が含まれている。
次に、処理部103−4は、処理実行装置10−3Bから入力された起動指示に応じて、記憶部106−4から読み出したバッチDを起動する。次に、処理部103−4は起動カウンタ107−4の起動回数に、起動指示に含まれるバッチCの起動回数(この例においては、2)を設定する。
Next, the determination unit 104-3B transmits an activation instruction for the batch D to the process execution device 10-4B according to the setting information stored in the storage unit 106-3. This activation instruction includes information indicating the value of the activation counter 107-3, that is, the number of activations of the batch C.
Next, the processing unit 103-4 activates the batch D read from the storage unit 106-4 in response to the activation instruction input from the process execution device 10-3B. Next, the processing unit 103-4 sets the number of activations of batch C included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-4.
上述したように、本実施形態によれば、処理実行装置10−nBが、各々、起動カウンタ107−nを備え、バッチの起動毎に起動回数を更新(例えば、加算)する。本実施形態に係る処理実行装置10−nBは、このバッチの起動回数によって各々のネット構成を区別しながら、バッチを起動することができる。すなわち、処理実行装置10−nBは、起動カウンタ107−nを備えることにより、ネット構成が互いに異なる同じ種類のバッチ(例えば、バッチA)が起動された場合に、これらのバッチを区別して処理することができる。よって、処理実行装置10−nBは、複数のネット構成を同時に処理することができる。ここで、従来の処理実行装置のように、起動カウンタ107−nを備えない場合において、複数のネット構成を同時に処理するために、予め複数のネット構成を設定しておく場合がある。処理実行装置10−nBは、予め複数のネット構成を設定することなく複数のネット構成を同時に処理することができるため、このような予め複数のネット構成を設定しておく場合に比べて、ネット構成の設定を簡素化することができる。 As described above, according to the present embodiment, each of the process execution devices 10-nB includes the activation counter 107-n, and updates (for example, adds) the number of activations every time the batch is activated. The process execution device 10-nB according to the present embodiment can start a batch while distinguishing each net configuration depending on the number of times the batch is started. That is, the process execution device 10-nB includes the activation counter 107-n, so that when batches of the same type (for example, batch A) having different net configurations are activated, these batches are distinguished and processed. be able to. Therefore, the process execution device 10-nB can process a plurality of net configurations simultaneously. Here, in the case where the activation counter 107-n is not provided as in the conventional processing execution apparatus, a plurality of net configurations may be set in advance in order to simultaneously process a plurality of net configurations. The processing execution apparatus 10-nB can process a plurality of net configurations at the same time without setting a plurality of net configurations in advance. Configuration settings can be simplified.
なお、起動指示には前段処理の起動回数を示す情報が含まれているとして説明したが、これに限られない。例えば、前段処理の起動指示によって後段処理が起動される際に、後段処理の処理部103−nが、記憶部201Bから前段処理の起動回数を示す情報を取得する構成であってもよい。
Although it has been described that the activation instruction includes information indicating the number of activations of the pre-stage process, the present invention is not limited to this. For example, the configuration may be such that, when the subsequent process is activated by the activation instruction for the preceding process, the processing unit 103-n for the subsequent process acquires information indicating the number of activations of the preceding process from the
次に、図12を参照して、バッチが異常終了した場合について説明する。
図12は、本実施形態に係るバッチ異常終了時の構成の一例を説明する図である。このうち、図12(a)は、第1の時刻に第1のネット構成に含まれるバッチAが起動された例である。図12(b)は、第2の時刻に第2のネット構成に含まれるバッチAが起動された例である。ここでは、第1のネット構成に含まれるバッチCが異常終了し、第1のネット構成に含まれるバッチDが起動できない場合について説明する。
Next, with reference to FIG. 12, the case where the batch is abnormally terminated will be described.
FIG. 12 is a diagram for explaining an example of the configuration at the time of abnormal termination of the batch according to the present embodiment. Among these, FIG. 12A shows an example in which the batch A included in the first net configuration is started at the first time. FIG. 12B is an example in which the batch A included in the second net configuration is activated at the second time. Here, a case will be described in which batch C included in the first net configuration ends abnormally and batch D included in the first net configuration cannot be started.
まず、第1のネット構成に含まれる各バッチに対する処理について説明する。図12(a)に示すように、処理部103−1は起動カウンタ107−1の起動回数に1を加算する。次に、処理部103−1は、記憶部106−1に記憶されている設定情報に基づいて記憶部106−1から読み出したバッチAを起動する。バッチA終了後、実行完了情報書込部105−1Bは、判定部104−1Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Aと実行完了情報と起動回数(=1)を記憶部201Bに書き込む。次に、判定部104−1Bは、記憶部106−1に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2Bに送信し、バッチCに対する起動指示を処理実行装置10−3Bに送信する。この起動指示には、起動カウンタ107−1の値、すなわちバッチAの起動回数を示す情報が含まれている。
First, processing for each batch included in the first net configuration will be described. As shown in FIG. 12A, the processing unit 103-1 adds 1 to the number of activations of the activation counter 107-1. Next, the processing unit 103-1 activates the batch A read from the storage unit 106-1 based on the setting information stored in the storage unit 106-1. After completion of the batch A, the execution completion information writing unit 105-1B sets the batch name A, the execution completion information, and the number of activations (= 1) in response to the instruction to write the execution completion information input from the determination unit 104-1B. Write to the
次に、処理部103−2は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−2から読み出したバッチBを起動する。次に、処理部103−2は起動カウンタ107−2の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、1)を設定する。
次に、処理部103−3は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−3から読み出したバッチCを起動する。次に、処理部103−3は起動カウンタ107−3の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、1)を設定する。
バッチB終了後、実行完了情報書込部105−2Bは、判定部104−2Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Bと実行完了情報と起動回数(=1)とを関連づけて記憶部201Bに書き込む。
Next, the processing unit 103-2 activates the batch B read from the storage unit 106-2 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-2 sets the number of activations of the batch A included in the activation instruction (in this example, 1) as the activation number of the activation counter 107-2.
Next, the processing unit 103-3 activates the batch C read from the storage unit 106-3 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-3 sets the number of activations of the batch A included in the activation instruction (in this example, 1) as the activation number of the activation counter 107-3.
After completion of the batch B, the execution completion information writing unit 105-2B receives the batch name B, the execution completion information, the number of activations (= 1), in response to the instruction to write the execution completion information input from the determination unit 104-2B. Are associated and written to the
この図12(a)は、バッチCが異常終了し、リランできなかった場合の例を示している。上述した図11(a)の場合と異なり、バッチCが異常終了した場合には、記憶部201Bには、起動回数(=1)とバッチ名Cに関連づけられた実行完了情報は記憶されない。また、起動カウンタ107−4の起動回数は、初期値0のままである。
FIG. 12A shows an example of a case where batch C has ended abnormally and could not be rerun. Unlike the case of FIG. 11A described above, when the batch C is abnormally terminated, the
次に、第2のネット構成に含まれる各バッチに対する処理について説明する。
図12(b)において、処理部103−1は起動カウンタ107−1の起動回数に1を加算する。ここで、第2のネット構成に含まれるバッチA起動前においては、起動カウンタ107−1の起動回数は1であるため、起動カウンタ107−1の起動回数は2になる。次に、処理部103−1は、記憶部106−1に記憶されている設定情報に基づいて記憶部106−1から読み出したバッチAを起動する。バッチA終了後、実行完了情報書込部105−1Bは、判定部104−1Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Aと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。次に、判定部104−1Bは、記憶部106−2に記憶されている設定情報に応じて、バッチBに対する起動指示を処理実行装置10−2Bに送信し、バッチCに対する起動指示を処理実行装置10−3Bに送信する。
Next, processing for each batch included in the second net configuration will be described.
In FIG. 12B, the processing unit 103-1 adds 1 to the number of activations of the activation counter 107-1. Here, before the activation of batch A included in the second net configuration, the activation counter 107-1 is activated 1, and the activation counter 107-1 is activated 2. Next, the processing unit 103-1 activates the batch A read from the storage unit 106-1 based on the setting information stored in the storage unit 106-1. After completion of the batch A, the execution completion information writing unit 105-1B determines the batch name A, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-1B. The data are written in the
次に、処理部103−2は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−2から読み出したバッチBを起動する。次に、処理部103−2は起動カウンタ107−2の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、2)を設定する。
次に、処理部103−3は、処理実行装置10−1Bから入力された起動指示に応じて、記憶部106−3から読み出したバッチCを起動する。次に、処理部103−3は起動カウンタ107−3の起動回数に、起動指示に含まれるバッチAの起動回数(この例においては、2)を設定する。
バッチB終了後、実行完了情報書込部105−2Bは、判定部104−2Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Bと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。
Next, the processing unit 103-2 activates the batch B read from the storage unit 106-2 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-2 sets the number of activations of the batch A included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-2.
Next, the processing unit 103-3 activates the batch C read from the storage unit 106-3 in response to the activation instruction input from the process execution device 10-1B. Next, the processing unit 103-3 sets the number of activations of batch A included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-3.
After completion of the batch B, the execution completion information writing unit 105-2B determines the batch name B, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-2B. The data are written in the
バッチC終了後、実行完了情報書込部105−3Bは、判定部104−3Bから入力された実行完了情報を書き込む指示に応じて、バッチ名Cと実行完了情報と起動回数(=2)を関連づけて記憶部201Bに書き込む。
判定部104−3Bは、記憶部106−3に記憶されている設定情報のうち、監視対象のバッチ名BとCを読み出す。次に、判定部104−3Bは、起動回数(=2)であり、バッチ名BとCに各々関連づけられた実行完了情報が記憶部201Bに記憶されているか否かを確認する。この場合、記憶部201Bには、起動回数(=2)に関連づけられてバッチ名Bに対応する実行完了情報が記憶され、起動回数(=2)に関連づけられてバッチ名Cに対応する実行完了情報が記憶されている。このため判定部104−3Bは、自装置および並列して処理されている他装置におけるすべてのバッチが終了したと判定する。
After completion of the batch C, the execution completion information writing unit 105-3B determines the batch name C, the execution completion information, and the number of activations (= 2) in response to the instruction to write the execution completion information input from the determination unit 104-3B. The data are written in the
The determination unit 104-3B reads the monitoring target batch names B and C from the setting information stored in the storage unit 106-3. Next, the determination unit 104-3B is the number of activations (= 2), and confirms whether execution completion information associated with each of the batch names B and C is stored in the
次に、判定部104−3Bは、記憶部106−3に記憶されている設定情報に応じて、バッチDに対する起動指示を処理実行装置10−4Bに送信する。
次に、処理部103−4は、処理実行装置10−3Bから入力された起動指示に応じて、記憶部106−4から読み出したバッチDを起動する。次に、処理部103−4は起動カウンタ107−4の起動回数に、起動指示に含まれるバッチCの起動回数(この例においては、2)を設定する。
Next, the determination unit 104-3B transmits an activation instruction for the batch D to the process execution device 10-4B according to the setting information stored in the storage unit 106-3.
Next, the processing unit 103-4 activates the batch D read from the storage unit 106-4 in response to the activation instruction input from the process execution device 10-3B. Next, the processing unit 103-4 sets the number of activations of batch C included in the activation instruction (in this example, 2) as the activation number of the activation counter 107-4.
上述したように、本実施形態によれば、処理実行装置10−nBが、各々、起動カウンタ107−nを備え、バッチの起動毎に起動回数を更新(例えば、加算)する。本実施形態に係る処理実行装置10−nBは、このようにバッチの起動回数と実行完了情報とをお互いに監視しあうことにより、バッチが異常終了したことを検出することができる。これにより、処理実行装置10−nBは、一部のネット構成に含まれるバッチが異常終了した場合であっても、他のネット構成に影響を与えることなく、起動回数に合わせてネット構成に含まれるバッチを起動することができる。 As described above, according to the present embodiment, each of the process execution devices 10-nB includes the activation counter 107-n, and updates (for example, adds) the number of activations every time the batch is activated. The process execution device 10-nB according to the present embodiment can detect that the batch has ended abnormally by monitoring the number of batch activations and the execution completion information in this way. As a result, the processing execution device 10-nB is included in the net configuration in accordance with the number of times of activation without affecting other net configurations even when batches included in some net configurations end abnormally. You can launch a batch.
なお、本実施形態では、起動カウンタ107−nを各処理実行装置10−nBが備える例を説明したが、これに限られない。起動カウンタは、例えば記憶装置20が備えていてもよく、あるいは、通信ネットワーク30に接続される起動カウンタ装置であってもよい。
In the present embodiment, the example in which each processing execution apparatus 10-nB includes the activation counter 107-n has been described, but the present invention is not limited to this. The activation counter may be provided in the
なお、第3実施形態において、例えば操作部101−nを管理者が操作して実行中のバッチを中断するようにしてもよい。このような場合であっても、本実施形態に係る処理実行装置10−nBは、起動回数に基づいて、次の時刻にスケジュールされているバッチのネット構成を維持して、バッチを実行することができる。 In the third embodiment, for example, an administrator may operate the operation unit 101-n to interrupt a running batch. Even in such a case, the process execution device 10-nB according to the present embodiment executes the batch while maintaining the net configuration of the batch scheduled at the next time based on the number of activations. Can do.
上述したように、第1〜第3実施形態によれば、バッチ監視装置が不要であるため、情報システムのコストを削減できる。
また、従来のバッチ監視装置を有する情報システムでは、バッチ監視装置によるバッチ間の連動は起動順番のみであったが、第1〜第3実施形態によれば、お互いにバッチ間の相互監視をしているため、密接な連動関係が可能になる。また、第1〜第3実施形態によれば、ネット構成の多重起動等の高機能なバッチ間の連動が可能になる。また第1〜第3実施形態によれば、随時系バッチ等の多彩なバッチに対応できる。
As described above, according to the first to third embodiments, since the batch monitoring device is unnecessary, the cost of the information system can be reduced.
In addition, in an information system having a conventional batch monitoring device, the batch monitoring device linked only to the starting order, but according to the first to third embodiments, mutual monitoring between batches is performed. Therefore, a close interlocking relationship becomes possible. In addition, according to the first to third embodiments, it is possible to link highly functional batches such as multiple activation of network configurations. In addition, according to the first to third embodiments, it is possible to deal with various batches such as a system batch at any time.
なお、第1〜第3実施形態では、2つの判定部104−n(含む104−B)が互いにバッチが終了したか否かを監視する例を説明したが、これに限られない。互いに監視するバッチは3つ以上であってもよい。
また、第1〜第3実施形態では、前段の処理実行装置10−n(含む10−nB)により起動されたバッチを実行している処理実行装置10−n同士についてバッチが終了したか否かを判定する例を説明したが、これに限られない。例えば、図13に示すように、監視し合うバッチは、起動指示を出力した処理実行装置10−n(含む10−nB)が異なっていてもよい。図13は、本実施形態に係るバッチの連動の一例を説明する図である。以下の例では、第1および第2実施形態で説明した処理実行装置10−nを例に説明するが、第3実施形態で説明した処理実行装置10−nBであってもよい。
In the first to third embodiments, the example in which the two determination units 104-n (including 104-B) monitor whether or not the batch has been completed has been described, but the present invention is not limited thereto. There may be three or more batches monitored each other.
In the first to third embodiments, whether or not the batches have been completed for the process execution devices 10-n executing the batches activated by the preceding process execution devices 10-n (including 10-nB). Although the example which determines this is demonstrated, it is not restricted to this. For example, as illustrated in FIG. 13, the batches to be monitored may be different from each other in the process execution device 10-n (including 10-nB) that has output the start instruction. FIG. 13 is a diagram illustrating an example of batch linking according to the present embodiment. In the following example, the processing execution device 10-n described in the first and second embodiments will be described as an example, but the processing execution device 10-nB described in the third embodiment may be used.
図13に示した例では、15台(n=15)の処理実行装置10−15が、通信ネットワーク30(図1参照)を介して接続されている。図13において、符号01_01、02_01〜02_04、03_01、04_01〜04_02、05_01、06_01、07_01〜07_02、08_01、09_01、10_01は、各々、バッチを示している。
処理実行装置10−1の各記憶部106−1には、バッチ01_01が記憶され、以下同様に、処理実行装置10−15の各記憶部106−15には、バッチ10_01が記憶されている。
In the example shown in FIG. 13, 15 (n = 15) processing execution devices 10-15 are connected via the communication network 30 (see FIG. 1). In FIG. 13, reference numerals 01_01, 02_01 to 02_04, 03_01, 04_01 to 04_02, 05_01, 06_01, 07_01 to 07_02, 08_01, 09_01, and 10_01 each indicate a batch.
The batch 01_01 is stored in each storage unit 106-1 of the process execution device 10-1, and similarly, the batch 10_01 is stored in each storage unit 106-15 of the process execution device 10-15.
バッチ01_01が終了後、判定部104−1は、処理実行装置10−2にバッチ02_1に対する起動指示を送信し、処理実行装置10_5にバッチ02_1〜02_04に対する起動指示を送信する。
バッチ02_01とバッチ02_02が終了後、監視するすべてのバッチが完了したと判定した判定部104−2または104−3は、処理実行装置10−6にバッチ03_1に対する起動指示を送信する。
バッチ03_01が終了後、判定部104−6は、処理実行装置10−7にバッチ04_01に対する起動指示を送信し、処理実行装置10−8にバッチ04_2に対する起動指示を送信する。
After the batch 01_01 ends, the determination unit 104-1 transmits an activation instruction for the batch 02_1 to the process execution device 10-2, and transmits an activation instruction for the batches 02_1 to 02_04 to the process execution device 10_5.
After the batch 02_01 and the batch 02_02 are finished, the determination unit 104-2 or 104-3 that determines that all the batches to be monitored are completed transmits an activation instruction for the batch 03_1 to the process execution device 10-6.
After the batch 03_01 ends, the determination unit 104-6 transmits an activation instruction for the batch 04_01 to the process execution device 10-7, and transmits an activation instruction for the batch 04_2 to the process execution device 10-8.
バッチ04_01とバッチ04_02が終了後、監視するすべてのバッチが完了したと判定した判定部104−7または104−8は、処理実行装置10−9にバッチ05_1に対する起動指示を送信する。
バッチ03_01とバッチ05_02が終了後、監視するすべてのバッチが完了したと判定した判定部104−4または104−9は、処理実行装置10−10にバッチ06_1に対する起動指示を送信する。
バッチ06_01が終了後、判定部104−10は、処理実行装置10−11にバッチ07_01に対する起動指示を送信し、処理実行装置10−12にバッチ07_2に対する起動指示を送信する。
After the batch 04_01 and the batch 04_02 are completed, the determination unit 104-7 or 104-8 that determines that all the batches to be monitored are completed transmits an activation instruction for the batch 05_1 to the process execution device 10-9.
After the batch 03_01 and the batch 05_02 are completed, the determination unit 104-4 or 104-9 that determines that all the batches to be monitored are completed transmits an activation instruction for the batch 06_1 to the process execution device 10-10.
After the batch 06_01 ends, the determination unit 104-10 transmits an activation instruction for the batch 07_01 to the process execution apparatus 10-11 and transmits an activation instruction for the batch 07_2 to the process execution apparatus 10-12.
バッチ07_01とバッチ07_02が終了後、監視するすべてのバッチが完了したと判定した判定部104−11または104−12は、処理実行装置10−13にバッチ08_1に対する起動指示を送信する。
バッチ02_04とバッチ08_01が終了後、監視するすべてのバッチが完了したと判定した判定部104−5または104−13は、処理実行装置10−14にバッチ09_1に対する起動指示を送信する。
バッチ09_01が終了後、判定部104−14は、処理実行装置10−15にバッチ10_01に対する起動指示を送信する。
After the batch 07_01 and the batch 07_02 are completed, the determination unit 104-11 or 104-12 that determines that all the batches to be monitored are completed transmits an activation instruction for the batch 08_1 to the process execution device 10-13.
After the batch 02_04 and the batch 08_01 are finished, the determination unit 104-5 or 104-13 that determines that all the batches to be monitored are completed transmits an activation instruction for the batch 09_1 to the process execution device 10-14.
After the batch 09_01 ends, the determination unit 104-14 transmits an activation instruction for the batch 10_01 to the process execution device 10-15.
以上のように、第1〜第3実施形態に係る処理実行装置10−n(含む10−nB)において、判定部104−nは、記憶部106−nに記憶されている設定情報に応じて、監視するバッチがすべて終了したか否かを判定する。そして、第1〜第3実施形態に係る処理実行装置10−n(含む10−nB)は、監視するバッチがすべて終了した場合、記憶部106−nに記憶されている設定情報に応じて後段のバッチを起動する起動指示を送信する。 As described above, in the processing execution devices 10-n (including 10-nB) according to the first to third embodiments, the determination unit 104-n is in accordance with the setting information stored in the storage unit 106-n. Determine whether all the batches to be monitored have been completed. Then, the process execution devices 10-n (including 10-nB) according to the first to third embodiments, when all the batches to be monitored are completed, are processed in accordance with the setting information stored in the storage unit 106-n. Send a start instruction to start the batch.
なお、本発明における処理実行装置10−n(含む10−nB)、記憶装置20(含む20A、20B)の機能を実現するためのプログラムをコンピュータ読み取り可能な記録媒体に記録して、この記録媒体に記録されたプログラムをコンピュータシステムに読み込ませ、実行することにより制御を行ってもよい。なお、ここでいう「コンピュータシステム」とは、OSや周辺機器等のハードウェアを含むものとする。また、「コンピュータシステム」は、ホームページ提供環境(あるいは表示環境)を備えたWWWシステムも含むものとする。また、「コンピュータ読み取り可能な記録媒体」とは、フレキシブルディスク、光磁気ディスク、ROM、CD−ROM等の可搬媒体、コンピュータシステムに内蔵されるハードディスク等の記憶装置のことをいう。さらに「コンピュータ読み取り可能な記録媒体」とは、インターネット等のネットワークや電話回線等の通信回線を介してプログラムが送信された場合のサーバやクライアントとなるコンピュータシステム内部の揮発性メモリ(RAM)のように、一定時間プログラムを保持しているものも含むものとする。 Note that a program for realizing the functions of the processing execution devices 10-n (including 10-nB) and the storage devices 20 (including 20A, 20B) according to the present invention is recorded on a computer-readable recording medium, and the recording medium Control may be performed by causing the computer system to read and execute the program recorded in the above. Here, the “computer system” includes an OS and hardware such as peripheral devices. The “computer system” includes a WWW system having a homepage providing environment (or display environment). The “computer-readable recording medium” refers to a storage device such as a flexible medium, a magneto-optical disk, a portable medium such as a ROM and a CD-ROM, and a hard disk incorporated in a computer system. Further, the “computer-readable recording medium” refers to a volatile memory (RAM) in a computer system that becomes a server or a client when a program is transmitted via a network such as the Internet or a communication line such as a telephone line. In addition, those holding programs for a certain period of time are also included.
また、上記プログラムは、このプログラムを記憶装置等に格納したコンピュータシステムから、伝送媒体を介して、あるいは、伝送媒体中の伝送波により他のコンピュータシステムに伝送されてもよい。ここで、プログラムを伝送する「伝送媒体」は、インターネット等のネットワーク(通信網)や電話回線等の通信回線(通信線)のように情報を伝送する機能を有する媒体のことをいう。また、上記プログラムは、前述した機能の一部を実現するためのものであってもよい。さらに、前述した機能をコンピュータシステムにすでに記録されているプログラムとの組み合わせで実現できるもの、いわゆる差分ファイル(差分プログラム)であってもよい。 The program may be transmitted from a computer system storing the program in a storage device or the like to another computer system via a transmission medium or by a transmission wave in the transmission medium. Here, the “transmission medium” for transmitting the program refers to a medium having a function of transmitting information, such as a network (communication network) such as the Internet or a communication line (communication line) such as a telephone line. The program may be for realizing a part of the functions described above. Furthermore, what can implement | achieve the function mentioned above in combination with the program already recorded on the computer system, what is called a difference file (difference program) may be sufficient.
1、1A、1B…処理実行システム、10−n、10−nB…処理実行装置、20、20A…記憶装置、30…通信ネットワーク、101−n…操作部、102−n…通信部、103−n…処理部、104−n、104−nB…判定部、105−n、105−nB…実行完了情報書込部、106−n…記憶部、107−n…起動カウンタ部、201…記憶部、202…調停部
DESCRIPTION OF
Claims (3)
前記自処理の実行が完了したときに、当該自処理の実行が完了したことを示す前記実行完了情報を記憶部に書き込む実行完了情報書込部と、
前記前段処理の開始時に起動回数を計数する起動カウンタと、
を備え、
前記実行完了情報書込部は、
前記前段処理の実行が完了したときに、前記実行完了情報と前記起動カウンタが計数した起動回数とを関連づけて前記記憶部に書き込み、
前記判定部は、
前記記憶部に記憶されている自処理実行装置の起動回数と同じ値の前記起動回数に関連づけられている前記実行完了情報を読み出し、読み出した前記実行完了情報に基づいて、複数の前記前段処理に含まれるすべての処理の実行が完了しているか否かを判定する
ことを特徴とする処理実行装置。 Based on the execution completion information indicating that the execution of the other process by another process execution apparatus that is processed in parallel with the own process executed by the own process execution apparatus is completed, the own process and the other process that are processed in parallel are Determining whether or not the execution of the preceding stage processing is completed, and determining that all the processes included in the preceding stage processing are completed and starting the subsequent stage processing executed after the preceding stage processing And
An execution completion information writing unit that writes the execution completion information indicating that the execution of the own process is completed to the storage unit when the execution of the own process is completed;
An activation counter that counts the number of activations at the start of the preceding process;
With
The execution completion information writing unit
When the execution of the preceding process is completed, the execution completion information and the number of activations counted by the activation counter are associated and written to the storage unit,
The determination unit
The execution completion information associated with the number of activations having the same value as the number of activations of the self-processing execution device stored in the storage unit is read, and a plurality of the preceding processes are performed based on the read execution completion information. A process execution apparatus for determining whether or not execution of all the processes included therein has been completed .
前記前段処理のうち複数の処理の実行が完了したときに、予め定められる書込み順序に基づいて前記実行完了情報を前記記憶部に書き込む
ことを特徴とする請求項1に記載の処理実行装置。 The execution completion information writing unit
The process execution apparatus according to claim 1 , wherein when the execution of a plurality of processes in the preceding process is completed, the execution completion information is written in the storage unit based on a predetermined write order.
起動カウンタが、並列処理される前記自処理と前記他処理とを含む前段処理の開始時に、起動回数を計数する起動回数計数手順と、
実行完了情報書込部が、前記前段処理の実行が完了したときに、前記前段処理の実行が完了したことを示す実行完了情報と、前記起動カウンタが計数した起動回数とを関連づけて記憶部に書き込む実行完了情報書込手順と、
判定部が、前記記憶部に記憶されている自処理実行装置の起動回数と同じ値の前記起動回数に関連づけられている前記実行完了情報を読み出し、読み出した前記実行完了情報に基づいて、前記前段処理の実行が完了しているか否かを判定し、前記前段処理に含まれるすべての処理が完了していると判定した場合に、前記前段処理の後に実行される後段処理を起動する判定手順と、
を有することを特徴とする処理実行方法。 About other processing by other processing execution devices that are processed in parallel with the own processing executed by the own processing execution device,
An activation counter that counts the number of activations at the start of the preceding process including the self-process and the other process to be processed in parallel;
When the execution completion information writing unit completes the execution of the preceding process, the execution completion information indicating that the execution of the preceding process is completed and the number of activations counted by the activation counter are associated with each other in the storage unit. Execution completion information writing procedure,
The determination unit reads the execution completion information associated with the number of activations having the same value as the number of activations of the own process execution device stored in the storage unit, and based on the read execution completion information, the pre-stage A determination procedure for determining whether or not the execution of the process has been completed and starting a subsequent process executed after the preceding process when it is determined that all the processes included in the preceding process have been completed ; ,
The process execution method characterized by having.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2012266281A JP5876406B2 (en) | 2012-12-05 | 2012-12-05 | Process execution device and process execution method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2012266281A JP5876406B2 (en) | 2012-12-05 | 2012-12-05 | Process execution device and process execution method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2014112300A JP2014112300A (en) | 2014-06-19 |
| JP5876406B2 true JP5876406B2 (en) | 2016-03-02 |
Family
ID=51169401
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2012266281A Active JP5876406B2 (en) | 2012-12-05 | 2012-12-05 | Process execution device and process execution method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5876406B2 (en) |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP3516049B2 (en) * | 1995-03-17 | 2004-04-05 | 富士通株式会社 | Batch job control system |
| JP5397076B2 (en) * | 2009-08-06 | 2014-01-22 | 日本電気株式会社 | Job execution apparatus, job execution method, and job execution program |
| JP5377231B2 (en) * | 2009-10-30 | 2013-12-25 | 株式会社東芝 | Job net control program and job net control device |
-
2012
- 2012-12-05 JP JP2012266281A patent/JP5876406B2/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| JP2014112300A (en) | 2014-06-19 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP4641546B2 (en) | Method and system for handling input/output (I/O) errors - Patents.com | |
| US7739371B2 (en) | Computer system | |
| JP5422342B2 (en) | Incident management method and operation management server | |
| US9218210B2 (en) | Distributed processing system | |
| EP2434729A2 (en) | Method for providing access to data items from a distributed storage system | |
| JP2010500673A (en) | Storage management system for maintaining consistency of remote copy data (storage management system, storage management method, and computer program) | |
| WO2014103029A1 (en) | Administration system and administration system control program | |
| CN103593266A (en) | ot standby method based on arbitration disk mechanism | |
| EP2287745A1 (en) | Computer system, managing server, and configuration information acquiring method | |
| US6493772B1 (en) | System and method with guaranteed maximum command response time | |
| CN107566460B (en) | Method and system for distributed deployment of planning tasks | |
| JP5876406B2 (en) | Process execution device and process execution method | |
| US6567912B1 (en) | Method and apparatus for robust initialization of devices | |
| US6732212B2 (en) | Launch raw packet on remote interrupt | |
| US20120087242A1 (en) | Systems and methods for throttling a fabric login in a fibre channel adapter | |
| JP2002358170A (en) | Disk storage device, computer system provided with the disk storage device, and error notification method at retry processing in the computer system | |
| US20120166750A1 (en) | System and method for managing resets in a system using shared storage | |
| US9239969B1 (en) | Image forming device, image forming method, and non-transitory computer readable medium | |
| JP6924898B2 (en) | Transaction processing methods, devices and devices | |
| TW589525B (en) | Checkpointing for recovery of channels in a data processing system | |
| EP3248157A1 (en) | Multiple phase unenrollment for devices under management | |
| JP6726136B2 (en) | Data access device and access error notification method | |
| JP2013200601A (en) | Database system, commitment method in database system, and program | |
| CN119668514B (en) | Resource taking-over method, device, equipment and medium for shared cluster | |
| WO2017041548A1 (en) | Network management data configuration method, device and system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20150129 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20150630 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20150728 |
|
| A521 | Written amendment |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20150916 |
|
| 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: 20160105 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20160121 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5876406 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |