JP6786975B2 - Job processing system, job processing device, job processing method, and program - Google Patents
Job processing system, job processing device, job processing method, and programDownload PDFInfo
- Publication number
- JP6786975B2 JP6786975B2JP2016176813AJP2016176813AJP6786975B2JP 6786975 B2JP6786975 B2JP 6786975B2JP 2016176813 AJP2016176813 AJP 2016176813AJP 2016176813 AJP2016176813 AJP 2016176813AJP 6786975 B2JP6786975 B2JP 6786975B2
- Authority
- JP
- Japan
- Prior art keywords
- job
- processing
- information
- processing device
- execution
- 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.)
- Expired - Fee Related
Links
Images
Landscapes
- Facsimiles In General (AREA)
Description
Translated fromJapanese 本発明は、ジョブ処理システム、ジョブ処理装置、ジョブ処理方法、及びプログラム
に関する。The present invention relates to a job processing system, a job processing apparatus, a job processing method, and a program.
例えば、画像形成装置によって文書からスキャンされた画像データや、他の手段によって入力されたデータ等に関して、予め定義されたワークフローに基づいてワークフロー処理（以下、ジョブと呼ぶ）を実行可能なジョブ処理システムが知られている。 For example, a job processing system capable of executing workflow processing (hereinafter referred to as a job) based on a predefined workflow for image data scanned from a document by an image forming apparatus, data input by other means, and the like. It has been known.
また、ジョブを複数のジョブ処理装置へ振り分ける負荷分散装置を有し、実行が要求された複数のジョブをジョブ単位で複数のジョブ処理装置に振り分けて処理するジョブ処理システムが知られている（例えば、特許文献１参照）。 Further, there is known a job processing system that has a load distribution device that distributes jobs to a plurality of job processing devices and distributes a plurality of jobs requested to be executed to a plurality of job processing devices for each job (for example). , Patent Document 1).
特許文献１に開示されたジョブ処理システムでは、複数の処理を組合せたワークフロー処理は、ワークフローの定義によって、処理に要する時間が異なるため、負荷分散装置がジョブ単位でワークフロー処理をジョブ処理装置へ振り分けることでは、ジョブ処理システム全体の負荷を効率良く分散することは困難である。 In the job processing system disclosed in
本発明の実施の形態は、上記の問題点に鑑みてなされたものであって、ワークフローに基づいてワークフロー処理を実行するジョブ処理システムにおいて、ジョブ処理システム全体で効率良く複数のワークフロー処理を分散処理することができるようにする。 An embodiment of the present invention has been made in view of the above problems, and in a job processing system that executes workflow processing based on a workflow, a plurality of workflow processes are efficiently distributed in the entire job processing system. To be able to.
上記課題を解決するため、本発明の一実施形態に係るジョブ処理システムは、１以上の処理が定義されたワークフローに基づく処理の実行単位であるジョブを実行する複数のジョブ処理装置がネットワークを介して接続されるジョブ処理システムであって、前記ジョブ処理装置は、前記ジョブを受け付けるジョブ受付部と、当該ジョブ処理装置が受け付けた前記ジョブである第１のジョブの実行に関するジョブ情報と、当該ジョブ処理装置とは異なる他のジョブ処理装置から送信され、当該他のジョブ処理装置が受け付けた前記ジョブである第２のジョブの実行に関するジョブ情報とをジョブ情報記憶部に記憶して管理するジョブ情報管理部と、前記第１のジョブが受け付けられたことに応じて、前記第１のジョブのジョブ情報を前記他のジョブ処理装置に通知する通知部と、前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されている場合、当該第１のジョブを実行し、前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを実行するジョブ実行部と、を有する。 In order to solve the above problems, in the job processing system according to the embodiment of the present invention, a plurality of job processing devices that execute jobs, which are execution units of processing based on a workflow in which one or more processes are defined, are connected via a network. The job processing device is a job processing system connected to the job processing system, and the job processing device includes a job receiving unit that accepts the job, job information related to execution of the first job that is the job received by the job processing device, and the job. Job information that is sent from another job processing device different from the processing device and is stored and managed in the job information storage unit with job information related to the execution of the second job, which is the job received by the other job processing device. Processing is started in the management unit, the notification unit that notifies the other job processing device of the job information of the first job in response to the acceptance of the first job, and the job information storage unit. When the job information of the first job that has not been executed is stored, the first job is executed, and the job information of the first job whose processing has not been started is stored in the job information storage unit. If not, the job information storage unit has a job execution unit that executes the second job based on the job information of the second job whose processing has not been started.
本発明の一実施形態によれば、ワークフローに基づいてワークフロー処理を実行するジョブ処理システムにおいて、ジョブ処理システム全体で効率良く複数のワークフロー処理を分散処理することができるようになる。 According to one embodiment of the present invention, in a job processing system that executes workflow processing based on a workflow, it becomes possible to efficiently perform distributed processing of a plurality of workflow processes in the entire job processing system.
以下に、本発明の実施の形態について、添付の図面を参照して説明する。 Hereinafter, embodiments of the present invention will be described with reference to the accompanying drawings.
＜システムの構成＞
図１は、一実施形態に係るジョブ処理システムのシステム構成の一例を示す図である。ジョブ処理システム１００は、例えば、インターネット等のネットワーク１０７に接続される複数のジョブ処理装置であるジョブ処理装置Ａ１０１−１、ジョブ処理装置Ｂ１０１−２、及びジョブ処理装置Ｃ１０１−３を含む。なお、以下の説明の中で、複数のジョブ処理装置のうち、任意のジョブ処理装置を示す場合、「ジョブ処理装置１０１」を用いる。また、図１に示すジョブ処理装置１０１の数は一例である。ジョブ処理装置１０１の数は、２つ以上の他の数であっても良い。<System configuration>
FIG. 1 is a diagram showing an example of a system configuration of a job processing system according to an embodiment. The
図１の例では、ジョブ処理装置Ａ１０１−１は、地域Ａ１０４に設けられており、地域Ａ１０４内のＬＡＮ（Local Area Network）１０３Ａを介して、複数の画像形成装置Ａ１０２−１、及び画像形成装置Ｂ１０２−２と接続されている。なお、地域Ａは、ジョブ処理装置Ａ１０１−１を含むグループの一例である。ジョブ処理装置Ａ１０１−１を含むグループは、例えば、拠点、ビル、フロア、部署等であっても良い。 In the example of FIG. 1, the job processing device A101-1 is provided in the area A104, and the plurality of image forming devices A102-1 and the image forming device are provided via the LAN (Local Area Network) 103A in the area A104. It is connected to B102-2. The area A is an example of a group including the job processing device A101-1. The group including the job processing device A101-1 may be, for example, a base, a building, a floor, a department, or the like.
また、ジョブ処理装置Ｂ１０１−２は、地域Ｂ１０５に設けられており、地域Ｂ１０５内のＬＡＮ１０３Ｂを介して、複数の画像形成装置Ｃ１０２−３、及び画像形成装置Ｄ１０２−４接続されている。なお、地域Ｂは、ジョブ処理装置Ｂ１０１−２を含むグループの一例である。 Further, the job processing device B101-2 is provided in the area B105, and is connected to the plurality of image forming devices C102-3 and the image forming device D102-4 via the
さらに、ジョブ処理装置Ｃ１０１−３は、地域Ｃ１０６に設けられており、地域Ｃ１０６内のＬＡＮ１０３Ｃを介して、複数の画像形成装置Ｅ１０２−５、及び画像形成装置Ｆ１０２−６接続されている。なお、地域Ｃは、ジョブ処理装置Ｃ１０１−３を含むグループの一例である。 Further, the job processing device C101-3 is provided in the area C106, and is connected to the plurality of image forming devices E102-5 and the image forming device F102-6 via the
図１の例では、地域ＣのＬＡＮ１０３には、例えば、ＰＣ（Personal Computer）、タブレット端末、又はスマートフォン等の情報端末１０８が接続されている。このように、各地域のＬＡＮには、画像形成装置１０２に加えて（又は代えて）情報端末１０８が接続されていても良い。 In the example of FIG. 1, an
上記の構成において、ジョブ処理システム１００は、例えば、画像形成装置１０２によって入力された画像データに対して、利用者が作成（又は選択）したワークフローに基づいて処理を行う。 In the above configuration, the
ワークフローとは、例えば、画像データに対する、入力処理、画像変換処理、出力処理等の各処理（プラグイン）を組合せて、所定の処理を定義したものである。なお、以下の説明の中で、ワークフローで指定された所定の処理の実行単位をジョブと呼ぶ。 The workflow defines, for example, a predetermined process by combining each process (plug-in) such as input process, image conversion process, and output process for image data. In the following description, the execution unit of a predetermined process specified in the workflow is called a job.
例えば、各画像形成装置１０２は、画像形成装置１０２に入力された画像データ（ジョブのデータ）と、実行するワークフローの情報（ジョブの情報）とを、同じ地域内のジョブ処理装置１０１に送信する。 For example, each
ジョブ処理システム１００は、複数の画像形成装置１０２から、各地域のジョブ処理装置１０１に送信された複数のジョブを、複数のジョブ処理装置１０１で分散して処理を実行する。例えば、ジョブ処理装置Ａ１０１−１は、ジョブＡを実行中に、画像形成装置Ａ１０２−１から他のジョブＢを受付すると、受付したジョブＢの情報を自装置のジョブキュー（待ち行列）に記憶し、ジョブＢのデータを記憶部に記憶する。 The
また、ジョブ処理装置Ａ１０１−１は、ジョブ処理装置Ａ１０１−１が受付したジョブＢの情報を、他のジョブ処理装置Ｂ１０１−２、及びジョブ処理装置Ｃ１０１−３に通知する。 Further, the job processing device A101-1 notifies the other job processing device B101-2 and the job processing device C101-3 of the information of the job B received by the job processing device A101-1.
通知を受けた他のジョブ処理装置Ｂ１０１−２、及びジョブ処理装置Ｃ１０１−３は、ジョブ処理装置Ａ１０１−１が受付したジョブＢの情報を、それぞれ、自装置のジョブキューに記憶する。 The other job processing device B101-2 and the job processing device C101-3 that have received the notification store the information of the job B received by the job processing device A101-1 in the job queue of their own device, respectively.
このように、各ジョブ処理装置１０１は、自装置で受付した処理待ちのジョブの情報を自装置のジョブキューに記憶して管理すると共に、自装置で受付した処理待ちのジョブの状態が変化すると、変化したジョブの情報を他のジョブ処理装置１０１に通知する。 In this way, each job processing device 101 stores and manages information on jobs waiting to be processed received by its own device in the job queue of its own device, and changes the state of jobs waiting to be processed received by its own device. , Notify the other job processing device 101 of the changed job information.
これにより、ジョブ処理システム１００の各ジョブ処理装置１０１は、ジョブ処理システム１００全体で処理待ちとなっているジョブの情報を、ジョブキューに記憶して管理することができる。 As a result, each job processing device 101 of the
また、各ジョブ処理装置１０１は、ジョブキューに記憶されているジョブのうち、自装置で受付し、自装置でジョブのデータを記憶しているジョブを優先的に実行する。また、各ジョブ処理装置１０１は、ジョブキューに、自装置で受付したジョブがない場合、ジョブキューに記憶された、他のジョブ処理装置で受付したジョブを取得し、実行する。 Further, each job processing device 101 preferentially executes a job stored in the job queue, which is received by its own device and whose job data is stored in its own device. Further, each job processing device 101 acquires and executes a job received by another job processing device stored in the job queue when there is no job received by the own device in the job queue.
これにより、本実施形態によれば、複数のジョブ処理装置１０１がネットワークを介して接続されるジョブ処理システム１００において、ジョブ処理システム全体で効率良く複数のジョブを分散処理することができるようになる。 As a result, according to the present embodiment, in the
なお、ジョブ処理システム１００が実行するジョブは、画像形成装置１０２から受付した画像データに対する処理に限られず、例えば、情報端末１０８から受付した文書データに対する処理等であっても良い。 The job executed by the
＜ハードウェア構成＞
（ジョブ処理装置、及び情報端末のハードウェア構成）
図１に示すジョブ処理装置１０１、及び情報端末１０８は、一般的なコンピュータの構成を有しているので、ここでは、一般的なコンピュータのハードウェア構成について説明する。<Hardware configuration>
(Hardware configuration of job processing device and information terminal)
Since the job processing device 101 and the
図２は、一実施形態に係るコンピュータのハードウェア構成例を示す図である。コンピュータ２００は、例えば、ＣＰＵ（Central Processing Unit）２０１、ＲＡＭ（Random Access Memory）２０２、ＲＯＭ（Read Only Memory）２０３、ストレージ装置２０４、ネットワークＩ／Ｆ２０５、入力装置２０６、表示装置２０７、外部Ｉ／Ｆ２０８、及びバス２０９等を有する。 FIG. 2 is a diagram showing an example of a computer hardware configuration according to an embodiment. The
ＣＰＵ２０１は、ＲＯＭ２０３やストレージ装置２０４等に格納されたプログラムやデータをＲＡＭ２０２上に読み出し、処理を実行することで、コンピュータ２００の各機能を実現する演算装置である。ＲＡＭ２０２は、ＣＰＵ２０１のワークエリア等として用いられる揮発性のメモリである。ＲＯＭ２０３は、電源を切ってもプログラムやデータを保持することができる不揮発性のメモリである。 The
ストレージ装置２０４は、例えば、ＨＤＤ（Hard Disk Drive）や、ＳＳＤ（Solid State Drive）等の大容量の記憶装置であり、ＯＳ、アプリケーションプログラム、各種のデータ等を記憶する。ネットワークＩ／Ｆ２０５は、コンピュータ２００をネットワーク１０７等に接続するための通信インタフェースである。 The
入力装置２０６は、例えば、マウス等のポインティングデバイスや、キーボード等の入力デバイスであり、コンピュータ２００に各操作信号を入力するために用いられる。表示装置２０７はディスプレイ等の表示デバイスであり、コンピュータ２００による処理結果等を表示する。 The
外部Ｉ／Ｆ２０８は、外部装置とのインタフェースである。外部装置には、記録媒体２１０等が含まれる。 The external I /
バス２０９は、上記の各構成要素に接続され、アドレス信号、データ信号、及び各種制御信号等を伝送する。 The
（画像形成装置のハードウェア構成）
図３は、一実施形態に係る画像形成装置１０２のハードウェア構成例を示す図である。(Hardware configuration of image forming apparatus)
FIG. 3 is a diagram showing a hardware configuration example of the
画像形成装置１０２は、コントローラ３１０、操作パネル３２０、通信Ｉ／Ｆ３３０、プロッタ３４０、スキャナ３５０、及びファクスコントロールユニット（以下、ＦＣＵと呼ぶ）３６０等を有する。 The
コントローラ３１０は、ＣＰＵ３１１、ＲＡＭ３１２、ＲＯＭ３１３、ＮＶＲＡＭ（Non-Volatile RAM）３１４、及びＨＤＤ３１５等を含む。 The
ＲＯＭ３１３は、各種プログラムやデータを格納している不揮発性の記憶装置である。ＲＡＭ３１２は、プログラムやデータを一時保持する揮発性の記憶装置である。ＮＶＲＡＭ３１４は、例えば設定情報等を格納する書き込み可能な不揮発性の記憶装置である。ＨＤＤ３１５は、各種プログラムやデータを格納している大容量の記憶装置である。 The
ＣＰＵ３１１は、ＲＯＭ３１３、ＮＶＲＡＭ３１４、ＨＤＤ３１５等からプログラムやデータ、設定情報等をＲＡＭ３１２上に読み出し、処理を実行することで、画像形成装置１０２の全体の制御や機能を実現する演算装置である。 The
操作パネル３２０は、ユーザからの入力を受付する入力部と、表示を行う表示部とを備えている。通信Ｉ／Ｆ３３０は、画像形成装置１０２をＬＡＮ１３０等のネットワークに接続するインタフェースである。これにより、画像形成装置１０２は、ジョブ処理装置１０１等と通信を行うことができる。 The
プロッタ３４０は、印刷データを印刷する印刷装置である。スキャナ３５０は、原稿等を読み取る読取装置である。ＦＣＵ３６０は、ファクスデータの送受信を行う。 The
＜機能構成＞
図４は、一実施形態に係るジョブ処理システムの機能構成図である。ジョブ処理システム１００は、ネットワーク１０７を介して互いに通信可能に接続されるジョブ処理装置Ａ１０１−１、ジョブ処理装置Ｂ１０１−２、及びジョブ処理装置Ｃ１０１−３を含む。<Functional configuration>
FIG. 4 is a functional configuration diagram of the job processing system according to the embodiment. The
なお、図４において、ジョブ処理装置Ｂ１０１−２、及びジョブ処理装置Ｃ１０１−３は、ジョブ処理装置Ａ１０１−１と同様の機能構成を有しているものとする。また、図４に示すジョブ処理装置１０１の数は一例であり、ジョブ処理システム１００に含まれる複数のジョブ処理装置１０１の数は、２台以上の他の数であっても良い。 In FIG. 4, it is assumed that the job processing device B101-2 and the job processing device C101-3 have the same functional configuration as the job processing device A101-1. Further, the number of job processing devices 101 shown in FIG. 4 is an example, and the number of a plurality of job processing devices 101 included in the
ジョブ処理装置１０１は、通信部４０１、ジョブ受付部４０２、ジョブデータ管理部４０３、ジョブ情報管理部４０４、更新情報通知部４０５、ジョブ実行部４０６、実行ジョブ決定部４０７、及び処理コスト算出部４０８等を有する。また、ジョブ処理装置１０１は、ジョブデータ記憶部４１１、ジョブ情報記憶部４１２、ワークフロー情報記憶部４１３、コスト情報記憶部４１４、及び通信速度情報記憶部４１５を有する。 The job processing device 101 includes a
通信部４０１は、ネットワーク１０７を介して、他のジョブ処理装置１０１と通信する手段であり、例えば、図２のネットワークＩ／Ｆ２０５、及び図２のＣＰＵ２０１で実行されるプログラム等によって実現される。 The
ジョブ受付部４０２は、画像形成装置１０２、又は情報端末１０８等の端末装置から、処理対象となるデータに、指定された１つ以上の処理を実行するジョブを受付する手段であり、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。ジョブ受付部４０２が受付するジョブには、例えば、画像形成装置１０２に入力された画像データ（ジョブのデータ）、及び実行するワークフローの情報（ジョブの情報）等が含まれる。 The
ジョブデータ管理部４０３は、ジョブ受付部４０２が受付したジョブのデータ（例えば、画像データ、文書データ等）を、ジョブデータ記憶部４１１に記憶して、管理する手段であり、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。また、ジョブデータ管理部４０３は、他のジョブ処理装置１０１からのジョブのデータの取得要求に応じて、ジョブデータ記憶部４１１に記憶したジョブのデータを提供する処理も行う。 The job
ジョブ情報管理部４０４は、ジョブ処理装置１０１が受け付けたジョブである第１のジョブの実行に関するジョブ情報と、他のジョブ処理装置１０１から送信され、他のジョブ処理装置が受け付けたジョブである第２のジョブの実行に関するジョブ情報とを、ジョブ情報記憶部４１２に記憶して、管理する。ジョブ情報管理部４０４は、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。 The job
なお、以下の説明の中で、ジョブ処理装置１０１が、自装置でジョブのデータを受け付けて管理するジョブを「第１のジョブ」と呼び、他のジョブ処理装置１０１が、ジョブのデータを受け付けて管理するジョブを「第２のジョブ」と呼ぶ。 In the following description, a job in which the job processing device 101 receives and manages job data in its own device is referred to as a "first job", and another job processing device 101 accepts job data. The job to be managed is called a "second job".
ジョブ情報管理部４０４が、ジョブ情報記憶部４１２に記憶して、管理するジョブキューの一例のイメージを図５（ａ）に示す。 FIG. 5A shows an image of an example of a job queue stored and managed by the job
図５（ａ）の例では、ジョブキュー５０１には、「ジョブＩＤ」、「ジョブの要求元」、「ジョブデータのサイズ」、「実行するワークフロー」、「ジョブを処理するジョブ処理装置」、「ジョブの状態」、「ジョブの開始日時」等の情報が含まれる。 In the example of FIG. 5A, the
「ジョブＩＤ」の情報は、ジョブを識別するための識別情報であり、例えば、ジョブを受付したジョブ処理装置１０１のジョブ情報管理部４０４がユニークな値を付与する。図５（ａ）の例では、ジョブＩＤの先頭の文字は、ジョブを受付したジョブ処理装置１０１に対応している。例えば、「Ａ」は、ジョブ処理装置Ａ１０１−１が受付したジョブであり、「Ｃ」は、ジョブ処理装置Ｃ１０１−３が受付したジョブである。 The information of the "job ID" is identification information for identifying a job, and for example, the job
ジョブＩＤは、例えば、ジョブデータ管理部４０３が管理するジョブデータと、ジョブ情報管理部４０４が管理するジョブ情報とを対応付けるキーとして用いられる。この場合、ジョブ情報管理部４０４は、ジョブＩＤを用いて、ジョブデータ管理部４０３が管理するジョブデータの中から、ジョブ情報に対応するジョブデータを特定し、取得することができる。 The job ID is used, for example, as a key for associating the job data managed by the job
或いは、第１のジョブを受け付けて管理するジョブ処理装置１０１のジョブ情報管理部４０４は、第１のジョブのジョブＩＤと、当該第１のジョブのジョブデータの保存先とを対応付けて管理しておくものであっても良い。 Alternatively, the job
「ジョブの要求元」の情報は、ジョブの要求元の装置（例えば、画像形成装置１０２、情報端末１０８等）の名前や、識別情報等、ジョブを要求した装置を特定するための情報である。 The "job request source" information is information for identifying the device that requested the job, such as the name of the device requesting the job (for example, the
「ジョブを管理するジョブ処理装置」の情報は、ジョブを受付し、ジョブのデータをジョブデータ記憶部４１１に記憶して、管理しているジョブ処理装置１０１を特定するための情報（名前、識別情報等）である。この情報により、ジョブ処理装置１０１は、各ジョブが、自装置でジョブのデータを管理する第１のジョブであるか、他のジョブ処理装置１０１がジョブのデータを管理する第２のジョブであるかを判断することができる。 The information of the "job processing device that manages the job" is information (name, identification) for receiving the job, storing the job data in the job
「ジョブデータのサイズ」の情報は、ジョブのデータ（例えば、画像データ）の大きさを示す情報である。 The information of "job data size" is information indicating the size of job data (for example, image data).
「実行するワークフロー」の情報は、実行するワークフローを特定するための情報（例えば、ワークフローの名前、識別情報等）である。 The information of "workflow to be executed" is information for specifying the workflow to be executed (for example, workflow name, identification information, etc.).
「ジョブを処理するジョブ処理装置」の情報は、ジョブキュー５０１に記憶されているジョブを処理するジョブ処理装置１０１が決定されたときに、決定されたジョブ処理装置１０１を特定するための情報（名前、識別情報等）が記憶される。 The information of the "job processing device for processing a job" is information for identifying the determined job processing device 101 when the job processing device 101 for processing the job stored in the
「ジョブの状態」は、ジョブの状態を示す情報であり、例えば、まだジョブを処理するジョブ処理装置が決まっていない「処理待ち」の状態や、既にジョブを処理するジョブ処理装置１０１が決定した「処理中」の状態等の情報が記憶される。 The "job status" is information indicating the job status. For example, the "waiting for processing" status in which the job processing device for processing the job has not yet been determined, or the job processing device 101 for processing the job has already been determined. Information such as the "processing" status is stored.
「ジョブの開始日時」の情報は、例えば、「ジョブの状態」が、「処理待ち」から「処理中」に更新された日時等の情報である。 The "job start date and time" information is, for example, information such as the date and time when the "job status" is updated from "waiting for processing" to "processing".
例えば、図５（ａ）に示すジョブキュー５０１において、ジョブＩＤ「Ａ３」のジョブを処理するジョブ処理装置１０１が、ジョブ処理装置Ｃ１０１−３に決定されると、ジョブキュー５０１は、例えば、図５（ｂ）に示すように更新される。 For example, in the
図５（ｂ）の例では、「ジョブを処理するジョブ処理装置」にジョブを処理するジョブ処理装置Ｃ１０１−３の情報が記憶されて、「ジョブの状態」が処理中となり、「ジョブの開始日時」が記録されている。 In the example of FIG. 5B, the information of the job processing device C101-3 that processes the job is stored in the "job processing device that processes the job", the "job status" is being processed, and the "job start" is set. The date and time is recorded.
ジョブ情報管理部４０４は、ジョブ処理装置１０１がジョブのデータを管理する第１のジョブの情報、及び他のジョブ処理装置１０１から通知される第２のジョブの情報を、例えば、図５（ａ）、（ｂ）に示すようなジョブキュー５０１に記憶して、管理する。 The job
なお、ジョブキュー５０１は、待ち行列となっており、新たに受付されたジョブは、例えば、ジョブキュー５０１の下側に順次に追加される。また、ジョブキュー５０１では、基本的に、先にジョブキュー５０１に記憶されたジョブ、すなわち、ジョブキュー５０１の上側に記憶されたジョブから順に実行される。ジョブの実行が完了したジョブは、ジョブキュー５０１から削除される。 The
また、ジョブデータ管理部４０３は、他のジョブ処理装置１０１から、ジョブキュー５０１に記憶した第２のジョブの情報が変更されたことを示す変更情報を受付すると、ジョブキュー５０１に記憶した第２のジョブの情報を更新する。 Further, when the job
さらに、ジョブデータ管理部４０３は、ジョブ処理装置１０１が、ジョブのデータを管理する第１のジョブの実行を要求する実行要求を受付したとき、受付した第１のジョブの「ジョブの状態」が処理待ちである場合、実行を許可する許可情報を要求元に返信する。 Further, when the job processing device 101 receives an execution request requesting execution of the first job that manages the job data, the job
さらにまた、ジョブデータ管理部４０３は、ジョブ処理装置１０１が、ジョブのデータを管理する第１のジョブの実行を要求する実行要求を受付したとき、受付した第１のジョブの「ジョブの状態」が処理中である場合、実行を拒否する拒否情報を要求元に返信する。 Furthermore, when the job processing device 101 receives an execution request requesting execution of the first job that manages the job data, the job
図４に戻り、ジョブ処理装置１０１の機能構成の説明を続ける。 Returning to FIG. 4, the description of the functional configuration of the job processing device 101 will be continued.
更新情報通知部４０５は、ジョブ情報管理部４０４が管理する第１のジョブの情報が変更された場合、変更された第１のジョブの情報を、他のジョブ処理装置１０１に通知する。更新情報通知部４０５は、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。 When the information of the first job managed by the job
例えば、更新情報通知部４０５は、ジョブ情報管理部４０４が管理するジョブキュー５０１に第１のジョブの情報が追加された場合、追加された第１のジョブの情報を含む第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。また、更新情報通知部４０５は、ジョブキュー５０１に記憶された第１のジョブの情報が変更された場合、変更された第１のジョブの情報を含む第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。さらに、また、更新情報通知部４０５は、ジョブキュー５０１に記憶された第１のジョブの情報が削除された場合、第１のジョブの情報が削除されたことを示す第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。 For example, when the information of the first job is added to the
ジョブ実行部４０６は、処理対象となるデータに、ワークフローで指定された１つ以上の処理を含むジョブを実行する手段であり、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。 The
ジョブ実行部４０６は、ジョブ情報記憶部４１２に記憶されたジョブキュー５０１に、処理が開始されていない処理待ち状態の第１のジョブのジョブ情報が記憶されている場合、処理待ち状態の第１のジョブを、順次に実行する。 When the
また、ジョブ実行部４０６は、ジョブキュー５０１に、処理待ち状態の第１のジョブのジョブ情報が記憶されていない場合、ジョブキュー５０１に記憶されている、処理待ち状態の第２のジョブのジョブ情報に基づいて、第２のジョブのデータを取得し、実行する。 If the
例えば、ジョブ実行部４０６は、ジョブキュー５０１に記憶されている第２のジョブの情報に基づいて、第２のジョブのデータを管理している他のジョブ処理装置１０１に、第２のジョブの実行を要求する実行要求を送信する。 For example, the
また、ジョブ実行部４０６は、実行要求を送信した他のジョブ処理装置から、第２のジョブの実行を許可する許可情報を受信した場合、他のジョブ処理装置から、第２のジョブのデータを取得し、実行する。さらに、ジョブ実行部４０６は、第２のジョブの実行が完了すると、第２のジョブの実行が完了したことを示す完了通知を、第２のジョブのデータを取得した他のジョブ処理装置１０１に通知する。 Further, when the
なお、ジョブ実行部４０６は、例えば、図５（ａ）、（ｂ）に示すジョブキュー５０１の「実行するワークフロー」の情報と、ワークフロー情報記憶部４１３に記憶されたワークフロー情報とに基づいて、各ジョブの処理内容を特定することができる。ワークフロー情報記憶部４１３に記憶されたワークフロー情報の一例のイメージを図５（ｃ）に示す。 The
図５（ｃ）の例では、ワークフロー情報５０２には、「ワークフロー」の情報と、「ワークフローの内容」の情報とが含まれる。「ワークフロー」の情報は、ワークフローを特定するための情報（名前、識別情報等）である。「ワークフローの内容」の情報は、各ワークフローで実行される１つ以上の処理の実行順序が記憶されている。 In the example of FIG. 5C, the
例えば、ジョブ実行部４０６は、図５（ａ）に示すジョブキュー５０１において、ジョブＩＤ「Ａ３」のジョブを実行する場合、実行するワークフロー「３」の内容を、ワークフロー情報５０２から取得する。また、ジョブ実行部４０６は、取得したワークフロー「３」の内容に基づいて、ジョブのデータに、画像変換プラグイン、ＯＣＲ（Optical Character Recognition）プラグイン、及びメール送信プラグイン（処理の別の一例）を実行する。なお、以下の説明の中で、ワークフローを構成する各処理をプラグインと呼ぶ場合がある。 For example, when the
実行ジョブ決定部４０７は、ジョブキュー５０１に複数の第２のジョブの情報が記憶されている場合、複数の第２のジョブの中から、ジョブ実行部４０６が実行するジョブを決定する。実行ジョブ決定部４０７は、例えば、図２のＣＰＵ２０１で実行されるプログラムによって実現される。 When the information of a plurality of second jobs is stored in the
一例として、実行ジョブ決定部４０７は、ジョブキュー５０１に記憶された複数の第２のジョブのうち、他のジョブよりも先にジョブキュー５０１に記憶された一のジョブを、ジョブ実行部４０６が実行するジョブを決定する。 As an example, the execution
別の一例として、実行ジョブ決定部４０７は、処理コスト算出部４０８が算出した、複数の第２のジョブの処理コストに基づいて、ジョブ実行部４０６が実行するジョブを決定するものであっても良い。なお、この場合の具体的な決定方法については、第２の実施形態で後述する。 As another example, even if the execution
処理コスト算出部４０８は、コスト情報記憶部４１４に記憶されたプラグインのコスト情報や、通信速度情報記憶部４１５に記憶された他のジョブ処理装置１０１との間の通信速度情報等に基づいて、第２のジョブの処理コストを算出する。なお、処理コストの具体的な算出方法については、第２の実施形態で後述する。 The processing
図６（ａ）は、コスト情報記憶部４１４に予め記憶されたプラグインのコスト情報のイメージを示している。図６（ａ）に示すように、プラグインのコスト情報６０１には、各プラグイン（処理）が、どのくらいの処理コストを要するのか、その重みを予め登録し、記憶した情報である。 FIG. 6A shows an image of the cost information of the plug-in stored in advance in the cost
例えば、画像変換プラグインは、画像変換の処理に、他の処理よりも処理時間を要するため、他のプラグインよりも処理コストが高い「１００」が設定されている。一方、メール送信プラグインは、メールの送信処理は、他の処理よりも短い時間で完了するため、他のプラグインよりも処理コストが低い「１０」が設定されている。 For example, since the image conversion plug-in requires more processing time than the other processing for the image conversion processing, "100" is set, which is higher in processing cost than the other plug-ins. On the other hand, in the mail sending plug-in, since the mail sending process is completed in a shorter time than other processes, "10" is set, which is lower in processing cost than other plug-ins.
図６（ｂ）は、通信速度情報記憶部４１５に予め記憶されたジョブ処理装置１０１間の通信速度情報６０２のイメージを示している。図６（ｂ）に示すように、ジョブ処理装置１０１間の通信速度情報６０２には、各ジョブ処理装置１０１間の通信速度を、予め登録し、記憶した情報である。 FIG. 6B shows an image of the
なお、ジョブ処理装置１０１間の通信速度情報６０２は、例えば、通信部４０１で計測した実際の通信速度を利用するものであっても良い。 The
なお、プラグインのコスト情報６０１、及びジョブ処理装置１０１間の通信速度情報６０２の利用方法については、第２の実施形態で後述する。 The method of using the plug-in
なお、ジョブデータ記憶部４１１、ジョブ情報記憶部４１２、ワークフロー情報記憶部４１３、コスト情報記憶部４１４、及び通信速度情報記憶部４１５は、例えば、図２のストレージ装置２０４、ＲＡＭ２０２等によって実現される記憶手段である。 The job
［第１の実施形態］
＜処理の流れ＞
続いて、第１の実施形態に係るジョブ処理方法の処理の流れについて説明する。[First Embodiment]
<Processing flow>
Subsequently, the processing flow of the job processing method according to the first embodiment will be described.
（ジョブの実行処理）
図７は、第１の実施形態に係るジョブの実行処理の例を示すフローチャートである。この処理は、各ジョブ処理装置１０１におけるジョブの実行処理の例を示している。(Job execution process)
FIG. 7 is a flowchart showing an example of job execution processing according to the first embodiment. This process shows an example of job execution process in each job processing device 101.
ステップＳ７０１において、ジョブ処理装置１０１のジョブ実行部４０６は、ジョブ情報記憶部４１２に記憶されたジョブキュー５０１に、処理待ちの第１のジョブ（第１のジョブの情報）があるか否かを判断する。 In step S701, the
ジョブキュー５０１に処理待ちの第１のジョブがない場合、ジョブ実行部４０６は、処理をステップＳ７０８に移行させる。一方、ジョブキュー５０１に処理待ちの第１のジョブがある場合、ジョブ実行部４０６は、処理をステップＳ７０２に移行させる。 If there is no first job waiting to be processed in the
ここでは、ジョブキュー５０１に記憶されている第１のジョブが１つであるものとして以下の説明を行う。ジョブキュー５０１に複数の第１のジョブが記憶されている場合は、他の第１のジョブより先にジョブキュー５０１に記憶された１つの第１のジョブに対して、以下の処理を実行すれば良い。 Here, the following description will be made assuming that there is only one first job stored in the
ステップＳ７０２に移行すると、ジョブ情報管理部４０４は、ジョブキュー５０１において、処理待ちとなっている第１のジョブの「ジョブの状態」を、「処理待ち」から「処理中」に変更（更新）する。 When the process proceeds to step S702, the job
ステップＳ７０３において、ジョブ処理装置１０１の更新情報通知部４０５は、ジョブキュー５０１に記憶された第１のジョブの情報が更新されたことを示す第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。 In step S703, the update
このとき、他のジョブ処理装置１０１のジョブ情報管理部４０４は、通知されたジョブの更新情報を用いて、自装置のジョブキュー５０１の情報を更新する。 At this time, the job
ステップＳ７０４において、ジョブ実行部４０６は、第１のジョブを実行する。例えば、ジョブ実行部４０６は、図５に示すようなジョブキュー５０１の「実行するワークフロー」の情報と、ワークフロー情報５０２の「ワークフローの内容」に従って、ジョブデータ記憶部４１１に記憶された第１のジョブのデータを処理する。 In step S704, the
ステップＳ７０５において、ジョブ情報管理部４０４は、ジョブ実行部４０６により実行された第１のジョブの情報をジョブキュー５０１から削除し、ジョブデータ管理部４０３は、第１のジョブのデータをジョブデータ記憶部４１１から削除する。 In step S705, the job
ステップＳ７０６において、更新情報通知部４０５は、ジョブキュー５０１から第１のジョブが削除されたことを示す第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。 In step S706, the update
ステップＳ７０７において、ジョブ受付部４０２（又はジョブ実行部４０６）は、第１のジョブの要求元（例えば、画像形成装置１０２）に、第１のジョブが完了したことを通知する。 In step S707, the job receiving unit 402 (or the job executing unit 406) notifies the requester of the first job (for example, the image forming apparatus 102) that the first job has been completed.
一方、ステップＳ７０８に移行すると、ジョブ実行部４０６は、ジョブキュー５０１に処理待ちの第２のジョブ（第２のジョブの情報）があるか否かを判断する。 On the other hand, when the process proceeds to step S708, the
ジョブキュー５０１に処理待ちの第２のジョブがない場合、ジョブ実行部４０６は処理を終了させる。一方、ジョブキュー５０１に処理待ちの第２のジョブがある場合、ジョブ実行部４０６は、処理をステップＳ７０９に移行させる。 If there is no second job waiting to be processed in the
ステップＳ７０９に移行すると、ジョブ実行部４０６は、ジョブキュー５０１に記憶された第２のジョブのデータを管理している他のジョブ処理装置に、第２のジョブの実行を要求する実行要求（要求情報）を送信する。 When the process proceeds to step S709, the
なお、ここでは、ジョブキュー５０１に記憶されている第２のジョブが１つであるものとして以下の説明を行う。第１の実施形態では、ジョブキュー５０１に複数の第２のジョブが記憶されている場合、例えば、他の第２のジョブより先にジョブキュー５０１に記憶された１つの第２のジョブに対して、以下の処理を実行する。 Here, the following description will be given assuming that there is only one second job stored in the
ステップＳ７１０において、ジョブ実行部４０６は、第２のジョブのデータを管理する他のジョブ処理装置１０１から、例えば、所定の時間内に第２のジョブの実行を許可する許可情報を受信したかを判断する。 In step S710, the
所定の時間内に第２のジョブの実行を許可する許可情報を受信しない場合、例えば、第２のジョブ実行を拒否する拒否情報を受信した場合、或いは許可情報も拒否情報も受信できなかった場合、ジョブ実行部４０６は処理を終了させる。 When the permission information for permitting the execution of the second job is not received within a predetermined time, for example, when the refusal information for refusing the execution of the second job is received, or when neither the permission information nor the refusal information can be received. , The
一方、所定の時間内に第２のジョブの実行を許可する許可情報を受信した場合、ジョブ実行部４０６は、処理をステップＳ７１１に移行させる。 On the other hand, when the permission information for permitting the execution of the second job is received within the predetermined time, the
ステップＳ７１１において、ジョブ実行部４０６は、第２のジョブのデータを管理する他のジョブ処理装置１０１から通知される第２のジョブの更新情報が受信されるのを待つ。また、ジョブ情報管理部４０４は、第２のジョブの更新情報が受信された後、受信された第２のジョブの更新情報に従って、ジョブキュー５０１に記憶した第２のジョブの情報を更新する。 In step S711, the
ステップＳ７１２において、ジョブ実行部４０６は、第２のジョブのデータを管理している他のジョブ処理装置１０１から、第２のジョブのデータを取得する。 In step S712, the
ステップＳ７１３において、ジョブ実行部４０６は、第２のジョブを実行する。例えば、ジョブ実行部４０６は、図５に示すようなジョブキュー５０１の「実行するワークフロー」の情報と、ワークフロー情報５０２の「ワークフローの内容」に従って、ステップＳ７１２で取得した第２のジョブのデータを処理する。 In step S713, the
ステップＳ７１４において、ジョブ実行部４０６は、第２のジョブが完了したことを示す完了情報を、第２のジョブを管理している他のジョブ処理装置１０１に通知する。 In step S714, the
ステップＳ７１５において、ジョブ実行部４０６は、第２のジョブのデータを管理する他のジョブ処理装置１０１から通知される第２のジョブの更新情報が受信されるのを待つ。また、ジョブ情報管理部４０４は、第２のジョブの更新情報が受信された後、受信された第２のジョブの更新情報に従って、ジョブキュー５０１に記憶した第２のジョブの情報、及びステップＳ７１２で取得した第２のジョブのデータを削除する。 In step S715, the
上記の処理に示すように、ジョブ処理装置１０１のジョブ実行部４０６は、ジョブキュー５０１に、ジョブ処理装置１０１でジョブのデータを管理する第１のジョブの情報が記憶されている場合、第１のジョブを実行する。また、ジョブ実行部４０６は、ジョブキュー５０１に第１のジョブのデータが記憶されていない場合、ジョブキュー５０１に記憶されている第２のジョブの情報に基づいて、第２のジョブを実行する。 As shown in the above processing, the
また、ジョブ処理装置１０１の更新情報通知部４０５は、ジョブキュー５０１に記憶された第１のジョブの情報が更新（追加、変更、削除等）された場合、第１のジョブが更新されたことを示す更新情報を、他のジョブ処理装置に通知する。 Further, the update
（ジョブデータの提供処理）
図８は、第１の実施形態に係るジョブデータの提供処理の例を示すフローチャートである。この処理は、ジョブ処理装置１０１が、ジョブのデータを管理している第１のジョブのデータを、他のジョブ処理装置１０１からの実行要求に応じて提供する処理の例を示している。(Job data provision process)
FIG. 8 is a flowchart showing an example of job data providing processing according to the first embodiment. This process shows an example of a process in which the job processing device 101 provides the data of the first job that manages the job data in response to the execution request from the other job processing device 101.
ステップＳ８０１において、ジョブ処理装置１０１は、他のジョブ処理装置１０１から、ジョブ処理装置１０１がジョブのデータを管理する第１のジョブの実行を要求する実行要求を受信すると、ステップＳ８０２以降の処理を実行する。 In step S801, when the job processing device 101 receives an execution request from another job processing device 101 requesting the execution of the first job in which the job processing device 101 manages the job data, the job processing device 101 performs the processing after step S802. Run.
ステップＳ８０２において、ジョブ処理装置１０１のジョブ情報管理部４０４は、第１のジョブの実行を要求する実行要求を受付すると、ジョブキュー５０１に記憶された第１のジョブの「ジョブの状態」の情報が、処理待ちであるかを判断する。 In step S802, when the job
第１のジョブの「ジョブの状態」の情報が、処理待ちでない場合（例えば、処理中である場合）、ジョブ情報管理部４０４は、処理をステップＳ８１０に移行させる。ステップＳ８１０に移行すると、ジョブ情報管理部４０４は、第１のジョブの実行を拒否する拒否情報を、実行要求を送信した要求元の他のジョブ処理装置１０１に通知する。 When the information of the "job status" of the first job is not waiting for processing (for example, when processing is in progress), the job
一方、第１のジョブの「ジョブの状態」の情報が、処理待ちである場合、ジョブ情報管理部４０４は、処理をステップＳ８０３に移行させる。 On the other hand, when the information of the "job status" of the first job is waiting for processing, the job
ステップＳ８０３に移行すると、ジョブ情報管理部４０４は、第１のジョブの実行を許可する許可情報を、実行要求の要求元の他のジョブ処理装置１０１に通知する。 When the process proceeds to step S803, the job
ステップＳ８０４において、ジョブ情報管理部４０４は、ジョブキュー５０１に記憶されている第１のジョブの「ジョブの状態」の情報を、例えば、処理中に変更する。 In step S804, the job
また、ジョブ情報管理部４０４は、ジョブキュー５０１に記憶されている第１のジョブの「ジョブを処理するジョブ処理装置」の情報に、要求元の他のジョブ処理装置１０１の情報を記憶し、「ジョブの開始日時」の情報を記憶する。 Further, the job
ステップＳ８０５において、更新情報通知部４０５は、第１のジョブの情報が更新されたことを示す第１のジョブの更新情報を、他のジョブ処理装置１０１の各々に通知する。この更新情報には、更新された第１のジョブの情報が含まれる。 In step S805, the update
ステップＳ８０６において、ジョブデータ管理部４０３は、第１のジョブのデータを、前述したジョブＩＤ、又はジョブＩＤに対応するジョブデータの保存先に基づいて取得し、要求元の他のジョブ処理装置１０１に送信する。 In step S806, the job
ステップＳ８０７において、ジョブ情報管理部４０４は、要求元の他のジョブ処理装置１０１から送信される第１のジョブの完了通知が受信されるのを待つ。また、第１のジョブの完了通知を受信した後、ジョブ情報管理部４０４は、第１のジョブの情報をジョブキュー５０１から削除し、ジョブデータ管理部４０３は、ジョブデータ記憶部４１１に記憶された第１のジョブのデータを削除する。 In step S807, the job
ステップＳ８０８において、更新情報通知部４０５は、第１のジョブの情報がジョブキュー５０１から削除されたことを示す更新情報を、他のジョブ処理装置１０１の各々に通知する。 In step S808, the update
ステップＳ８０９において、ジョブ受付部４０２は、第１のジョブの要求元（例えば、画像形成装置１０２）に、第１の情報が完了したことを通知する。 In step S809, the
上記の処理に示すように、ジョブ処理装置１０１は、他のジョブ処理装置１０１から、第１のジョブの実行を要求する実行要求を受信したときに、要求された第１のジョブの状態が処理待ちの状態である場合、ジョブの実行を許可し、ジョブのデータを提供する。 As shown in the above processing, when the job processing device 101 receives an execution request requesting execution of the first job from another job processing device 101, the state of the requested first job is processed. If it is in a waiting state, allow the job to be executed and provide the job data.
（ジョブ処理システムの処理）
続いて、ジョブ処理システム１００の処理の例について、シーケンス図を用いて説明する。(Job processing system processing)
Subsequently, an example of processing of the
図９、１０は、第１の実施形態に係るジョブ処理システムの例を示すシーケンス図である。また、図１１は、第１の実施形態に係る各ジョブ処理装置のジョブキューのイメージを示す図である。 9 and 10 are sequence diagrams showing an example of the job processing system according to the first embodiment. Further, FIG. 11 is a diagram showing an image of a job queue of each job processing device according to the first embodiment.
図９に示す処理の開始時点における各ジョブ処理装置１０１のジョブキューのイメージを図１１（ａ）に示す。 An image of the job queue of each job processing device 101 at the start of the processing shown in FIG. 9 is shown in FIG. 11A.
図１１において、ジョブ処理装置Ａ１０１−１のジョブキュー１１０１、ジョブ処理装置Ｂ１０１−２のジョブキュー１１０２、ジョブ処理装置Ｃ１０１−３のジョブキュー１１０３は、図５のジョブキュー５０１から、説明に必要な情報を抜粋したものである。 In FIG. 11, the
なお、図１１において、表中の「−」は、情報が格納されていないことを示すものとする。また、図１１の「管理する装置」は、図５のジョブキュー５０１の「ジョブを管理するジョブ処理装置」に対応しており、図１１の「処理する装置」は、図５のジョブキュー５０１の「ジョブを処理するジョブ処理装置」に対応しているものとする。 In FIG. 11, "-" in the table indicates that the information is not stored. Further, the “device to manage” in FIG. 11 corresponds to the “job processing device” in FIG. 5 for
図１１（ａ）に示すように、図９に示す処理の開始時点において、各ジョブ処理装置１０１のジョブキュー１１０１、１１０２、１１０３には、ジョブの情報が記憶されていないものとする。 As shown in FIG. 11A, it is assumed that the job information is not stored in the
図９のステップＳ９０１において、例えば、画像形成装置Ａ１０２−１から、ジョブ処理装置Ａ１０１−１に対して、ジョブの実行要求が送信される。 In step S901 of FIG. 9, for example, the image forming apparatus A102-1 transmits a job execution request to the job processing apparatus A101-1.
ステップＳ９０２において、ジョブ処理装置Ａ１０１−１は、画像形成装置Ａ１０２−１から受付けたジョブを、例えば、ジョブＩＤ「Ａ１」として管理する。このとき、ジョブ処理装置Ａ１０１−１は、他のジョブを実行していないので、受付したジョブＩＤ「Ａ１」のジョブを、ジョブキュー１１０１に記憶せずに、すぐに実行する。 In step S902, the job processing device A101-1 manages the job received from the image forming device A102-1 as, for example, the job ID "A1". At this time, since the job processing device A101-1 has not executed another job, the received job with the job ID "A1" is immediately executed without being stored in the
同様に、ステップＳ９０３において、例えば、画像形成装置Ｃ１０２−３から、ジョブ処理装置Ｂ１０１−２に対して、ジョブの実行要求が送信される。 Similarly, in step S903, for example, the image forming apparatus C102-3 transmits a job execution request to the job processing apparatus B101-2.
ステップＳ９０４において、ジョブ処理装置Ｂ１０１−２は、画像形成装置Ａ１０２−３から受付けたジョブを、例えば、ジョブＩＤ「Ｃ１」として管理する。このとき、ジョブ処理装置Ｂ１０１−２は、他のジョブを実行していないので、受付したジョブＩＤ「Ｃ１」のジョブを、ジョブキュー１１０２に記憶せずに、すぐに実行する。 In step S904, the job processing device B101-2 manages the job received from the image forming device A102-3 as, for example, the job ID “C1”. At this time, since the job processing device B101-2 has not executed another job, the received job with the job ID "C1" is immediately executed without being stored in the
ステップＳ９０５において、例えば、画像形成装置Ｂ１０２−２から、ジョブ処理装置Ａ１０１−１に対して、ジョブの実行要求が送信される。 In step S905, for example, the image forming apparatus B102-2 transmits a job execution request to the job processing apparatus A101-1.
ステップＳ９０６において、ジョブ処理装置Ａ１０１−１は、画像形成装置Ｂ１０２−２から受付けたジョブを、例えば、ジョブＩＤ「Ｂ１」として管理する。このとき、ジョブ処理装置Ａ１０１−１は、他のジョブ（ジョブＩＤ「Ａ１」）を実行しているので、受付したジョブＩＤ「Ｂ１」のジョブをすぐに実行することができない。 In step S906, the job processing device A101-1 manages the job received from the image forming device B102-2 as, for example, the job ID “B1”. At this time, since the job processing device A101-1 is executing another job (job ID "A1"), the received job with the job ID "B1" cannot be executed immediately.
この場合、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、ジョブＩＤ「Ｂ１」のジョブの情報を、ジョブキュー１１０１に記憶し、ジョブデータ管理部４０３は、ジョブＩＤ「Ｂ１」のジョブのデータを、ジョブデータ記憶部４１１に記憶する。 In this case, the job
このとき、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブ情報管理部４０４によって、ジョブキュー１１０１に第１のジョブが追加されたので、第１のジョブの更新情報を他のジョブ処理装置１０１の各々に通知する。 At this time, the update
ステップＳ９０７において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブ処理装置Ａ１０１−１のジョブキュー１１０１に、ジョブＩＤ「Ｂ１」のジョブが追加されたことを示すジョブの更新情報を、ジョブ処理装置Ｂ１０１−２に通知する。 In step S907, the update
ステップＳ９０８において、ジョブ処理装置Ｂ１０１−２のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブＩＤ「Ｂ１」のジョブの情報を、ジョブキュー１１０２に記憶する。 In step S908, the job
ステップＳ９０９において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブ処理装置Ａ１０１−１のジョブキュー１１０１に、ジョブＩＤ「Ｂ１」のジョブが追加されたことを示すジョブの更新情報を、ジョブ処理装置Ｃ１０１−３に通知する。 In step S909, the update
ステップＳ９１０において、ジョブ処理装置Ｃ１０１−３のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブＩＤ「Ｂ１」のジョブの情報を、ジョブキュー１１０３に記憶する。 In step S910, the job
ステップＳ９１０における各ジョブ処理装置１０１のジョブキューのイメージを図１１（ｂ）に示す。図１１（ｂ）に示すように、各ジョブ処理装置１０１のジョブキュー１１０１、１１０２、１１０３には、ジョブＩＤ「Ｂ１」のジョブの情報が、共通に記憶されている。なお、図１１（ｂ）において、「管理する装置」に記憶されている「Ａ」は、ジョブ処理装置Ａ１０１−１を示すものとする。 An image of the job queue of each job processing device 101 in step S910 is shown in FIG. 11B. As shown in FIG. 11B, the job information of the job ID “B1” is commonly stored in the
ステップＳ９１１において、他のジョブを実行していないジョブ処理装置Ｃ１０１−３は、例えば、図７に示すジョブの実行処理を実行する。ここでは、ジョブ処理装置Ｃ１０１−３のジョブキュー１１０３には、処理待ちの第１のジョブの情報は記憶されておらず、処理待ちの第２のジョブの情報（ジョブＩＤ「Ｂ１」のジョブの情報）が記憶されている。したがって、ジョブ処理装置Ｃ１０１−３のジョブ実行部４０６は、ジョブＩＤ「Ｂ１」のジョブのデータを管理するジョブ処理装置Ａ１０１−１に、ジョブＩＤ「Ｂ１」のジョブの実行を要求する実行要求を送信する。 In step S911, the job processing device C101-3, which has not executed another job, executes, for example, the job execution processing shown in FIG. 7. Here, the information of the first job waiting to be processed is not stored in the
ステップＳ９１２において、ジョブ処理装置Ａ１０１−１は、自装置でジョブのデータを管理するジョブＩＤ「Ｂ１」のジョブ（第１のジョブ）の実行要求を受付けると、例えば、図８に示すジョブデータの提供処理を実行する。 In step S912, when the job processing device A101-1 receives the execution request of the job (first job) of the job ID "B1" that manages the job data in its own device, for example, the job data shown in FIG. Execute the provision process.
ステップＳ９１２において、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、実行要求を受付したジョブＩＤ「Ｂ１」のジョブの状態を確認する。ここでは、図１１（ｂ）に示すように、ジョブＩＤ「Ｂ１」のジョブの状態は「処理待ち」である。 In step S912, the job
ステップＳ９１３において、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、ジョブＩＤ「Ｂ１」のジョブの実行を許可する許可情報を、実行要求のジョブ処理装置Ｃ１０１−３に通知する。 In step S913, the job
ステップＳ９１４において、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、ジョブキュー１１０１に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を更新する。例えば、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、ジョブキュー１１０１に記憶されたジョブＩＤ「Ｂ１」の情報のうち、「処理する装置」の情報に「Ｃ」（ジョブ処理装置Ｃ１０１−３）を記憶し、「ジョブの状態」の情報を「処理中」に変更する。 In step S914, the job
このとき、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブ情報管理部４０４によって、ジョブキュー１１０１記憶された第１のジョブの情報が変更されたので、第１のジョブの更新情報を他のジョブ処理装置１０１の各々に通知する。 At this time, the update
ステップＳ９１５において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブキュー１１０１に記憶されたジョブＩＤ「Ｂ１」のジョブの情報が変更されたことを示すジョブの更新情報を、ジョブ処理装置Ｂ１０１−２に通知する。 In step S915, the update
ステップＳ９１６において、ジョブ処理装置Ｂ１０１−２のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブキュー１１０２に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を更新する。 In step S916, the job
ステップＳ９１７において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブキュー１１０１に記憶されたジョブＩＤ「Ｂ１」のジョブの情報が変更されたことを示すジョブの更新情報を、ジョブ処理装置Ｃ１０１−３に通知する。 In step S917, the update
ステップＳ９１８において、ジョブ処理装置Ｃ１０１−３のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブキュー１１０３に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を更新する。 In step S918, the job
ステップＳ９１８における各ジョブ処理装置１０１のジョブキューのイメージを図１１（ｃ）に示す。図１１（ｃ）に示すように、各ジョブ処理装置１０１のジョブキュー１１０１、１１０２、１１０３には、ジョブＩＤ「Ｂ１」のジョブの情報が、共通に記憶されている。なお、図１１（ｃ）において、「処理する装置」に記憶されている「Ｃ」は、ジョブ処理装置Ｃ１０１−３を示すものとする。 An image of the job queue of each job processing device 101 in step S918 is shown in FIG. 11 (c). As shown in FIG. 11C, the job information of the job ID “B1” is commonly stored in the
ステップＳ９１９において、ジョブ処理装置Ａ１０１−１のジョブデータ管理部４０３は、例えば、ジョブ処理装置Ｃ１０１−１からの要求に応じて、ジョブＩＤ「Ｂ１」のジョブのデータを、例えば、ジョブＩＤに対応するジョブデータの保存先から取得する。また、ジョブ処理装置Ａ１０１−１のジョブデータ管理部４０３は、取得したジョブＩＤ「Ｂ１」のジョブのデータをジョブ処理装置Ｃ１０１−１に送信する。 In step S919, the job
ステップＳ９２０において、ジョブ処理装置Ｃ１０１−３のジョブ実行部４０６は、ジョブ処理装置Ａ１０１−１から取得したジョブＩＤ「Ｂ１」のジョブを実行する。 In step S920, the
ステップＳ９２０のジョブの実行が完了すると、図１０のステップＳ９２１において、ジョブ処理装置Ｃ１０１−３のジョブ実行部４０６は、ジョブ処理装置Ａ１０１−１に、ジョブの実行が完了したことを示す完了通知を通知する。 When the execution of the job in step S920 is completed, in step S921 of FIG. 10, the
ステップＳ９２２において、ジョブ処理装置Ａ１０１−１のジョブ情報管理部４０４は、ジョブ処理装置Ｃ１０１−３からジョブＩＤ「Ｂ１」のジョブの完了通知を受付すると、ジョブキュー１１０１に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を削除する。また、ジョブ処理装置Ａ１０１−１のジョブデータ管理部４０３は、ジョブデータ記憶部４１１に記憶したジョブＩＤ「Ｂ１」のジョブのデータを削除する。 In step S922, when the job
このとき、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブ情報管理部４０４によって、ジョブキュー１１０１記憶された第１のジョブの情報が変更（削除）されたので、第１のジョブの更新情報を他のジョブ処理装置１０１の各々に通知する。 At this time, the update
ステップＳ９２３において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブキュー１１０１に記憶されていたジョブＩＤ「Ｂ１」のジョブの情報が削除されたことを示すジョブの更新情報を、ジョブ処理装置Ｂ１０１−２に通知する。 In step S923, the update
ステップＳ９２４において、ジョブ処理装置Ｂ１０１−２のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブキュー１１０２に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を削除する。 In step S924, the job
ステップＳ９２５において、ジョブ処理装置Ａ１０１−１の更新情報通知部４０５は、ジョブキュー１１０１に記憶されていたジョブＩＤ「Ｂ１」のジョブの情報が削除されたことを示すジョブの更新情報を、ジョブ処理装置Ｃ１０１−３に通知する。 In step S925, the update
ステップＳ９２６において、ジョブ処理装置Ｃ１０１−３のジョブ情報管理部４０４は、ジョブ処理装置Ａ１０１−１から送信されたジョブの更新情報に基づいて、ジョブキュー１１０３に記憶されたジョブＩＤ「Ｂ１」のジョブの情報を削除する。また、ジョブ処理装置Ｃ１０１−３のジョブデータ管理部４０３は、ジョブＩＤ「Ｂ１」のジョブのデータを削除する。 In step S926, the job
ステップＳ９２６における各ジョブ処理装置１０１のジョブキューのイメージを図１１（ｄ）に示す。図１１（ｄ）に示すように、各ジョブ処理装置１０１のジョブキュー１１０１、１１０２、１１０３から、ジョブＩＤ「Ｂ１」のジョブの情報が、共通に削除されている。 An image of the job queue of each job processing device 101 in step S926 is shown in FIG. 11 (d). As shown in FIG. 11D, the job information of the job ID “B1” is commonly deleted from the
ステップＳ９２７において、ジョブ処理装置Ａ１０１−１のジョブ受付部４０２は、ジョブＩＤ「Ｂ１」のジョブの要求元の画像形成装置Ｂ１０２−２に、ジョブが完了したことを示す完了通知を送信する。 In step S927, the
このように、本実施形態に係るジョブ処理システム１００では、各ジョブ処理装置１０１は、ジョブ処理システム１００で処理待ちとなっているジョブの情報を、ジョブキューに共通に記憶して、管理する。 As described above, in the
また、各ジョブ処理装置１０１は、ジョブキューに、自装置でジョブのデータを管理している第１のジョブの情報がある場合、第１のジョブを実行する。 Further, each job processing device 101 executes the first job when the job queue contains information on the first job for which the job data is managed by the own device.
さらに、各ジョブ処理装置１０１は、ジョブキューに、第１のジョブの情報がない場合、ジョブキューに記憶された第２のジョブを取得し、実行する。 Further, each job processing device 101 acquires and executes the second job stored in the job queue when the job queue does not have the information of the first job.
上記の処理により、本実施形態によれば、複数のジョブ処理装置１０１がネットワークを介して接続されるジョブ処理システム１００において、ジョブ処理システム１００全体で効率良く複数のジョブを分散処理することができるようになる。 By the above processing, according to the present embodiment, in the
［第２の実施形態］
第２の実施形態では、ジョブキューに処理待ちの第１のジョブがなく、ジョブキューに処理待ちの複数の第２のジョブがある場合に、ジョブ処理装置１０１が、第２のジョブの処理コストに基づいて、実行する１つのジョブを決定する処理の例について説明する。[Second Embodiment]
In the second embodiment, when there is no first job waiting to be processed in the job queue and there are a plurality of second jobs waiting to be processed in the job queue, the job processing device 101 determines the processing cost of the second job. An example of a process for determining one job to be executed will be described.
＜機能構成＞
第２の実施形態に係るジョブ処理システムの機能構成は、図４に示す一実施形態に係るジョブ処理システムの構成と同様なので、ここでは、第１の実施形態との相違点を中心に説明を行う。<Functional configuration>
Since the functional configuration of the job processing system according to the second embodiment is the same as the configuration of the job processing system according to the first embodiment shown in FIG. 4, the description will be focused on the differences from the first embodiment. Do.
処理コスト算出部４０８は、ジョブキューに処理待ちの第１のジョブがなく、ジョブキューに処理待ちの複数の第２のジョブがある場合に、複数の第２のジョブの処理コストを算出する。処理コスト算出部４０８は、例えば、図６（ａ）に示すようなプラグインのコスト情報６０１と、例えば、図６（ｂ）に示すような通信速度情報６０２とを用いて、第２のジョブ毎の処理コストを算出する。 The processing
例えば、処理コスト算出部４０８は、次の式を用いて、第２のジョブの処理コストを計算する。 For example, the processing
（ジョブの処理コスト）＝（実行するプラグインのコストの総和）×（通信コスト）
＝Σプラグインのコスト×（ジョブデータサイズ［MB］×８／通信速度［Mbps］）
なお、上記の式では、ジョブデータサイズに８を乗算することにより、ｂｙｔｅを、ｂｉｔに変換している。(Job processing cost) = (Total cost of plug-ins to be executed) x (Communication cost)
= Σ plug-in cost x (job data size [MB] x 8 / communication speed [Mbps])
In the above formula, bytes are converted to bits by multiplying the job data size by 8.
例えば、ジョブ処理装置Ｃ１０１−３のジョブキューに、図５（ａ）に示すように２つの第２のジョブが記憶されている場合、ジョブ処理装置Ｃ１０１−３の処理コスト算出部４０８は、２つの第２のジョブの処理コストを、以下のように計算する。 For example, when two second jobs are stored in the job queue of the job processing device C101-3 as shown in FIG. 5A, the processing
（ジョブＩＤ「Ａ３」の処理コスト）
＝（１００＋８０＋１０）×（（４×１０＾６×８）／（５０×１０＾６））＝１２１．６
（ジョブＩＤ「Ｃ５」の処理コスト）
＝（１００＋１０）×（（５×１０＾６×８）／（２０×１０＾６））＝２２０
実行ジョブ決定部４０７は、ジョブキューに処理待ちの第１のジョブがなく、ジョブキューに処理待ちの複数の第２のジョブがある場合に、処理コスト算出部４０８が算出した第２のジョブ毎の処理コストを用いて、実行する１つの第２のジョブを決定する。(Processing cost of job ID "A3")
= (100 + 80 + 10) x ((4 x 10 ^ 6 x 8) / (50 x 10 ^ 6)) = 121.6
(Processing cost of job ID "C5")
= (100 + 10) x ((5 x 10 ^ 6 x 8) / (20 x 10 ^ 6)) = 220
When the job queue does not have the first job waiting for processing and the job queue has a plurality of second jobs waiting for processing, the execution
例えば、実行ジョブ決定部４０７は、処理コスト算出部４０８が算出した第２のジョブ毎の処理コストの値が低い方から順に、実行する１つの第２のジョブを決定する。 For example, the execution
上記の例では、ジョブＩＤ「Ａ３」のコストが、ジョブＩＤ「Ｃ５」の処理コストより低いので、実行ジョブ決定部４０７は、ジョブＩＤ「Ａ３」のジョブを、実行する第２のジョブに決定する。 In the above example, since the cost of the job ID "A3" is lower than the processing cost of the job ID "C5", the execution
＜処理の流れ＞
続いて、第２の実施形態に係るジョブ処理方法の処理の流れについて説明する。<Processing flow>
Subsequently, the processing flow of the job processing method according to the second embodiment will be described.
（ジョブの実行処理）
図１２は、第２の実施形態に係るジョブの実行処理の例を示すフローチャートである。なお、基本的な処理は、図７に示す第１の実施形態に係るジョブ実行処理と同様なので、ここでは、第１の実施形態との相違点を中心に説明を行う。(Job execution process)
FIG. 12 is a flowchart showing an example of job execution processing according to the second embodiment. Since the basic processing is the same as the job execution processing according to the first embodiment shown in FIG. 7, the differences from the first embodiment will be mainly described here.
ステップＳ７０１において、ジョブ処理装置１０１のジョブ実行部４０６は、ジョブ情報記憶部４１２に記憶されたジョブキュー５０１に、処理待ちの第１のジョブがあるか否かを判断する。 In step S701, the
ジョブキュー５０１に処理待ちの第１のジョブがない場合、ジョブ実行部４０６は、処理をステップＳ７０８に移行させる。 If there is no first job waiting to be processed in the
一方、ジョブキュー５０１に処理待ちの第１のジョブがある場合、ジョブ実行部４０６は、ステップＳ１２０１において、図７のステップＳ７０２〜Ｓ７０７に示す第１のジョブの実行処理を実行する。 On the other hand, when there is a first job waiting to be processed in the
ステップＳ７０８に移行すると、ジョブ実行部４０６は、ジョブキュー５０１に処理待ちの第２のジョブがあるか否かを判断する。 When the process proceeds to step S708, the
ジョブキュー５０１に処理待ちの第２のジョブがない場合、ジョブ実行部４０６は処理を終了させる。一方、ジョブキュー５０１に処理待ちの第２のジョブがある場合、ジョブ実行部４０６は、処理をステップＳ１２０２に移行させる。 If there is no second job waiting to be processed in the
ステップＳ１２０２に移行すると、処理コスト算出部４０８は、ジョブキューに記憶されている第２のジョブ毎の処理コストを算出する。 When the process proceeds to step S1202, the processing
ステップＳ１２０３において、実行ジョブ決定部４０７は、候補となる第２のジョブの中から、ジョブの処理コストが最も低い１つの第２のジョブを特定する。 In step S1203, the execution
ステップＳ１２０４において、実行ジョブ決定部４０７は、特定した第２のジョブのデータを管理している他のジョブ処理装置１０１に、特定した第２のジョブの実行を要求する実行要求を送信する。 In step S1204, the execution
ステップＳ１２０５において、実行ジョブ決定部４０７は、例えば、所定の時間内に要求した第２のジョブの実行を許可する許可情報を受信したかを判断する。 In step S1205, the execution
所定の時間内に第２のジョブの実行を許可する許可情報を受信した場合、ジョブ実行部４０６は、ステップＳ１２０８において、例えば、図７のステップＳ７１１〜Ｓ７１５に示す第２のジョブの実行処理を実行する。 When the permission information for permitting the execution of the second job is received within the predetermined time, the
一方、所定の時間内に第２のジョブの実行を許可する許可情報を受信しない場合、実行ジョブ決定部４０７は、処理をステップＳ１２０６に移行させる。 On the other hand, when the permission information permitting the execution of the second job is not received within the predetermined time, the execution
ステップＳ１２０６において、実行ジョブ決定部４０７は、他に候補となる第２のジョブがあるかを判断する。 In step S1206, the execution
他に候補となる第２のジョブがない場合、実行ジョブ決定部４０７は、処理を終了させる。一方、他に候補となる第２のジョブがある場合、実行ジョブ決定部４０７は、処理をステップＳ１２０７に移行させる。 If there is no other candidate second job, the execution
ステップＳ１２０７に移行すると、実行ジョブ決定部４０７は、実行が許可されなかった第２のジョブを、候補から除外して、ステップＳ１２０３以降の処理を再度実行する。 When the process proceeds to step S1207, the execution
（処理コストの算出処理）
図１３は、第２の実施形態係る処理コストの算出処理の例を示すフローチャートである。(Processing cost calculation process)
FIG. 13 is a flowchart showing an example of the processing cost calculation processing according to the second embodiment.
ステップＳ１３０１において、処理コスト算出部４０８は、例えば、図６（ａ）に示すようなプラグインのコスト情報６０１と、例えば、図５（ｃ）に示すようなワークフロー情報５０２とを用いて、ジョブに含まれるプラグインの総コストを算出する。 In step S1301, the processing
ステップＳ１３０２において、処理コスト算出部４０８は、ジョブのデータサイズと、例えば、図６に示すような通信速度情報６０２とを用いて、ジョブの通信速度を算出する。 In step S1302, the processing
ステップＳ１３０３において、処理コスト算出部４０８は、ステップＳ１３０１で算出したプラグインの総コストと、ステップＳ１３０２で算出した通信コストとの積を、ジョブの処理コストとする。 In step S1303, the processing
以上、本実施形態によれば、各ジョブ処理装置１０１は、他のジョブ処理装置１０１がジョブのデータを管理している第２のジョブを実行する際に、他のジョブ処理装置１０１との間の通信速度や、ジョブのデータサイズを考慮して実行するジョブを決定する。 As described above, according to the present embodiment, each job processing device 101 is connected to the other job processing device 101 when the other job processing device 101 executes the second job in which the job data is managed. Determine the job to be executed in consideration of the communication speed of the job and the data size of the job.
これにより、本実施形態によれば、複数のジョブ処理装置１０１がネットワークを介して接続されるジョブ処理システム１００において、ジョブ処理システム全体で、さらに効率良く複数のジョブを分散処理することができるようになる。 As a result, according to the present embodiment, in the
＜その他の実施形態＞
図１に示すジョブ処理システム１００のシステム構成、及び図４に示すジョブ処理システム１００の機能構成は一例であり、本実施形態に係るジョブ処理システム１００は、様々なシステム構成が可能である。<Other Embodiments>
The system configuration of the
例えば、本実施形態に係るジョブ処理装置１０１は、特許文献１に示されるような負荷分散装置を利用したジョブ処理システムにも、好適に適用することができる。 For example, the job processing device 101 according to the present embodiment can be suitably applied to a job processing system using a load distribution device as shown in
図１４は、その他の実施形態に係るジョブ処理システムの機能構成図である。図１４に示すジョブ処理システム１４００は、複数のジョブ処理装置１０１と、ネットワーク１０７を介して接続される負荷分散装置（情報処理装置）１４０１を有している。 FIG. 14 is a functional configuration diagram of a job processing system according to another embodiment. The
負荷分散装置１４０１は、例えば、特許文献１と同様に、ジョブを複数のジョブ処理装置１０１に振り分けるものとする。 As in
各ジョブ処理装置１０１は、負荷分散装置１４０１から受付けたジョブの情報を、図４の画像形成装置１０２から受付けたジョブと同様にジョブキューに記憶して、管理する。 Each job processing device 101 stores and manages the job information received from the
また、各ジョブ処理装置１０１は、自装置でジョブのデータを管理している第１のジョブの情報を、他のジョブ処理装置１０１に通知することにより、ジョブキューの情報を共有する。 Further, each job processing device 101 shares the job queue information by notifying the other job processing devices 101 of the information of the first job whose job data is managed by its own device.
さらに、各ジョブ処理装置１０１は、ジョブキューに処理待ちの第1のジョブがある場合、第１のジョブを実行し、ジョブキューに処理待ちの第１のジョブがない場合、ジョブキューに記憶された第２のジョブの情報に基づいて、第２のジョブを取得し、実行する。 Further, each job processing device 101 executes the first job when there is a first job waiting to be processed in the job queue, and stores the first job in the job queue when there is no first job waiting to be processed in the job queue. The second job is acquired and executed based on the information of the second job.
このようなシステム構成においても、各ジョブ処理装置１０１は、自装置で受付けた第１のジョブがなくなると、他のジョブ処理装置１０１が受付けた第２のジョブを自律的に取得して、実行することができる。したがって、ジョブ処理システム１４００においても、ジョブ処理システム１４００全体で効率良く複数のジョブを分散処理することができる。 Even in such a system configuration, each job processing device 101 autonomously acquires and executes a second job received by another job processing device 101 when the first job received by its own device disappears. can do. Therefore, even in the
また、図４に示すジョブ処理装置１０１に含まれる機能構成の少なくとも一部は、画像形成装置１０２に含まれていても良い。さらに、図４に示すジョブ処理装置１０１に含まれる各記憶部は、ネットワーク１０７を介して接続されるストレージサーバ等に含まれていても良い。 Further, at least a part of the functional configuration included in the job processing apparatus 101 shown in FIG. 4 may be included in the
１００ ジョブ処理システム
１０１ ジョブ処理装置
１０２ 画像形成装置
１０７ ネットワーク
４０２ ジョブ受付部
４０４ ジョブ情報管理部
４０５ 更新情報通知部
４０６ ジョブ実行部
４０７ 実行ジョブ決定部
４０８ 処理コスト算出部
４１１ ジョブデータ記憶部
４１２ ジョブ情報記憶部
１４０１ 負荷分散装置（情報処理装置）100 Job processing system 101
Claims (13)
Translated fromJapanese前記ジョブ処理装置は、
前記ジョブを受け付けるジョブ受付部と、
当該ジョブ処理装置が受け付けた前記ジョブである第１のジョブの実行に関するジョブ情報と、当該ジョブ処理装置とは異なる他のジョブ処理装置から送信され、当該他のジョブ処理装置が受け付けた前記ジョブである第２のジョブの実行に関するジョブ情報とをジョブ情報記憶部に記憶して管理するジョブ情報管理部と、
前記第１のジョブが受け付けられたことに応じて、前記第１のジョブのジョブ情報を前記他のジョブ処理装置に通知する通知部と、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されている場合、当該第１のジョブを実行し、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを実行するジョブ実行部と、
を有するジョブ処理システム。A job processing system in which a plurality of job processing devices that execute jobs, which are execution units of processing based on a workflow in which one or more processes are defined, are connected via a network.
The job processing device is
The job reception department that accepts the job and
The job information related to the execution of the first job, which is the job received by the job processing device, and the job sent from another job processing device different from the job processing device and received by the other job processing device. A job information management unit that stores and manages job information related to the execution of a second job in the job information storage unit, and
A notification unit that notifies the other job processing device of the job information of the first job in response to the acceptance of the first job.
When the job information of the first job whose processing has not been started is stored in the job information storage unit, the first job is executed.
When the job information of the first job whose processing has not been started is not stored in the job information storage unit, the second job which is stored in the job information storage unit and whose processing has not been started. The job execution unit that executes the second job based on the job information of
Job processing system with.
前記第１のジョブの実行を開始したことに応じて、当該第１のジョブのジョブ情報を変更し、
前記通知部は、
前記第１のジョブのジョブ情報が変更された場合、当該ジョブ情報を前記他のジョブ処理装置に通知する請求項１に記載のジョブ処理システム。The job execution unit
The job information of the first job is changed according to the start of execution of the first job.
The notification unit
The job processing system according to claim 1, wherein when the job information of the first job is changed, the job information is notified to the other job processing apparatus.
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを受け付けた前記他のジョブ処理装置に対して、当該ジョブ処理装置によって当該第２のジョブを実行することを要求する要求情報を送信し、当該他のジョブ処理装置から当該第２のジョブの実行を許可する許可情報を受信した場合、当該他のジョブ処理装置から、当該第２のジョブにおける処理対象のデータを取得する請求項１又は２に記載のジョブ処理システム。The job execution unit
When the job information of the first job whose processing has not been started is not stored in the job information storage unit, the second job which is stored in the job information storage unit and whose processing has not been started. Based on the job information of, the request information requesting that the second job be executed by the job processing device is transmitted to the other job processing device that has received the second job, and the other According to claim 1 or 2, when the permission information for permitting the execution of the second job is received from the job processing device of the second job, the data to be processed in the second job is acquired from the other job processing device. Job processing system.
当該ジョブ処理装置において前記第２のジョブの実行が完了したとき、当該第２のジョブの実行が完了したことを示す完了通知を、当該第２のジョブの前記処理対象のデータを取得した前記他のジョブ処理装置に通知する請求項３に記載のジョブ処理システム。The job execution unit
When the execution of the second job is completed in the job processing device, a completion notification indicating that the execution of the second job is completed is given to the other person who has acquired the data of the processing target of the second job. The job processing system according to claim 3, which notifies the job processing apparatus of the above.
前記他のジョブ処理装置から、前記ジョブ情報記憶部に記憶されている前記第１のジョブを前記他のジョブ処理装置によって実行することを要求する要求情報を受信したときに、前記第１のジョブが処理待ちの状態である場合、
当該要求情報を送信した前記他のジョブ処理装置に、前記第１のジョブの実行を許可する許可情報を送信し、前記ジョブ情報記憶部に記憶されている前記第１のジョブのジョブ情報に、前記第１のジョブの処理が開始されたことを示す情報を記憶する請求項１乃至４のいずれか一項に記載のジョブ処理システム。The job information management department
When the request information requesting that the first job stored in the job information storage unit be executed by the other job processing device is received from the other job processing device, the first job Is waiting for processing
The permission information for permitting the execution of the first job is transmitted to the other job processing device that has transmitted the request information, and the job information of the first job stored in the job information storage unit is added to the job information. The job processing system according to any one of claims 1 to 4, which stores information indicating that the processing of the first job has been started.
前記許可情報を送信した前記他のジョブ処理装置から、前記第１のジョブの実行が完了したことを示す完了情報の通知を受付した場合、
前記ジョブ情報記憶部に記憶した前記第１のジョブのジョブ情報を削除し、
前記第１のジョブの要求元に、前記第１のジョブが完了したことを通知する請求項５に記載のジョブ処理システム。The job processing device is
When the notification of the completion information indicating that the execution of the first job is completed is received from the other job processing device that has transmitted the permission information.
The job information of the first job stored in the job information storage unit is deleted.
The job processing system according to claim 5, which notifies the requester of the first job that the first job has been completed.
前記ジョブ情報記憶部に記憶されている前記第２のジョブの処理コストを算出する処理コスト算出部と、
前記ジョブ情報記憶部に処理が開始されていない複数の前記第２のジョブが記憶されている場合、前記処理コスト算出部が算出した前記処理コストを用いて、前記ジョブ実行部で実行する一の前記第２のジョブを決定する実行ジョブ決定部と、
を有する請求項１乃至６のいずれか一項に記載のジョブ処理システム。The job processing device is
A processing cost calculation unit that calculates the processing cost of the second job stored in the job information storage unit, and a processing cost calculation unit.
When a plurality of the second jobs whose processing has not been started are stored in the job information storage unit, the processing cost calculated by the processing cost calculation unit is used to execute one in the job execution unit. The execution job determination unit that determines the second job, and
The job processing system according to any one of claims 1 to 6.
当該ジョブ処理装置と他のジョブ処理装置との間の通信速度の情報を用いて、前記第２のジョブの処理コストを算出する請求項７に記載のジョブ処理システム。The processing cost calculation unit of the job processing device
The job processing system according to claim 7, wherein the processing cost of the second job is calculated by using the information of the communication speed between the job processing device and another job processing device.
前記第２のジョブに応じた前記ワークフローに定義された前記１つ以上の処理コストの総コストを算出し、
当該ジョブ処理装置と他のジョブ処理装置との間の通信速度の情報と、前記第２のジョブのデータサイズとを用いて通信コストを算出し、
前記算出された前記総コストと、前記通信コストの積を用いて、前記第２のジョブの処理コストを算出する請求項７又は８に記載のジョブ処理システム。The processing cost calculation unit of the job processing device
The total cost of one or more of the processing costs defined in the workflow according to the second job is calculated.
The communication cost is calculated using the information on the communication speed between the job processing device and another job processing device and the data size of the second job.
The job processing system according to claim 7 or 8, wherein the processing cost of the second job is calculated by using the product of the calculated total cost and the communication cost.
前記ジョブ情報記憶部に記憶されている処理を開始していない前記複数の前記第２のジョブの中から、前記処理コスト算出部が算出した前記第２のジョブの処理コストが低い順に前記ジョブ実行部で実行する前記一のジョブを決定する請求項７乃至９のいずれか一項に記載のジョブ処理システム。The execution job determination unit
The job execution is performed in ascending order of the processing cost of the second job calculated by the processing cost calculation unit from among the plurality of the second jobs that have not started the processing stored in the job information storage unit. The job processing system according to any one of claims 7 to 9, which determines the one job to be executed by the unit.
前記ジョブを受け付けるジョブ受付部と、
当該ジョブ処理装置が受け付けた前記ジョブである第１のジョブの実行に関するジョブ情報と、当該ジョブ処理装置とは異なる他のジョブ処理装置から送信され、当該他のジョブ処理装置が受け付けた前記ジョブである第２のジョブの実行に関するジョブ情報とをジョブ情報記憶部に記憶して管理するジョブ情報管理部と、
前記第１のジョブが受け付けられたことに応じて、前記第１のジョブのジョブ情報を前記他のジョブ処理装置に通知する通知部と、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されている場合、当該第１のジョブを実行し、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを実行するジョブ実行部と、
を有するジョブ処理装置。The job processing device of a job processing system in which a plurality of job processing devices that execute jobs, which are execution units of processing based on a workflow in which one or more processes are defined, are connected via a network.
The job reception department that accepts the job and
The job information related to the execution of the first job, which is the job received by the job processing device, and the job sent from another job processing device different from the job processing device and received by the other job processing device. A job information management unit that stores and manages job information related to the execution of a second job in the job information storage unit, and
A notification unit that notifies the other job processing device of the job information of the first job in response to the acceptance of the first job.
When the job information of the first job whose processing has not been started is stored in the job information storage unit, the first job is executed.
When the job information of the first job whose processing has not been started is not stored in the job information storage unit, the second job which is stored in the job information storage unit and whose processing has not been started. The job execution unit that executes the second job based on the job information of
Job processing device with.
前記ジョブを受け付けるステップと、
当該ジョブ処理装置が受け付けた前記ジョブである第１のジョブの実行に関するジョブ情報と、当該ジョブ処理装置とは異なる他のジョブ処理装置から送信され、当該他のジョブ処理装置が受け付けた前記ジョブである第２のジョブの実行に関するジョブ情報とをジョブ情報記憶部に記憶して管理するステップと、
前記第１のジョブが受け付けられたことに応じて、前記第１のジョブのジョブ情報を前記他のジョブ処理装置に通知するステップと、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されている場合、当該第１のジョブを実行するステップと、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを実行するステップと、
を実行させるためのプログラム。To the job processing device of the job processing system in which a plurality of job processing devices that execute jobs, which are execution units of processing based on a workflow in which one or more processes are defined, are connected via a network.
The step of accepting the job and
The job information related to the execution of the first job, which is the job received by the job processing device, and the job sent from another job processing device different from the job processing device and received by the other job processing device. A step of storing and managing job information related to the execution of a second job in the job information storage unit, and
A step of notifying the other job processing device of the job information of the first job in response to the acceptance of the first job, and
When the job information of the first job whose processing has not been started is stored in the job information storage unit, the step of executing the first job and
When the job information of the first job whose processing has not been started is not stored in the job information storage unit, the second job which is stored in the job information storage unit and whose processing has not been started. Steps to execute the second job based on the job information of
A program to execute.
前記ジョブ処理装置が、
前記ジョブを受け付けるステップと、
当該ジョブ処理装置が受け付けた前記ジョブである第１のジョブの実行に関するジョブ情報と、当該ジョブ処理装置とは異なる他のジョブ処理装置から送信され、当該他のジョブ処理装置が受け付けた前記ジョブである第２のジョブの実行に関するジョブ情報とをジョブ情報記憶部に記憶して管理するステップと、
前記第１のジョブが受け付けられたことに応じて、前記第１のジョブのジョブ情報を前記他のジョブ処理装置に通知するステップと、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されている場合、当該第１のジョブを実行するステップと、
前記ジョブ情報記憶部に、処理が開始されていない前記第１のジョブのジョブ情報が記憶されていない場合、前記ジョブ情報記憶部に記憶されている、処理が開始されていない前記第２のジョブのジョブ情報に基づいて、当該第２のジョブを実行するステップと、
を含むジョブ処理方法。A job processing method in a job processing system in which a plurality of job processing devices that execute jobs, which are execution units of processing based on a workflow in which one or more processes are defined, are connected via a network.
The job processing device
The step of accepting the job and
The job information related to the execution of the first job, which is the job received by the job processing device, and the job sent from another job processing device different from the job processing device and received by the other job processing device. A step of storing and managing job information related to the execution of a second job in the job information storage unit, and
A step of notifying the other job processing device of the job information of the first job in response to the acceptance of the first job, and
When the job information of the first job whose processing has not been started is stored in the job information storage unit, the step of executing the first job and
When the job information of the first job whose processing has not been started is not stored in the job information storage unit, the second job which is stored in the job information storage unit and whose processing has not been started. Steps to execute the second job based on the job information of
Job processing method including.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2016176813AJP6786975B2 (en) | 2016-09-09 | 2016-09-09 | Job processing system, job processing device, job processing method, and program |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2016176813AJP6786975B2 (en) | 2016-09-09 | 2016-09-09 | Job processing system, job processing device, job processing method, and program |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2018041400A JP2018041400A (en) | 2018-03-15 |
| JP6786975B2true JP6786975B2 (en) | 2020-11-18 |
Family
ID=61626174
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2016176813AExpired - Fee RelatedJP6786975B2 (en) | 2016-09-09 | 2016-09-09 | Job processing system, job processing device, job processing method, and program |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP6786975B2 (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| KR102227204B1 (en)* | 2019-02-12 | 2021-03-11 | 한전케이디엔주식회사 | Real-Time Work Flow Management System using Distributed Processing |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH11312149A (en)* | 1998-04-28 | 1999-11-09 | Hitachi Ltd | Load distribution control method and device |
| JP2004206298A (en)* | 2002-12-24 | 2004-07-22 | Casio Soft Co Ltd | Job processing system and program |
| JP2008077266A (en)* | 2006-09-20 | 2008-04-03 | Nec Corp | Service control unit, distributed service control system, service control method, and program |
| JP4245055B2 (en)* | 2007-01-29 | 2009-03-25 | コニカミノルタビジネステクノロジーズ株式会社 | Image processing system, image processing apparatus, job processing method, and program |
- 2016
- 2016-09-09JPJP2016176813Apatent/JP6786975B2/ennot_activeExpired - Fee Related
Also Published As
| Publication number | Publication date |
|---|---|
| JP2018041400A (en) | 2018-03-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP5383335B2 (en) | Data transmission apparatus, transmission control method, and program | |
| CN101043574B (en) | Image forming apparatus and image forming method | |
| US20130176592A1 (en) | Output control system, output control method, and output control apparatus | |
| JP6179083B2 (en) | Information processing apparatus, output system, and program | |
| JP6064800B2 (en) | Information processing apparatus and program | |
| CN104917922A (en) | Image forming apparatus, data management method, and storage medium | |
| JP2017192110A (en) | System, server, method, and program for storing data | |
| JP6303505B2 (en) | Information processing system, information processing method, device, and program | |
| CN110389727A (en) | Image forming system and image forming method | |
| US20120272188A1 (en) | Information processing apparatus, information processing method, and non-transitory computer readable medium | |
| JP6195340B2 (en) | Content management system, server device, control method, and program | |
| JP6786975B2 (en) | Job processing system, job processing device, job processing method, and program | |
| JP6060573B2 (en) | OUTPUT SYSTEM, OUTPUT CONTROL DEVICE, OUTPUT DEVICE, AND PROGRAM | |
| KR102143411B1 (en) | Image forming apparatus, method for controlling image forming apparatus, and storage medium | |
| JP6844197B2 (en) | Information processing system, program, processing execution method | |
| JP7047504B2 (en) | Job system, job execution method, information processing device, program | |
| JP5417043B2 (en) | Image forming apparatus, image forming system, and image processing method | |
| US9866721B2 (en) | Information processing apparatus, image forming apparatus, and non-transitory computer readable medium for file distribution to servers | |
| JP6727775B2 (en) | Server device, control system, control method, and program | |
| CN106371774A (en) | Server apparatus that distributes print data, management method of print data | |
| JP2021110992A (en) | Color management apparatus, color management method, and program | |
| JP5833605B2 (en) | Image processing apparatus and image processing system | |
| JP7346926B2 (en) | Information processing device, information processing method, program and information processing system | |
| JP2009134413A (en) | Image processing system and image processing program | |
| JP6481666B2 (en) | Image processing device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination | Free format text:JAPANESE INTERMEDIATE CODE: A621 Effective date:20190703 | |
| A977 | Report on retrieval | Free format text:JAPANESE INTERMEDIATE CODE: A971007 Effective date:20200806 | |
| 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:20200929 | |
| A61 | First payment of annual fees (during grant procedure) | Free format text:JAPANESE INTERMEDIATE CODE: A61 Effective date:20201012 | |
| R151 | Written notification of patent or utility model registration | Ref document number:6786975 Country of ref document:JP Free format text:JAPANESE INTERMEDIATE CODE: R151 | |
| LAPS | Cancellation because of no payment of annual fees |