JP3680228B2

JP3680228B2 - Execution state management method and system for parallel processing process

Info

Publication number: JP3680228B2
Application number: JP19799596A
Authority: JP
Inventors: 博司加藤; 敏雄西山
Original assignee: Nippon Telegraph and Telephone Corp; NTT Inc USA
Current assignee: NTT Inc; NTT Inc USA
Priority date: 1996-07-26
Filing date: 1996-07-26
Publication date: 2005-08-10
Anticipated expiration: 2016-07-26
Also published as: JPH1040116A

Description

【０００１】
【発明の属する技術分野】
本発明は、並行処理プロセスの実行状態管理方法及びシステムに係り、特に、１つのプロセスが複数のジョブ（サブプロセス）からなり、それぞれのジョブ毎の実行状態に基づいて、元のプロセスの状態の集計管理を実施したり、あるプロセスが他のプロセスの状態に基づいて状態取得を可能にするための並行処理プロセスの実行状態管理方法及びシステムに関する。
【０００２】
【従来の技術】
従来、プロセスの実行状態は、１つの状態のみで表され、実行変化に伴う状態変化に応じて、同時に複数の状態で表現することは想定されていないため、プロセスの実行状態の管理において、個々の状態は相互に排他的であり、常に１つの状態が終了すると、他の１つの状態に遷移することを前提としている。
【０００３】
【発明が解決しようとする課題】
しかしながら、プロセスが同時に複数のジョブを非同期に処理した場合、ジョブ毎の実行状態のうち、どれを当該プロセスの状態として管理すべきか判断する方法がない。このため、当該プロセスにおいて、実際に実行されている状態を正確に把握できないという問題がある。
【０００４】
本発明は、上記の点に鑑みなされたもので、１つのプロセスが同時にそれぞれ個別の状態を持つ複数のジョブを並行処理した場合であっても、その複数の状態の中から当該プロセスの状態として管理すべき状態を一意に決定することが可能な並行処理プロセス実行状態管理方法及びシステムを提供することを目的とする。
また、本発明の目的は、プロセスが処理する複数のジョブ全体が終了するまでの、途中の状態変化を矛盾なく管理することが可能な並行処理プロセス実行状態管理方法及びシステムを提供することである。
更なる本発明の目的は、プロセスがもつ複数の状態の中から最も重要な状態を抽出することが可能な並行処理プロセス実行状態管理方法及びシステムを提供することである。
【０００５】
【課題を解決するための手段】
図１は、本発明の原理を説明するための図である。
本発明の並行処理プロセスの実行状態管理方法は、並行してジョブを処理するプロセスの実行状態を監視し、プロセスの状態の変化を検出する状態監視ステップと（ステップ１）、
状態監視ステップにおいて、プロセスに新たな状態が発生したことが検出されると、状態と該状態に対応する優先順位を保持する状態定義記憶手段の情報を参照して（ステップ２）、通知された状態と同一の優先順位の状態群を取得し、該プロセスのプロセス識別子に基づいて、プロセス毎にプロセス識別子と状態集合を保持する状態集合保持手段を検索し（ステップ３ ) 、状態集合を取得し、該状態群と該状態集合との対比により、通知された状態と該状態集合の中から最も優先順位の高い状態を該プロセスの状態として一意に決定する（ステップ４）状態決定ステップと、を行う。
【０００６】
また、本発明は、状態決定ステップにおいて、
状態監視ステップで検出された変化したプロセスの状態に基づいて、状態定義記憶手段を検索し、プロセスの状態と該状態に対応する優先順位及びそれと同一の優先順位の状態からなる状態群を取得する優先順位検索ステップと、
状態監視ステップで検出された前記状態群に含まれる状態が変化したプロセスのプロセス識別子に基づいて、状態集合保持手段を検索し、該プロセス識別子に対応する状態集合を取得する状態集合検索ステップと、
優先順位検索ステップにより検索された状態が、状態集合検索ステップにより取得した状態集合と重複していれば、当該重複している状態を該状態集合から削除して前記状態監視ステップで検出された状態を加えて新たな状態集合として、状態集合保持手段に格納する第１の状態集合更新ステップと、
新たな状態集合の中で最も優先順位が高い状態を当該プロセスの状態とする第１の状態認識ステップと、を行う。
【０００７】
また、本発明は、状態決定ステップにおいて、
状態監視ステップにおいてプロセスの状態の終了が検出されると、状態集合保持手段の該プロセスに対応する状態集合から終了した該状態を削除して新たな状態集合として、状態集合保持手段に格納する削除ステップと、
状態定義記憶手段を参照して、新たな状態集合のうち、最も優先順位が高い状態を当該プロセスの状態とする第２の状態認識ステップとを行う。
【０００８】
また、本発明は、状態決定ステップにおいて、
状態監視ステップにおいて検出された状態に対応する状態定義記憶手段の優先順位を取得し、状態監視ステップにおいて検出されたプロセスの状態が、状態集合保持手段に保持されている状態集合の要素より、優先順位が高い場合には、該状態集合保持手段に保持されている状態集合に該通知されたプロセスの状態を追加する第２の状態集合更新ステップと、
プロセスの現在状態を、通知されたプロセスの状態とする第３の状態認識ステップとを行う。
【０００９】
また、本発明は、状態決定ステップにおいて、
状態監視ステップにおいて検出された状態に対応する状態定義記憶手段の優先順位を取得し、該通知された状態が、状態集合保持手段に保持されている状態集合の要素と優先順位が同じである場合は、該状態集合保持手段に保持されているそれまでの状態を削除し、該通知されたプロセスの状態を該状態集合保持手段に格納する第２の状態集合更新ステップと、
プロセスの現在の状態を、通知されたプロセスの状態とする第４の状態認識ステップとを行う。
【００１０】
また、本発明は、状態決定ステップにおいて、
状態監視ステップにおいて検出された状態に対応する状態定義記憶手段の優先順位を取得し、該通知された状態が、状態集合保持手段に保持されている状態集合の要素より優先順位が低い場合は、該状態集合保持手段に、該通知されたプロセスの状態を追加する第４の状態集合更新ステップと、
プロセスの現在の状態を、プロセスの状態の通知以前の状態とする第５の状態認識ステップとを行う。
【００１１】
図２は、本発明の原理構成図である。
本発明の並行処理プロセスの実行状態管理システムは、
並行処理を実施する管理対象であるプロセス群１０と、
プロセスの状態の変化を検出する状態監視手段２２と、
プロセス毎にプロセス識別子と状態集合を保持する状態集合保持手段２３と、
状態と該状態に対応する優先順位を保持する状態定義記憶手段２４と、
状態監視手段２２からプロセスに新たな状態が発生したことが通知されると、状態定義記憶手段２４の情報を参照して、通知された状態と同一の優先順位の状態群を取得し、該プロセスのプロセス識別子により、状態集合保持手段２３を検索し、状態集合を取得し、該状態群と該状態集合との対比により、通知された状態と該状態集合の中から最も優先順位の高い状態を該プロセスの状態として一意に決定する状態決定手段２１と、を有する。
【００１２】
上記の状態決定手段２１は、
状態監視手段２２から通知される変化したプロセスの状態に基づいて、状態定義記憶手段２４を検索し、プロセスの状態と該状態に対応する優先順位とその同一の優先順位の状態からなる状態群を取得する優先順位検索手段と、
状態監視手段２２から通知される状態が変化したプロセスのプロセス識別子に基づいて、状態集合保持手段２３を検索し、該プロセス識別子に対応する状態集合を取得する状態集合検索手段と、
優先順位検索手段により検索された状態が、状態集合検索手段により取得した状態集合と重複していれば、当該重複している状態を該状態集合から削除して該通知されたプロセスの状態を加えて新たな状態集合として、状態集合保持手段２３に格納する第１の状態集合更新手段と、
新たな状態集合の中で最も優先順位が高い状態を当該プロセスの状態とする第１の状態認識手段とを含む。
【００１３】
また、上記の状態決定手段２１は、
状態監視手段２２からプロセスの状態の終了が通知されると、状態集合保持手段２３の該プロセスに対応する状態集合から終了した該状態を削除して新たな状態集合として、状態集合保持手段２３に格納する削除手段と、
状態定義記憶手段２４を参照して、新たな状態集合のうち、最も優先順位が高い状態を当該プロセスの状態とする第２の状態認識手段とを含む。
【００１４】
また、上記の状態決定手段２１は、
状態監視手段２２により通知された状態に対応する状態定義記憶手段２４の優先順位を取得し、該状態監視手段２２から通知されたプロセスの状態が、状態集合保持手段２３に保持されている状態集合の要素より、優先順位が高い場合には、該状態集合保持手段２３に保持されている状態集合に該通知されたプロセスの状態を追加する第２の状態集合更新手段と、
プロセスの現在状態を、通知されたプロセスの状態とする第３の状態認識手段とを含む。
【００１５】
また、上記の状態決定手段２１は、
状態監視手段２２により通知された状態に対応する状態定義記憶手段２４の優先順位を取得し、該通知された状態が、状態集合保持手段２３に保持されている状態集合の要素と該優先順位が同じである場合は、該状態集合保持手段２３に保持されているそれまでの状態を削除し、該通知されたプロセスの状態を該状態集合保持手段２３に格納する第２の状態集合更新手段と、
プロセスの現在の状態を、通知されたプロセスの状態とする第４の状態認識手段とを含む。
【００１６】
また、上記の状態決定手段２１は、
状態監視手段２２から通知された状態に対応する状態定義記憶手段２４の優先順位を取得し、該通知された状態が、状態集合保持手段２３に保持されている状態集合の要素より優先順位が低い場合は、該状態集合保持手段２３に、該通知されたプロセスの状態を追加する第４の状態集合更新手段と、
プロセスの現在の状態を、プロセスの状態の通知以前の状態とする第５の状態認識手段とを含む。
【００１７】
このように、本発明によれば、プロセスの実行状態を管理する状態管理システムにおいて、プロセスが取り得る状態及びその優先順位を定義し、これらを対として管理し、プロセスの実行を監視し、当該プロセスの状態の変化を検知する。プロセスの実行状態が１つ以上の状態を持つ状態集合となった場合に、そのプロセスの識別子と状態集合を対として保持し、プロセスの識別子毎に最も高い優先順位の状態のみを現在の状態を代表する状態として１つだけ認識する。管理対象となるプロセスの状態が変化した場合に、プロセスの識別子とプロセスの状態の優先順位を取得し、当該順位が同一の優先順位であるとき、変化した状態を当該プロセスの状態として認識する。
【００１８】
また、変化した状態の順位が高い優先順位である場合には、変化した状態を当該プロセスの状態と認識する。低い優先順位であれば、認識する状態は変更しない。
さらに、新しい新たな状態の追加や、それまでの状態の削除等をプロセス識別子と共に記録しておくことにより、複数の状態を取り得るプロセスでも一意の状態の決定を行うことが可能である。
【００１９】
従って、プロセスが複数のジョブを同時に実行した場合でも、上記の状態決定手段により、当該プロセスの状態を常に一意に決定することが可能となる。
また、状態保持手段により、プロセス毎に発生した状態を保持しておくために、プロセス全体が終了する途中の状態変化を矛盾なく管理することが可能となる。
【００２０】
さらに、優先順位を参照することにより、当該プロセスの最も重要な状態を抽出することが可能となる。
【００２１】
【発明の実施の形態】
図３は、本発明の実行状態管理システムの構成を示す。
同図に示す実行状態管理システムは、管理対象１０と状態管理部２０から構成され、管理対象１０には、並行処理を行うプロセスＡ，Ｂ，Ｃ，Ｄが存在する。状態管理部２０は、状態決定部２１、状態監視部２２、状態保持部２３、状態定義管理部２４より構成される。
【００２２】
状態決定部２１は、プロセスの予め決めておいた識別子と状態集合を取得し、さらに、ある状態の追加、削除の通知を行うと同時に、取得した状態集合中の最も高い優先順位の状態のみを現在の状態を代表する状態として１つだけ認識する。
【００２３】
状態監視部２２は、並行処理する複数のプロセスの実行状態を監視し、当該プロセスの状態の変化を検出する。
状態保持部２３は、１つのプロセスの実行状態が１つ以上の状態を有する状態集合となっている場合に、当該プロセスの予め決めておいた識別子と状態集合を対として保持する。
【００２４】
状態定義管理部２４は、プロセスが取り得る状態に優先順位を付与し、当該優先順位と状態を対として保持する。
上記の構成による一連の処理を説明する。
状態監視部２２が、管理対象１０のプロセスに新たな状態が生じたことを検出すると、状態監視部２２は、そのプロセス識別子と、当該状態が生じたことを状態決定部２１に通知する。
【００２５】
状態決定部２１は、状態監視部２２から通知された状態と同一優先順位の状態群を状態定義管理部２４から取得し、状態監視部２２から通知された識別子の状態集合を状態保持部２３から取得し、状態集合の中から状態群と重複している状態があった場合には、状態集合から重複している状態を削除して新しい状態集合とし、重複している状態がない場合には、そのまま新たな状態集合とし、新たな状態集合に登録された状態を含めてプロセス識別子と共に、状態保持部２３に保持する。
【００２６】
同時に、状態決定部２１は、新たに当該プロセスの状態として現在の状態保持部２３に保持されている状態集合の中で優先順位の最も高い状態を現在のそのプロセスの状態として認識し、プロセスの１つの状態が終了したことを状態監視部２２が検出した場合には、状態監視部２２は、当該プロセスの識別子とプロセスの状態の終了を状態決定部２１に通知する。状態決定部２１は、通知された状態の削除を状態保持部２３に通知する。
【００２７】
状態決定部２１は、新たに当該プロセスの状態として現在の状態保持部２３に保持されている状態集合の中で優先順位が最も高いものを現在の状態として認識し、状態保持部２３に通知し、状態保持部２３では、状態決定部２１からの通知に基づいて状態の追加、削除を行う。
【００２８】
これにより、複数の実行状態を取り得るプロセスでも、１つのプロセスについては、常にその時点で最も優先順位の高い状態１つだけを、状態決定部２１で認識できる。
以下では、図３に示す構成に基づいて説明する。
【００２９】
図４は、本発明のプロセスに新たな状態が生じた場合の動作のフローチャートである。
ステップ１０１）管理対象１０のプロセス１１に新たな状態が生じた場合、状態監視部２２は、プロセス１１の識別子と生じた状態を検出する。
【００３０】
ステップ１０２）状態監視部２２は、プロセス識別子と生じた状態を状態決定部２１に通知する。
ステップ１０３）状態決定部２１は、通知された状態と同一優先順位の状態の全てを状態定義管理部２４より取得する。
【００３１】
ステップ１０４）状態決定部２１は、プロセス識別子をキーにして状態保持部２３よりプロセスの状態集合を取得する。
ステップ１０５）次に、ステップ１０３で取得した同一優先順位の状態の中にステップ１０４で取得した状態集合にあるものとが重複していれば、ステップ１０６に移行し、重複していなければ、ステップ１０７に移行する。
【００３２】
ステップ１０６）状態集合から重複している状態を削除して、新たな状態集合とする。
ステップ１０７）状態集合に変更状態を加えて新たな状態集合とし、ステップ１０３で検索した状態保持部２３のステップ１０２で取得したプロセス識別子に状態集合として再設定する。
【００３３】
ステップ１０８）状態決定部２１は、当該状態集合の中で最も優先順位の高いものを当該プロセス１１の状態として認識する。
次に、プロセス１１が状態を終了した場合の動作を説明する。
図５は、本発明のプロセスが状態を終了した場合の動作のフローチャートである。
【００３４】
ステップ２０１）状態監視部２２がプロセス１１の状態の終了を検出する。
ステップ２０２）状態監視部２２は、プロセス識別子と終了した状態を状態決定部２１に通知する。
ステップ２０３）状態決定部２１は、プロセス識別子をキーにして、状態保持部２３より状態集合を取得し、通知された状態を状態集合から削除し、新しい状態集合とする。
【００３５】
ステップ２０４）状態決定部２１は、状態保持部２３にその新しい状態集合を設定する。
ステップ２０５）状態決定部２１は、当該状態集合の中で最も優先順位の高いものを当該プロセス１１の状態として認識する。
【００３６】
次に、状態決定部２１における状態の認識動作を詳細に説明する。
図６は、本発明の状態決定部におけるプロセスに対する状態の認識動作のフローチャートである。
ステップ３０１）状態決定部２１は、状態定義管理部２４から最も優先順位の高い状態群を取得する。
【００３７】
ステップ３０２）状態決定部２１は、新しい状態集合中に一致する状態がないかを調べ、ない場合には、ステップ３０３に移行し、ある場合には、ステップ３０４に移行する。
ステップ３０３）状態定義管理部２４より次に優先順位の高い状態群を取り出し、ステップ３０２に移行する。
【００３８】
ステップ３０４）状態決定部２１は、当該状態をそのプロセス１１の状態として認識する。
【００３９】
【実施例】
以下に、本発明の実施例を図面と共に説明する。
図７は、本発明の一実施例の実行状態管理システムの第１の例である。
本実施例では、電話応対、帳票処理等を実施する業務管理システムにおいて、処理として、電話処理、帳票処理、作業処理、休憩処理があり、優先順位は、以下の通りである。
Ｐ１．電話処理
Ｐ２．帳票処理
Ｐ３．作業処理
Ｐ４．休憩処理
また、処理が取り得る状態として、電話処理については、「電話の着信」、「電話応対」があり、帳票処理については、「帳票着信」、「帳票処理」があり、休憩処理は「休憩」のみ、作業処理は「作業」のみである。
【００４０】
システムの運用前、状態を定義しておく必要があるため、状態定義管理部２４には、以下のように優先順位と状態が組で定義される。
Ｐ１／電話着信、電話応対
Ｐ２／帳票受信、帳票処理
Ｐ３／休憩、作業
Ｐ４／その他
このような前提で、同じ優先順位の状態がプロセス１１で生じた場合の例を説明する。図７に示す○内の数字と以下の説明の○内の数字は一致するものとする。
【００４１】
▲１▼ 運用段階において、プロセスＡ１１が「電話応対」という状態になった場合、状態監視部２２が、当該プロセスＡ１１のこの状態を検出し、状態決定部２１に「プロセス識別子＝プロセスＡ」「生じた状態＝電話応対」を通知する。
▲２▼ 状態決定部２１は、生じた状態（電話応対）をキーにして状態定義管理部２４から「電話応対」と同一優先順位（Ｐ１）の状態群である〔「電話着信」，「電話応対」〕を取得する。
【００４２】
▲３▼ 次に、状態決定部２１は、プロセスＡ１１のプロセス識別子（プロセスＡ）をキーにしてプロセスＡ１１の状態集合である
〔「電話着信」、「帳票処理」〕
を状態保持部２３から取得する。
【００４３】
▲４▼ これにより、状態保持部２３から取得した状態集合において、「電話着信」が重複しているため、その状態集合の中から状態定義管理部２４より取得した状態である「電話着信」を削除し、新しい状態集合を
「帳票処理」
とする。
【００４４】
▲５▼ 次に新しい状態集合に、状態監視部２２から通知された状態である「電話応対」を状態保持部２３に追加し、
〔「電話応対」，「帳票処理」〕
という新しい状態集合とする。
【００４５】
▲６▼ その新しい状態集合を状態保持部２３に設定し、状態定義管理部２４から新しい状態集合のうち、最も高い優先順位の状態である「電話応対」をこのプロセスＡ１１の状態として、状態決定部２１が認識することができる。その結果を図８に示す。
【００４６】
次に、優先順位の低い状態がプロセスＤ１１で発生した場合について説明する。図９は、本発明の一実施例の優先順位が低い状態がプロセスで発生した例を示す図である。同図中の○内の数字と、以下の説明における○内の数字は一致するものとする。
【００４７】
▲１▼ プロセスＤ１１で「作業」という状態が発生する。
▲２▼ プロセスＤ１１の状態「作業」を状態監視部２２が検出し、状態決定部２１に「プロセス識別子＝プロセスＤ」「生じた状態＝作業」を通知する。
▲３▼ 状態決定部２１は、状態定義部２４から作業と同じ優先順位である状態群「休憩」と「作業」を取得する。
【００４８】
▲４▼ 次に、プロセスＤ１１の状態集合である「電話応対」を状態保持部２３から取得し、状態定義部２４から取得した状態と重複しているものがないので、状態集合に「作業」を追加し、新しい状態集合を
〔「電話応対」「作業」〕
とする。
【００４９】
▲５▼ その新しい状態集合を状態保持部２３に設定し、状態決定部２１はプロセスＤ１１の状態を優先順位により「電話応対」のままとする。その結果を図１０に示す。
図１１は、本発明の管理方法を適用した場合の認識状態の利用例を示す。同図の処理が下から実行された順になっており、棒グラフが時間に対して重なっている部分が状態集合であり、時間の欄に認識されている状態が表されている。この時間を集計することにより、システムの状態別集計管理等に利用することが可能である。
【００５０】
なお、本発明は、上記の実施例に限定されることなく、特許請求の範囲内で種々変更・応用が可能である。
【００５１】
【発明の効果】
上述のように、本発明によれば、プロセスは、プロセス内のサブプロセス毎に、状態の追加、削除といったことを繰り返すだけで、結果としてプロセスの状態を管理することが可能である。
【００５２】
また、状態に優先順位が設けられるため、管理されるプロセスは自プロセスの状態を最も高い優先順位で一意に決定されるので、プロセスの状態判別が容易となる。
【図面の簡単な説明】
【図１】本発明の原理を説明するための図である。
【図２】本発明の原理構成図である。
【図３】本発明の実行状態管理システムの構成図である。
【図４】本発明のプロセスに新たな状態が生じた場合の動作のフローチャートである。
【図５】本発明のプロセスが状態を終了した場合の動作のフローチャートである。
【図６】本発明の状態決定部におけるプロセスに対する状態の認識動作のフローチャートである。
【図７】本発明の一実施例の実行状態管理システムの第１の例である。
【図８】本発明の一実施例の実行状態管理システムの第１の例における処理結果を示す図である。
【図９】本発明の一実施例の優先順位が低い状態がプロセスで発生した例を示す図である。
【図１０】本発明の一実施例の優先順位が低い状態がプロセスで発生した場合の処理結果を示す図である。
【図１１】本発明の管理方法を適用した場合の認識状態の利用例を示す図である。
【符号の説明】
１０管理対象、プロセス群
１１プロセス
２０状態管理部
２１状態決定部、状態決定手段
２２状態監視部、状態監視手段
２３状態保持部、状態集合保持手段
２４状態定義管理部、状態定義記憶手段[0001]
BACKGROUND OF THE INVENTION
The present invention relates to a parallel processing process execution state management method and system, and in particular, one process includes a plurality of jobs (subprocesses), and the state of the original process is determined based on the execution state of each job. The present invention relates to an execution state management method and system for a parallel processing process for performing aggregation management and enabling a certain process to acquire a state based on the state of another process.
[0002]
[Prior art]
Conventionally, the execution state of a process is represented by only one state, and it is not assumed to be expressed in a plurality of states at the same time in accordance with the state change accompanying the change in execution. These states are mutually exclusive, and when one state is always finished, it is assumed that a transition is made to another one state.
[0003]
[Problems to be solved by the invention]
However, when a process simultaneously processes a plurality of jobs asynchronously, there is no method for determining which of the execution states for each job should be managed as the state of the process. For this reason, in the process, there is a problem that the state actually executed cannot be accurately grasped.
[0004]
The present invention has been made in view of the above points. Even when a single process simultaneously processes a plurality of jobs having individual states, the process state is selected from the plurality of states. It is an object to provide a parallel processing process execution state management method and system capable of uniquely determining a state to be managed .
Another object of the present invention is to provide a parallel processing process execution state management method and system capable of managing state changes in the middle until a plurality of jobs processed by the process are completed. .
A further object of the present invention is to provide a parallel process execution state management method and system capable of extracting the most important state from a plurality of states of a process.
[0005]
[Means for Solving the Problems]
FIG. 1 is a diagram for explaining the principle of the present invention.
The parallel processing process execution state management method of the present invention monitors the execution state of processes that process jobs in parallel and detects a change in the state of the process (step 1).
In the state monitoring step, when it is detected that a new state has occurred in the process, the state definition storage means that holds the state and the priority corresponding to the state is referred to (step 2) and notified. A state group having the same priority order as the state is acquired, and a state set holding unit that holds the process identifier and the state set is searched for each process based on the process identifier of the process (step 3 ) , and the state set is acquired. A state determination step that uniquely determines the notified state and the state with the highest priority from the state set as the state of the process by comparing the state group and the state set (step 4), Do.
[0006]
In the state determination step , the present invention
Based on the state of the changed process detected in the state monitoring step, the state definition storage unit is searched, and a state group including the state of the process, the priority corresponding to the state, and the state having the same priority as the priority is acquired. A priority search step;
Based on the process identifier of the process whose state included in the state group detected in the state monitoring step is changed, a state set holding unit is searched, and a state set search step for acquiring a state set corresponding to the process identifier;
If the state searched in the priority order search step overlaps the state set acquired in the state set search step, the state detected in the state monitoring step by deleting the overlapping state from the state set And a first state set update step of storing in the state set holding means as a new state set;
A first state recognition step is performed in which the state having the highest priority in the new state set is the state of the process.
[0007]
In the state determination step , the present invention
When the end of the process state is detected in the state monitoring step, the state that has ended from the state set corresponding to the process of the state set holding unit is deleted and stored in the state set holding unit as a new state set Steps,
With reference to the state definition storage means, a second state recognition step is performed in which the state having the highest priority in the new state set is set as the state of the process.
[0008]
In the state determination step , the present invention
The priority of the state definition storage means corresponding to the state detected in the state monitoring step is acquired, and the state of the process detected in the state monitoring step has priority over the elements of the state set held in the state set holding means. If the rank is high, a second state set update step of adding the state of the notified process to the state set held in the state set holding unit;
A third state recognition step for setting the current state of the process to the state of the notified process is performed .
[0009]
In the state determination step , the present invention
When the priority of the state definition storage unit corresponding to the state detected in the state monitoring step is acquired, and the notified state has the same priority as the element of the state set held in the state set holding unit Deletes the previous state held in the state set holding unit, and stores the notified state of the process in the state set holding unit;
A fourth state recognition step is performed for setting the current state of the process to the state of the notified process .
[0010]
In the state determination step , the present invention
If the priority of the state definition storage means corresponding to the state detected in the state monitoring step is acquired and the notified state has a lower priority than the elements of the state set held in the state set holding means, A fourth state set update step of adding the state of the notified process to the state set holding means;
A fifth state recognition step is performed in which the current state of the process is set to a state before the notification of the state of the process .
[0011]
FIG. 2 is a principle configuration diagram of the present invention.
The parallel processing process execution state management system of the present invention includes:
A process group 10 which is a management target for performing parallel processing;
State monitoring means 22 for detecting a change in the state of the process;
State set holding means 23 for holding a process identifier and a state set for each process ;
A state definition storage unit 24 that holds a state and a priority order corresponding to the state;
When it is notified from the state monitoring unit 22 that a new state has occurred in the process, the state definition storage unit 24 is referred to, and a state group having the same priority as the notified state is acquired. The state set holding means 23 is searched by using the process identifier, the state set is acquired, and the state having the highest priority is selected from the state set and the state set by comparing the state group and the state set. State determining means 21 for uniquely determining the state of the process .
[0012]
The state determination means 21
Based on the changed process state notified from the state monitoring unit 22, the state definition storage unit 24 is searched, and a state group including a process state, a priority corresponding to the state, and a state having the same priority order is obtained. A priority search means to obtain;
A state set search unit that searches the state set holding unit 23 based on the process identifier of the process whose state is notified from the state monitoring unit 22 and acquires a state set corresponding to the process identifier;
If the state searched by the priority order search means overlaps with the state set acquired by the state set search means, the duplicate state is deleted from the state set and the state of the notified process is added. First state set updating means for storing in the state set holding means 23 as a new state set,
The highest priority status in the new state set and a first state recognition means for the state of the process.
[0013]
In addition, the state determination means 21
When the end of the process state is notified from the state monitoring unit 22, the state set holding unit 23 deletes the completed state from the state set corresponding to the process and creates a new state set to the state set holding unit 23. Delete means to store;
Referring to the state definition storage unit 24, a second state recognition unit that sets the state having the highest priority in the new state set as the state of the process is included.
[0014]
In addition, the state determination means 21
The priority of the state definition storage unit 24 corresponding to the state notified by the state monitoring unit 22 is acquired, and the state of the process notified from the state monitoring unit 22 is held in the state set holding unit 23 A second state set update unit that adds the state of the notified process to the state set held in the state set holding unit 23 when the priority is higher than the element of
And third state recognition means for setting the current state of the process to the state of the notified process.
[0015]
In addition, the state determination means 21
Acquires priority status definition storage unit 24 corresponding to the notified state by the state monitoring means 22, the notification state is, elements and the priority of the set of states stored in the state set storage means 23 If the same is to delete the condition of up to and held in the state set storage unit 23, and a second state set updating means for storing the state of the notified process to the state set storage means 23 ,
The current state of the process, and a fourth state recognition means for the state notification process.
[0016]
In addition, the state determination means 21
The priority of the state definition storage unit 24 corresponding to the state notified from the state monitoring unit 22 is acquired, and the notified state has a lower priority than the elements of the state set held in the state set holding unit 23 A fourth state set update means for adding the state of the notified process to the state set holding means 23 ;
And fifth state recognition means for setting the current state of the process to a state before the notification of the process state.
[0017]
Thus, according to the present invention, in the state management system that manages the execution state of the process, the states that the process can take and their priorities are defined, these are managed as a pair, the execution of the process is monitored, Detect process state changes. When a process execution state becomes a state set having one or more states, the process identifier and the state set are stored as a pair, and only the highest priority state for each process identifier is changed to the current state. Only one state is recognized as a representative state. When the state of the process to be managed changes, the process identifier and the priority order of the process state are acquired, and when the order is the same priority order, the changed state is recognized as the state of the process.
[0018]
Further, when the order of the changed state is high priority, the changed state is recognized as the state of the process. If the priority is low, the recognition state is not changed.
Further, by recording the addition of a new new state, the deletion of the state so far, and the like together with the process identifier, it is possible to determine a unique state even in a process that can take a plurality of states.
[0019]
Therefore, even when a process executes a plurality of jobs at the same time, the state determination unit can always uniquely determine the state of the process.
In addition, since the state that has occurred for each process is held by the state holding unit, it is possible to manage a state change during the completion of the entire process without contradiction.
[0020]
Furthermore, by referring to the priority order, the most important state of the process can be extracted.
[0021]
DETAILED DESCRIPTION OF THE INVENTION
FIG. 3 shows the configuration of the execution state management system of the present invention.
The execution state management system shown in FIG. 1 includes a management target 10 and a state management unit 20, and the management target 10 includes processes A, B, C, and D that perform parallel processing. The state management unit 20 includes a state determination unit 21, a state monitoring unit 22, a state holding unit 23, and a state definition management unit 24.
[0022]
The state determination unit 21 acquires a predetermined identifier and state set of the process, and further notifies the addition and deletion of a certain state, and at the same time, only the state with the highest priority in the acquired state set. Only one state is recognized as representing the current state.
[0023]
The state monitoring unit 22 monitors the execution state of a plurality of processes that are processed in parallel, and detects a change in the state of the process.
When the execution state of one process is a state set having one or more states, the state holding unit 23 holds a predetermined identifier and state set of the process as a pair.
[0024]
The state definition management unit 24 assigns priorities to the states that can be taken by the process, and holds the priorities and states as a pair.
A series of processes according to the above configuration will be described.
When the state monitoring unit 22 detects that a new state has occurred in the process of the management target 10, the state monitoring unit 22 notifies the state determination unit 21 of the process identifier and that state has occurred.
[0025]
The state determination unit 21 acquires a state group having the same priority as the state notified from the state monitoring unit 22 from the state definition management unit 24, and acquires a state set of identifiers notified from the state monitoring unit 22 from the state holding unit 23. If there is a state that overlaps with the state group from the state set, delete the overlapping state from the state set to create a new state set, and if there is no overlapping state The new state set is used as is, and the state registered in the new state set is stored in the state holding unit 23 together with the process identifier.
[0026]
At the same time, the state determination unit 21 recognizes the state having the highest priority in the state set held in the current state holding unit 23 as the state of the process as the current state of the process. When the state monitoring unit 22 detects that one state has ended, the state monitoring unit 22 notifies the state determination unit 21 of the identifier of the process and the end of the process state. The state determination unit 21 notifies the state holding unit 23 of deletion of the notified state.
[0027]
The state determination unit 21 recognizes the state set with the highest priority among the state sets held in the current state holding unit 23 as the state of the process, and notifies the state holding unit 23 of the current state. The state holding unit 23 adds and deletes states based on the notification from the state determination unit 21.
[0028]
Thereby, even in a process that can take a plurality of execution states, the state determination unit 21 can always recognize only one state having the highest priority order at that time.
Below, it demonstrates based on the structure shown in FIG.
[0029]
FIG. 4 is a flowchart of the operation when a new state occurs in the process of the present invention.
Step 101) When a new state occurs in the process 11 of the management target 10, the state monitoring unit 22 detects the identifier of the process 11 and the generated state.
[0030]
Step 102) The state monitoring unit 22 notifies the state determination unit 21 of the process identifier and the generated state.
Step 103) The state determination unit 21 acquires all the states having the same priority order as the notified state from the state definition management unit 24.
[0031]
Step 104) The state determination unit 21 acquires a process state set from the state holding unit 23 using the process identifier as a key.
Step 105) Next, if the same priority order acquired in Step 103 overlaps that in the state set acquired in Step 104, the process proceeds to Step 106. 107.
[0032]
Step 106) The overlapping state is deleted from the state set to obtain a new state set.
Step 107) A changed state is added to the state set to make a new state set, and the state identifier is reset as the state set acquired in step 102 of the state holding unit 23 searched in step 103.
[0033]
Step 108) The state determination unit 21 recognizes the state having the highest priority in the state set as the state of the process 11.
Next, an operation when the process 11 ends the state will be described.
FIG. 5 is a flowchart of the operation when the process of the present invention ends the state.
[0034]
Step 201) The state monitoring unit 22 detects the end of the state of the process 11.
Step 202) The state monitoring unit 22 notifies the state determination unit 21 of the process identifier and the completed state.
Step 203) The state determination unit 21 acquires a state set from the state holding unit 23 using the process identifier as a key, deletes the notified state from the state set, and creates a new state set.
[0035]
Step 204) The state determination unit 21 sets the new state set in the state holding unit 23.
Step 205) The state determination unit 21 recognizes the state having the highest priority in the state set as the state of the process 11.
[0036]
Next, the state recognition operation in the state determination unit 21 will be described in detail.
FIG. 6 is a flowchart of the state recognition operation for the process in the state determination unit of the present invention.
Step 301) The state determination unit 21 acquires the state group having the highest priority from the state definition management unit 24.
[0037]
Step 302) The state determination unit 21 checks whether there is a matching state in the new state set. If there is no matching state, the state determination unit 21 proceeds to Step 303, and if it exists, proceeds to Step 304.
Step 303) The state group with the next highest priority is extracted from the state definition management unit 24, and the process proceeds to Step 302.
[0038]
Step 304) The state determination unit 21 recognizes the state as the state of the process 11.
[0039]
【Example】
Embodiments of the present invention will be described below with reference to the drawings.
FIG. 7 is a first example of an execution state management system according to an embodiment of the present invention.
In the present embodiment, in a business management system that performs telephone reception, form processing, etc., there are telephone processing, form processing, work processing, and break processing as processing, and the priority order is as follows.
P1. Telephone processing P2. Form processing P3. Work process P4. Rest processing In addition, as for the state that the processing can take, there are “incoming call” and “answering phone” for telephone processing, and “incoming form” and “form processing” for form processing, Only “break” and the work process is only “work”.
[0040]
Since it is necessary to define the state before the system is operated, the priority and state are defined in pairs in the state definition management unit 24 as follows.
P1 / call incoming, telephone reception P2 / form reception, form processing P3 / break, work P4 / others An example of the case where the same priority state occurs in the process 11 will be described. Assume that the numbers in the circles in FIG. 7 match the numbers in the circles in the following description.
[0041]
(1) In the operation stage, when the process A11 is in a state of “telephone reception”, the state monitoring unit 22 detects this state of the process A11 and notifies the state determination unit 21 “process identifier = process A”, “ Notification is made that “the situation has occurred = telephone reception”.
(2) The state determination unit 21 is a group of states having the same priority (P1) as the “telephone reception” from the state definition management unit 24 using the state (telephone reception) as a key. Response "].
[0042]
(3) Next, the state determination unit 21 is a state set of the process A11 by using the process identifier (process A) of the process A11 as a key ["phone call", "form processing"]
Is acquired from the state holding unit 23.
[0043]
(4) As a result, in the state set acquired from the state holding unit 23, “call reception” is duplicated, so that “call reception” which is the state acquired from the state definition management unit 24 from the state set is displayed. Delete and create a new state set "form processing"
And
[0044]
(5) Next, “telephone reception”, which is the state notified from the state monitoring unit 22, is added to the state holding unit 23 in the new state set,
["Phone answering", "Form processing"]
A new state set.
[0045]
(6) The new state set is set in the state holding unit 23, and the state definition management unit 24 sets the state with the highest priority among the new state sets, “telephone reception”, as the state of this process A11. The unit 21 can recognize it. The result is shown in FIG.
[0046]
Next, a case where a low priority state occurs in the process D11 will be described. FIG. 9 is a diagram illustrating an example in which a low priority state occurs in a process according to an embodiment of the present invention. The numbers in circles in the figure and the numbers in circles in the following description are the same.
[0047]
(1) A state of “work” occurs in the process D11.
(2) The state monitoring unit 22 detects the state “work” of the process D11 and notifies the state determination unit 21 of “process identifier = process D” and “occurred state = work”.
(3) The state determination unit 21 acquires from the state definition unit 24 the state groups “break” and “work” having the same priority as the work.
[0048]
(4) Next, “telephone reception” which is the state set of the process D11 is acquired from the state holding unit 23, and there is no overlap with the state acquired from the state definition unit 24. And add a new state set ("telephone answer""work")
And
[0049]
(5) The new state set is set in the state holding unit 23, and the state determination unit 21 keeps the state of the process D11 as “telephone reception” according to the priority order. The result is shown in FIG.
FIG. 11 shows an example of using the recognition state when the management method of the present invention is applied. The processing in the figure is performed in the order of execution from the bottom, and the portion where the bar graph overlaps with respect to time is a state set, and the state recognized in the time column is represented. By counting this time, it is possible to use it for total management according to the state of the system.
[0050]
The present invention is not limited to the above-described embodiments, and various modifications and applications can be made within the scope of the claims.
[0051]
【The invention's effect】
As described above, according to the present invention, the process can manage the state of the process as a result only by repeating the addition and deletion of the state for each sub-process in the process.
[0052]
In addition, since the priority is provided to the state, the process to be managed is uniquely determined with the highest priority in the state of its own process, so that it becomes easy to determine the state of the process.
[Brief description of the drawings]
FIG. 1 is a diagram for explaining the principle of the present invention.
FIG. 2 is a principle configuration diagram of the present invention.
FIG. 3 is a configuration diagram of an execution state management system according to the present invention.
FIG. 4 is a flowchart of the operation when a new state occurs in the process of the present invention.
FIG. 5 is a flowchart of the operation when the process of the present invention ends the state.
FIG. 6 is a flowchart of a state recognition operation for a process in a state determination unit according to the present invention.
FIG. 7 is a first example of an execution state management system according to an embodiment of the present invention.
FIG. 8 is a diagram illustrating a processing result in the first example of the execution state management system according to the embodiment of this invention;
FIG. 9 is a diagram illustrating an example in which a low priority state occurs in a process according to an embodiment of the present invention.
FIG. 10 is a diagram showing a processing result when a low priority state occurs in a process according to an embodiment of the present invention.
FIG. 11 is a diagram illustrating a usage example of a recognition state when the management method of the present invention is applied.
[Explanation of symbols]
DESCRIPTION OF SYMBOLS 10 Management object, Process group 11 Process 20 State management part 21 State determination part, State determination means 22 State monitoring part, State monitoring means 23 State holding part, State set holding means 24 State definition management part, State definition storage means

Claims

A status monitoring step for monitoring the execution status of processes that process jobs in parallel and detecting changes in the status of the processes;
In the state monitoring step, when it is detected that a new state has occurred in the process, the state notified by referring to the information of the state definition storage means holding the state and the priority corresponding to the state, and A state group having the same priority is acquired, and based on the process identifier of the process, a state set holding unit that holds the process identifier and the state set is searched for each process, the state set is acquired, and the state group and the state A state determination step for uniquely determining the notified state and the state having the highest priority from the state set as the state of the process by comparison with the state set;
Execution status managing concurrency process and performs.

In the state determination step,
Based on the changed state of the process detected in the state monitoring step, the state definition storage means is searched and a state comprising the state of the process, the priority corresponding to the state, and the state of the same priority A priority search step for obtaining a group;
A state set search step of searching the state set holding means based on a process identifier of the process whose state detected in the state monitoring step has changed, and acquiring a state set corresponding to the process identifier;
If a state included in the state group searched by the priority order search step overlaps with an element of the state set acquired by the state set search step, the overlapping state is deleted from the state set. Then, a first state set update step of adding the state detected in the state monitoring step and storing it in the state set holding means as a new state set;
The execution state management method for a parallel processing process according to claim 1, wherein a first state recognition step is performed in which a state having the highest priority in the new state set is a state of the process .

In the state determination step,
When the end of the process state is detected in the state monitoring step, the state set holding unit deletes the completed state from the state set corresponding to the process and creates a new state set in the state set holding unit. Delete step to store;
The execution of the parallel processing process according to claim 1 , wherein a second state recognition step is performed by referring to the state definition storage means and setting a state having the highest priority in the new state set as a state of the process. State management method.

In the state determination step,
The priority of the state definition storage unit corresponding to the state detected in the state monitoring step is acquired, and the state of the process detected in the state monitoring step is stored in the state set holding unit. A second state set update step of adding the state of the notified process to the state set held in the state set holding means when the priority is high by any element;
The execution state management method of the parallel processing process according to claim 1 , wherein a third state recognition step of setting the current state of the process as the state of the notified process is performed.

In the state determination step,
The priority of the state definition storage means corresponding to the state detected in the state monitoring step is acquired, and the notified state is the state set element held in the state set holding means and the priority is If they are the same, a second state set update step of deleting the previous state held in the state set holding unit and storing the state of the notified process in the state set holding unit;
The execution state management method for a parallel processing process according to claim 1 , wherein a fourth state recognition step is performed in which a current state of the process is set to a state of the notified process.

In the state determination step,
The priority of the state definition storage means corresponding to the state detected in the state monitoring step is acquired, and the notified state has a lower priority than the elements of the state set held in the state set holding means A fourth state set update step of adding the state of the notified process to the state set holding means;
The execution state management method of the parallel processing process according to claim 1 , wherein a fifth state recognition step of setting the current state of the process to a state before the notification of the state of the process is performed.

A group of processes to be managed to perform parallel processing, and
State monitoring means for detecting a change in the state of the process;
State set holding means for holding a process identifier and a state set for each process;
State definition storage means for holding states and priorities corresponding to the states;
When it is notified from the state monitoring means that a new state has occurred in the process, referring to the information in the state definition storage means, a state group having the same priority as the notified state is obtained, The state set holding means is searched by the process identifier of the process, the state set is obtained, and the state having the highest priority is selected from the notified state and the state set by comparing the state group and the state set. State determining means for uniquely determining the state of the process ;
An execution state management system for a parallel processing process, comprising:

The state determining means includes
Based on the changed state of the process notified from the state monitoring unit, the state definition storage unit is searched, and a state composed of the state of the process, the priority corresponding to the state, and the state of the same priority A priority search means for acquiring a group ;
A state set search unit that searches the state set holding unit based on a process identifier of the process whose state notified from the state monitoring unit is changed, and acquires a state set corresponding to the process identifier;
If the state included in the state group searched by the priority order search unit overlaps the state set acquired by the state set search unit, the overlapping state is deleted from the state set. A first state set updating means for adding the state of the notified process and storing it in the state set holding means as a new state set;
The new state set highest priority execution state management system concurrency process of claim 7, including a first state recognition means for high state of the process state in the.

The state determining means includes
When the end of the process state is notified from the state monitoring unit, the state set holding unit deletes the completed state from the state set corresponding to the process and creates a new state set to the state set holding unit. Delete means to store;
8. The execution of a parallel processing process according to claim 7, further comprising: a second state recognition unit that refers to the state definition storage unit and sets a state having the highest priority in the new state set as a state of the process. State management system.

The state determining means includes
The priority of the state definition storage unit corresponding to the state notified by the state monitoring unit is acquired, and the state of the process notified from the state monitoring unit is stored in the state set holding unit . A second state set updating means for adding the state of the notified process to the state set held in the state set holding means when the priority is higher than the element ;
Execution state management system concurrency process of claim 7, including a current state and a third state recognition means for the state of the notified process of said process.

The state determining means includes
Gets the priority of the state definition storage means corresponding to the state of being notified by the state monitoring means, the notification state is, elements and the priority of the set of states held in the state set storage means If they are the same, a second state set update unit that deletes the previous state held in the state set holding unit and stores the state of the notified process in the state set holding unit;
Execution state management system concurrency process of claim 7, including a current state and a fourth state recognition means for the state of the notified process of said process.

The state determining means includes
The priority of the state definition storage unit corresponding to the state notified from the state monitoring unit is acquired, and the notified state has a lower priority than the elements of the state set held in the state set holding unit A fourth state set update unit for adding the state of the notified process to the state set holding unit;
8. The execution state management system for a parallel processing process according to claim 7, further comprising fifth state recognition means for setting the current state of the process to a state before notification of the state of the process.