JP5256787B2 - Queue management apparatus, control program, job processing system, and control method - Google Patents

Description

  The present invention relates to a queue management device, a control program, a job processing system, and a control method.

  Conventionally, a queue management apparatus has been used as one method for efficiently processing a job by a plurality of users using a plurality of execution computers. This queue management apparatus first arranges jobs in the queue (queue) from the top in the order of input. When there is a vacancy in the execution computer, the job at the head of the queue is sent to the computer in order and processed. Thereby, a plurality of execution computers can be efficiently used by a plurality of users.

  When a job is automatically sent to an execution computer using this queue management device, the job processing result is output in the form of a file. This file is stored in a storage device connected to the execution computer. The storage device has a specified capacity. If the queue management device is left unattended with the storage device exceeding this specified capacity, job processing results are not accumulated, and results may be wasted. In order to prevent this, Patent Document 1 describes a method of stopping a queue management device when a storage device exceeds a specified capacity.

An image input device provided with an automatic document feeder reads a document, and stores the obtained image data in a storage device. At this time, if there is no room for writing in the storage device, there is a method of interrupting the reading of the original, waiting for the number of jobs in the storage device to decrease due to the end of the job being printed, and restarting the reading of the original. Patent Document 2.
JP-A-60-238958 Japanese Patent Laid-Open No. 4-306059

  However, the prior art described in the above literature has room for improvement in the following points.

  If multiple storage devices are used, the queue management device cannot determine in which storage device the job is stored in the prior art, so when one of the storage devices exceeds its capacity, Even if there is room in the storage device, the queue management device must be stopped.

  The present invention has been made in view of the above circumstances, and an object of the present invention is to provide a queue management device including a plurality of storage devices, even if some storage devices exceed the capacity, And to provide a queue management apparatus that smoothly executes job processing.

  According to the present invention, a plurality of user terminals that input a job to be executed, a plurality of execution devices that execute the job, and a plurality of memories that store output files output from the execution device as processing results of the job A queue management apparatus connected to the apparatus via a network, wherein the queue management apparatus registers a job submitted from the user terminal in a queue, and stores the output file of the job An allocating unit for allocating the storage device to the job, a distribution unit for allocating the job to the execution device capable of processing the job, a processing stage of the job, and a capacity of the storage device When the storage unit determines that the capacity exceeds the capacity by the monitoring unit that monitors the excess and the monitoring unit, the storage unit is set as the storage destination. Stop means for stopping the processing of the job in line, and when the processing of the job is stopped, the storage device is allocated to another job before execution with the same storage destination as the job. A queue management device including allocation changing means for changing to the other storage device.

Various methods can be adopted for the monitoring unit to determine whether the capacity of the storage device is exceeded. The following is an example.
(1) When the used capacity information of the stored file stored in the storage device is obtained and the output file is stored, the monitoring means is configured to store the output capacity when the used capacity of the storage device exceeds a predetermined upper limit value. Is determined to be over capacity.
(2) Obtaining the free space information of the storage device, and when the capacity required for storing the output file exceeds the free space, the monitoring means determines that the storage device is over capacity.

  The processing steps may include “cueing”, “running”, “stopping”, and “ending”.

  Further, the queue management device includes a reducing unit that reduces the used capacity of the storage device that has exceeded the capacity, and the monitoring unit does not exceed the capacity of the storage device as a result of reducing the used capacity of the storage device. And a restarting means for restarting the processing of the job that has been stopped.

Various methods can be adopted as a method for the reduction means to reduce the used capacity of the storage device. The following is an example.
(1) Compress the uncompressed and stored file that is not used by the job and stored in the storage device that has exceeded the capacity.
(2) Delete the unnecessary stored file stored in the storage device whose capacity has been exceeded.
(3) A part or all of the stored file stored in the storage device that has exceeded the capacity is moved to another storage device.

  Further, the queue management device includes a license assignment unit that assigns a license for each job, a license management unit that manages the number of assigned licenses so as not to exceed the number of contracts, and the job that has been stopped. License release means for releasing the license, and license reassignment means for reassigning the license to the stopped job that can be resumed.

  In this queue management device, the user terminal, the job input from the user terminal, the processing stage of the job, the storage device for storing the output file of the job, and the capacity of the storage device A database having a table associating the excess determination may be included.

  The allocating unit can allocate the storage device serving as a storage destination to the job using information from the database.

  The monitoring means can monitor the job processing stage and the storage device capacity excess in association with each user terminal using the information from the database.

  When the processing of the job is stopped, the monitoring unit changes the allocation so as to change the storage device corresponding to the user terminal that has input the job to another storage device that is not determined to have exceeded the capacity. Means can change the database.

  The allocation unit is not determined to have exceeded the capacity of another job before execution whose storage destination is the same as the stopped job, using information from the database changed by the allocation change unit. Other storage devices can be allocated.

  The database includes contact information of the user terminal, and the monitoring unit uses the contact information for the user terminal that has input the job when processing of the job is stopped. It can be notified that the job is stopped.

  According to the present invention, there is provided a program for controlling a queue management apparatus, comprising: a step of registering jobs in a queue in the order of input from a user terminal to the queue management apparatus; and a storage location of an output file of the job Allocating a storage device to the job, allocating the job to an execution device capable of processing the job, and storing the storage device if the storage device is determined to exceed capacity The step of stopping the processing of the job that is being executed first, and when the processing of the job is stopped, the storage device And a step of changing the allocation to the other storage device.

  The control program can cause the queue management device to execute a step of reducing the capacity of the storage device that has exceeded the capacity and a step of restarting the processing of the job that has been stopped.

  In the control program, a step of assigning a license to the queue management device for each job, a step of releasing the license of the job that has been stopped, and a license for the stopped job that can be resumed A step of reassigning

  According to the present invention, a plurality of user terminals that input a job to be executed, a plurality of execution devices that execute the job, and a plurality of memories that store output files output from the execution device as processing results of the job A job processing system including a device and a queue management device, wherein the queue management device includes a registration unit that registers the jobs in a queue in the order of input from the user terminal, and a storage location of the output file of the job Allocation means for allocating the storage device to the job, distribution means for allocating the job to the execution device capable of processing the job, processing stage of the job, and excess capacity of the storage device And when the storage device determines that the storage device exceeds the capacity, the storage device is set as the storage destination. Stop means for stopping the processing of the job in line, and when the processing of the job is stopped, the storage device is allocated to another job before execution with the same storage destination as the job. A job processing system comprising: an allocation changing means for changing to another storage device.

  In the job processing system, the user terminal may include display means for displaying monitoring information acquired from the monitoring means.

  Further, in the job processing system, the queue management device includes a reduction unit that reduces the used capacity of the storage device that has exceeded the capacity, and the monitoring unit stores the storage device as a result of reducing the used capacity of the storage device. Resuming means for resuming processing of the job that has been stopped when it is determined that the apparatus does not exceed the capacity.

  Further, in the job processing system, the queue management device includes a license allocation unit that allocates a license for each job, a license management unit that manages the number of allocated licenses so as not to exceed the number of contracts, License release means for releasing the license of the job that has become, and license reassignment means for reassigning the license to the stopped job that can be resumed.

  According to the present invention, there is provided a control method for a job processing system, the step of registering jobs in a queue in the order of input from a user terminal, and the storage device that is the storage destination of the output file of the job. A step of allocating a job, a step of allocating the job to an execution device capable of processing the job, and the job being executed with the storage device as a storage destination when the storage device is determined to have exceeded capacity When the processing of the job is stopped and the processing of the job is stopped, the allocation of the storage device is changed to another storage device for another job before execution whose storage destination is the same as the job And a control method comprising the steps of:

  Further, the control method of the job processing system may include a step of reducing the used capacity of the storage device that has exceeded the capacity, and a step of restarting the processing of the job that has been stopped.

  Further, in the control method of the job processing system, a step of assigning a license for each job, a step of releasing the license of the job that has been stopped, and a step of assigning the license to the stopped job that can be resumed. Reassigning.

  According to the present invention, in a queue management device having a plurality of storage devices, there is provided a queue management device that smoothly executes job processing using other storage devices even when some storage devices exceed their capacity. Is done.

Hereinafter, embodiments of the present invention will be described with reference to the drawings. In all the drawings, the same reference numerals are given to the same components, and the description will be omitted as appropriate.
(First embodiment)

  FIG. 1 is a configuration diagram of a queue management apparatus according to an embodiment of the present invention and a job processing system including the queue management apparatus.

  A plurality of user terminals 12 (121, 122, 123) for inputting a job to be executed, a plurality of execution devices 13 (131, 132, 133) for executing the job, and output from the execution device 13 as a job processing result A queue management apparatus 11 connected to a plurality of storage devices 14 (141, 142, 143) for storing output files via a network, and the queue management apparatus 11 executes jobs input from the user terminal 12 A registration unit 111 that registers in a queue, an allocation unit 112 that allocates a storage device 14 that stores a job output file to a job, and a distribution unit that allocates a job to an execution device 13 that can process the job 113, a monitoring unit 114 that monitors the job processing stage and the capacity excess of the storage device 14, and the monitoring unit 114 14 is determined to exceed the capacity, the stop unit 115 that stops the processing of the job being executed with the storage device 14 as the storage destination, and the job and the storage destination are the same when the job processing is stopped. And an assignment changing unit 116 that changes the assignment of the storage device 14 to another storage device 14 for another job before execution.

  The various components of the present invention do not necessarily have to be independent of each other. A plurality of components are formed as a single member, and a single component is formed of a plurality of members. It may be that a certain component is a part of another configuration, a part of a certain component overlaps a part of another component, and the like.

  Further, the network referred to in the present invention may be any of wired, wireless, and a combination thereof as long as it can mediate information transmission between the queue management device 11, the user terminal 12, the execution device 13, and the storage device 14. . Further, the network configuration is not limited to the configuration shown in FIG. 1 as long as information can be transmitted between the queue management device 11, the user terminal 12, the execution device 13, and the storage device 14. For example, the queue management device 11, the user terminal 12, the execution device 13, and the storage device 14 may all be connected to the same network.

  In FIG. 1, the user terminal 12, the execution device 13, and the storage device 14 are each composed of three, but any number of user terminals 12, execution devices 13, and storage devices 14 may be used.

  The queue management device 11 includes a registration unit 111, an allocation unit 112, a distribution unit 113, a monitoring unit 114, a stop unit 115, and an allocation change unit 116.

  The registration unit 111 arranges jobs submitted from the user terminal 12 from the top in the order of submission and registers them in the queue.

  The allocation unit 112 allocates, for each job, a storage device 14 that stores an output file to be output as a result of processing the job by the execution device 13. Details of the allocation method will be described later.

  The distribution unit 113 distributes the job to the execution device 13 that can process the job. For example, when the monitoring unit 114 detects that the execution device 131 has finished processing the preceding job, the distribution unit 113 sends the job at the head of the queue to the execution device 131. This is an example of a distribution method, and is not limited to this method.

  The monitoring unit 114 monitors a job processing stage and an excess capacity of the storage device 14. Details of the monitoring method will be described later.

  As an example of the job processing stage described above, “cueing”, “running”, “stopped”, “finished”, and the like can be given.

  An example of a determination method for the above capacity excess of the storage device 14 will be described and described in detail. For example, when storing the output file in the storage device 141, the current used capacity information is acquired from the storage device 141, added to the capacity necessary for storing the output file, and the storage device 141 used after the output file is stored. When the capacity is obtained and this value exceeds a predetermined upper limit value, the storage device 141 determines that the capacity is exceeded. Alternatively, when the output file is stored in the storage device 141, the current free space information of the storage device 141 is acquired, and the storage device 141 exceeds the free space when the capacity necessary for storing the output file exceeds the free space It is determined that

  In the configuration of FIG. 1, the monitoring unit 114 can acquire the used capacity information or the free capacity information of the storage device 14 via the execution device 13. However, depending on the configuration, the monitoring unit 114 may acquire the used capacity information or the free capacity information directly from the storage device 14.

  When the monitoring unit 114 determines that any of the storage devices 14 exceeds the capacity, the stop unit 115 stops processing of the job being executed with the storage device 14 determined to have exceeded the capacity as a storage destination.

When the job processing is stopped, the assignment changing unit 116 changes the assignment of the storage device 14 to another storage device 14 for another job before execution whose storage destination is the same as that job. In FIG. 1, the job process stop information is exemplified by the configuration acquired from the monitoring unit 114, but may be acquired from the stop unit 115. Details of the allocation changing method will be described later.
(Second Embodiment)

  FIG. 2 is a block diagram showing a second embodiment of the present invention.

  A plurality of user terminals 22 (221, 222, 223), a plurality of execution devices 23 (231, 232, 233), a plurality of storage devices 24 (241, 242, 243), and queues connected via a network The management device 21 includes a registration unit 211, an allocation unit 212, a distribution unit 213, a monitoring unit 214, a stop unit 215, and an allocation change unit 216. This is the same as in FIG. The description of each component is the same as the description of FIG.

  Further, the queue management device 21 has a reduction unit 217 that reduces the used capacity of the storage device 24 that has exceeded the capacity, and a used capacity of the storage device 24 is reduced, and the monitoring unit 214 does not exceed the capacity of the storage device 24. A restart unit 218 that restarts the processing of the job that has been stopped.

  An example of a method by which the reduction unit 217 reduces the capacity of the storage device 24 will be specifically described. For example, when the monitoring unit 214 determines that the storage device 241 has exceeded the capacity, the stop unit 215 stops processing of the job being executed with the storage device 241 as the storage destination. The monitoring unit 214 acquires the job stop information from the execution device 231 that was executing the stopped job, and transmits the job stop information to the reduction unit 217. The reduction unit 217 causes one of the execution devices 23 to reduce the stored file in the storage device 241. Various modes can be adopted as the reduction method. The following is an example.

  The stored file that is not used by the uncompressed and stopped job stored in the storage device 241 that has exceeded the capacity is compressed.

  Delete unnecessary stored files stored in the storage device 241 whose capacity has been exceeded.

  A part or all of the stored file stored in the storage device 241 whose capacity has been exceeded is moved to another storage device. Here, the other storage devices may include the storage devices 242 and 243.

An example of a method in which the resuming unit 218 resumes the processing of the stopped job will be specifically described. For example, after the reduction unit 217 reduces the stored file of the storage device 241 that is determined to have exceeded the capacity, the monitoring unit 214 determines that the storage device 241 has exceeded the capacity, and the determination result is “No”. The restarting unit 218 acquires the determination result information from the monitoring unit 214 and restarts the job processing.
(Third embodiment)

  FIG. 3 is a block diagram showing a third embodiment of the present invention.

  A plurality of user terminals 32 (321, 322, 323), a plurality of execution devices 33 (331, 332, 333), a plurality of storage devices 34 (341, 342, 343), and queues connected via a network The queue management device 31, which is the management device 31, includes a registration unit 311, an allocation unit 312, a distribution unit 313, a monitoring unit 314, a stop unit 315, an allocation change unit 316, a reduction unit 317, and a restart. Part 318. This is the same as FIG. The description of each component is the same as the description of FIGS. 1 and 2 described above.

  Further, the queue management device 31 releases a license for a job that has been stopped, a license allocation unit 319 that allocates a license for each job, a license management unit 3110 that manages so that the number of allocated licenses does not exceed the number of contracts. And a license reassignment unit 3112 that reassigns a license to a stopped job that can be resumed.

  In order to manage the job so that the number of licenses contracted by the user is not exceeded, the license assignment unit 319 assigns a license for each job. When the license allocation unit 319 allocates a license for each job, the license management unit 3110 determines whether the number of licenses corresponding to the job exceeds a predetermined number of contracts. If the predetermined number of contracts is exceeded, the job is stored in the queue again. Such a license management method has been conventionally performed.

  However, in the license management method as described above, the license assigned to the job cannot be used while the job processing is stopped due to the excess capacity of the storage device 34.

  The queue management device 31 includes the license release unit 3111 and the license reassignment unit 3112, so that the license of the job that has been stopped can be used.

  When the stop unit 315 stops the job, the monitoring unit 314 transmits information about the job stop to the license management unit 3110. The license management unit 3110 causes the license release unit 3111 to release the license for the stopped job.

The reduction unit 317 reduces the used capacity of the storage device 34 that has exceeded the capacity, and the monitoring unit 314 determines that the capacity of the storage device 34 has been exceeded. If the determination result is “No”, the license management unit 3110 determines whether there is a vacant license corresponding to the stopped job. If there is, the license reassignment unit 3112 assigns a license to the job. Information regarding the reassignment of the license is transmitted from the license management unit 3110 to the monitoring unit 314. The monitoring unit 314 causes the resuming unit 318 to resume processing of the job.
(Fourth embodiment)

  FIG. 4 is a block diagram showing a fourth embodiment of the present invention.

  A plurality of user terminals 42 (421, 422, 423), a plurality of execution devices 43 (431, 432, 433), a plurality of storage devices 44 (441, 442, 443), and queues connected via a network The queue management device 41, which is the management device 41, includes a registration unit 411, an allocation unit 412, a distribution unit 413, a monitoring unit 414, a stop unit 415, an allocation change unit 416, a reduction unit 417, and a restart. A section 418, a license allocation section 419, a license management section 4110, a license release section 4111, and a license reassignment section 4112. This is the same as FIG. The description of each component is the same as the description of FIG. 1, FIG. 2, and FIG.

  Further, a table that associates the user terminal 42, the job input from the user terminal 42, the processing stage of the job, the storage device 44 that stores the output file of the job, and the capacity excess of the storage device 44. A database 4113 can be included.

  An example of the table included in the database 4113 is shown in FIGS. FIG. 5 shows identification information (user ID) of the user terminal 42, contact information (mail address) of the user terminal, and identification information (storage device 44) that stores the output file of the job input from the user terminal 42. Storage device ID). FIG. 6 is a table in which a user ID, job identification information (job ID) input from the user terminal 42, and a processing stage of the job are combined. FIG. 7 is a table in which the storage device ID and the capacity excess determination information of the storage device 44 are combined.

  An example of an allocation method using the database 4113 will be specifically described. For example, when FIG. 5 and FIG. 6 are associated with a user ID and a storage device ID is requested instead of the user ID, the table shown in FIG. 8 is obtained. The allocation unit 412 can allocate the storage device 44 as a storage destination in association with the job using this table.

  An example of the monitoring method and the allocation changing method using the database 4113 will be specifically described. For example, when the user terminal 421 inputs a job with job ID JOB001, the input information of the job is registered in the database 4113 from the user terminal 421. The monitoring unit 414 that acquired the information in which the job is registered in the database 4113 determines that the job processing stage is “being queued”, and rewrites the table in FIG. 6.

  The distribution unit 413 distributes the job to the execution device 431. The monitoring unit 414 that has acquired the information on the distribution of the job from the distribution unit 413 determines that the job processing stage is “in execution” and rewrites the table in FIG. 6.

  While the execution device 431 is executing the job, if the monitoring unit 414 determines that the storage device 441 that is the storage destination of the job exceeds the capacity, the stop unit 415 causes the execution device 431 to process the job. Stop. The monitoring unit 414 transmits information indicating that the processing of the job has been stopped to the license management unit 4110 and the allocation change unit 416. Also, the monitoring unit 414 warns the user terminal 421 that the processing of the job has been stopped, using the mail address registered in the table of FIG. The license management unit 4110 causes the license release unit 4111 to release the license of the stopped job. The assignment changing unit 416 rewrites the tables of FIGS. 5, 6, and 7 registered in the database 4113. The user terminal 421 (user ID 421) is associated with the storage device 442 (storage device ID 442) that does not exceed the capacity, the processing stage of the job is set to “stopped”, and the capacity excess determination of the storage device 441 is rewritten to “Yes”. .

  The job with the job ID “JOB003” of “Queueing” input from the same user terminal 421 as the job of “Stopped” is taken out of the queue and assigned a license. The allocation unit 412 allocates the storage device 442 as a storage destination using the table of FIG. 8 created by associating the table of FIG. 5 and FIG. 6 rewritten to the allocation change unit 416 with the user ID.

  The reduction unit 417 reduces the used capacity of the storage device 441. The monitoring unit 414 determines whether the capacity of the storage device 441 is exceeded. If the determination result is “No”, the license management unit 4110 determines whether the number of licenses corresponding to the job exceeds a predetermined number of contracts. If the predetermined number of contracts is not exceeded, the license reassignment unit 4112 assigns a license to the job. Information about the reassignment of the license to the job is transmitted from the license management unit 4110 to the monitoring unit 414. The monitoring unit 414 causes the resuming unit 418 to resume processing of the job. Further, the monitoring unit 414 determines that the job processing stage is “executing” and rewrites the table of FIG. 6.

  The execution device 431 stores the output file of the job in the storage device 441. The monitoring unit 414 that acquired the information indicating the completion of the job processing from the execution device 431 determines that the job processing stage is “finished” and rewrites the table of FIG. 6.

  The user terminal 42 can include a display unit (not shown) that displays monitoring information acquired from the monitoring unit 414. The monitoring information can have any of the information shown in the tables of FIGS. 5, 6, and 7 registered in the database 4113.

  FIG. 9 is a flowchart showing a processing flow of the fourth embodiment.

  First, the registration unit 411 registers a job input from the user terminal 42 in a queue. At this time, new job information is registered in the database 4113 from the user terminal 42 (S901).

  When the processing stage of another job having the same user ID as that job becomes “stopped” while the job is stored in the queue (S902), information is acquired from the monitoring unit 414 and assigned. The changing unit 416 rewrites the tables of FIGS. 5, 6 and 7 registered in the database 4113 (S903).

  Take the job at the head of the queue. The license management unit 4110 determines whether the number of licenses corresponding to the job exceeds a predetermined number of contracts. If the determination result is “Yes”, the job is returned to the queue again (S904). If the determination result is “No”, the license assignment unit 419 assigns a license to the job (S905).

  When FIG. 5 and FIG. 6 included in the database 4113 are associated with a user ID and a job ID is requested instead of the user ID, the table shown in FIG. 8 is obtained. The allocating unit 412 uses this table to associate and allocate the storage device 44 that is the storage destination to the job (S906).

  The job to which the storage destination is assigned is distributed to the execution device 43 that can be processed by the distribution unit 413 (S907) and executed (S908). If the monitoring unit 414 determines that the storage device 44 serving as the storage destination of the job exceeds the capacity during execution of the job (S909), the execution device 43 stops processing the job (S910).

  When the “in-execution” job becomes “stopped”, the license management unit 4110 that has acquired information from the monitoring unit 414 causes the license release unit 4111 to release the license of the stopped job (S911).

  When the “in-execution” job becomes “stopped”, the reduction unit 417 that has acquired the information indicating that the job is “stopped” from the monitoring unit 414 is determined that one of the execution devices 43 has exceeded the capacity. The stored files in the storage device 44 are reduced (S912). The monitoring unit 414 determines whether the capacity of the storage device 44 is exceeded. If the determination result is “Yes”, the processing in the reduction unit 417 is repeated again (S913).

  If the determination result is “No”, the license management unit 4110 determines whether the number of licenses corresponding to the job exceeds the predetermined number of contracts. If the determination result is “No”, the determination is repeated until the license becomes empty (S914). If the determination result is “Yes”, the license reassignment unit 4112 assigns a license to the job (S915). Information about the reassignment of the license to the job is transmitted from the license management unit 4110 to the monitoring unit 414. The monitoring unit 414 causes the resuming unit 418 to resume processing of the job (S916).

  The execution device 43 stores the output file of the job in the storage device 44 (S917), and the processing of the job ends.

  The processing flow of the fourth embodiment has been described above. However, in the processing flow of the third embodiment as well, only the method for realizing the steps of registration (S901), allocation change (S903), and allocation (S906) changes. The order does not change.

  In the processing flow of the second embodiment, the steps of determining the number of licenses (S904, S914), license allocation (S905), license release (S911), and license reassignment (S915) are excluded, but other steps are performed. The order is the same.

  Further, in the first embodiment, the reduction (S912) and resumption (S916) steps are excluded from the processing flow of the second embodiment. Also, when the job is stopped due to the excess of capacity, there is no resumption means, and therefore the processing of the job is ended, which is different from the processing flow of the other embodiments.

  As described above, according to the queue management device of the embodiment of the present invention, the processing to be stopped due to the excess of the capacity of the storage device is limited to some jobs, so the processing of other jobs is processed smoothly. be able to.

  In the conventional queue management device, the target to be stopped when the storage device capacity is exceeded is the queue management device. On the other hand, in the queue management apparatus of the present invention, the target to be stopped when the capacity of the storage device is exceeded is a job being executed with the storage device as the storage destination, which is limited as compared with the prior art.

It is also possible to resume processing of a job that has been stopped. The license assigned to the stopped job can be released and used for other jobs. As a result, it is possible to further suppress the loss caused to the entire system by the stop of job processing due to the excess of the storage device capacity.
(Appendix)
(Invention 1)
A network is connected to a plurality of user terminals that input jobs to be executed, a plurality of execution devices that execute the jobs, and a plurality of storage devices that store output files output from the execution devices as processing results of the jobs. A queue management device connected via
The queue management device includes:
Registration means for registering the job submitted from the user terminal in a queue;
Allocating means for allocating the storage device that is the storage destination of the output file of the job to the job;
Distribution means for distributing the job to the execution device capable of processing the job;
Monitoring means for monitoring the job processing stage and excess storage capacity of the storage device;
When the monitoring unit determines that the storage device exceeds the capacity, a stopping unit that stops processing of the job being executed with the storage device as a storage destination;
An assignment changing unit for changing the assignment of the storage device to another storage device with respect to another job before execution whose processing destination is the same as the job when processing of the job is stopped;
A queue management device comprising:
(Invention 2)
In the queue management device according to the first aspect of the present invention,
The monitoring means acquires the used capacity information of the storage device, stores the output file, and determines that the storage device exceeds the capacity when the used capacity of the storage device exceeds a predetermined upper limit value. A featured queue management device.
(Invention 3)
In the queue management device according to the first aspect of the present invention,
The monitoring means acquires the free space information of the storage device, and determines that the storage device is over capacity when the capacity required for storing the output file exceeds the free space .
(Invention 4)
In the queue management device according to any one of the inventions 1 to 3,
The queue management apparatus according to claim 1, wherein the processing steps include “cueing”, “running”, “stopping”, and “ending”.
(Invention 5)
In the queue management device according to any one of the inventions 1 to 4,
The queue management device includes:
Reduction means for reducing the used capacity of the storage device that has exceeded the capacity;
As a result of reducing the used capacity of the storage device, when the monitoring unit determines that the storage device does not exceed the capacity, a restart unit that resumes processing of the job that has been stopped;
A queue management device comprising:
(Invention 6)
In the queue management device according to the invention 5,
The queue management apparatus, wherein the reduction unit compresses an uncompressed and stored file that is not used by the job and stored in the storage device that has exceeded the capacity.
(Invention 7)
In the queue management device according to the invention 5 or 6,
The queue management apparatus, wherein the reduction means deletes the unnecessary stored file stored in the storage device that has exceeded its capacity.
(Invention 8)
In the queue management device according to any one of inventions 5 to 7,
The queue management apparatus according to claim 1, wherein the reduction unit moves a part or all of the stored files stored in the storage device whose capacity has been exceeded to another storage device.
(Invention 9)
In the queue management device according to any one of inventions 5 to 8,
The queue management device includes:
A license assigning means for assigning a license for each job;
License management means for managing the number of assigned licenses so as not to exceed the number of contracts;
A license releasing means for releasing the license of the job that has been stopped;
A license reassignment unit that reassigns the license to the stopped job that can be resumed;
A queue management device comprising:
(Invention 10)
In the queue management device according to any one of the inventions 1 to 9,
A table associating the user terminal, the job input from the user terminal, the processing stage of the job, the storage device for storing the output file of the job, and an overcapacity determination of the storage device; A queue management device comprising a database having the same.
(Invention 11)
In the queue management device according to the tenth aspect,
The queue management device, wherein the allocating unit allocates the storage device serving as a storage destination for the job using information from the database.
(Invention 12)
In the queue management device according to invention 10 or 11,
The queue management apparatus characterized in that the monitoring means monitors, in association with the processing stage of the job and an excess capacity of the storage device, for each user terminal, using information from the database.
(Invention 13)
In the queue management device according to the invention 12,
When the processing of the job is stopped, the monitoring unit changes the allocation so as to change the storage device corresponding to the user terminal that has input the job to another storage device that is not determined to have exceeded the capacity. A queue management apparatus characterized by causing the database to be changed.
(Invention 14)
In the queue management device according to the invention 13,
The allocation unit is not determined to have exceeded the capacity of another job before execution whose storage destination is the same as the stopped job, using information from the database changed by the allocation change unit. A queue management device characterized by assigning another storage device.
(Invention 15)
In the queue management device according to any one of inventions 10 to 14,
The database includes contact information of the user terminal, and the monitoring unit uses the contact information for the user terminal that has input the job when processing of the job is stopped. A queue management apparatus that reports that the job is stopped.
(Invention 16)
A program for controlling a queue management device, the queue management device
Registering jobs in the queue in the order submitted by the user terminal;
Assigning a storage device, which is a storage destination of the output file of the job, to the job;
Allocating the job to execution devices capable of processing the job;
If it is determined that the storage device is over capacity, stopping the processing of the job being executed with the storage device as a storage destination;
When the processing of the job is stopped, changing the storage device assignment to another storage device for another job before execution whose storage destination is the same as the job;
A control program to execute.
(Invention 17)
In the control program according to the sixteenth aspect of the present invention, for the queue management device,
Reducing the used capacity of the storage device that has exceeded capacity;
Resuming processing of the job that has been stopped;
A control program to execute.
(Invention 18)
In the control program according to the seventeenth aspect of the present invention, for the queue management device,
Assigning a license for each job;
Releasing the license for the suspended job;
Re-assigning the license to the suspended job that has become resumable;
A control program to execute.
(Invention 19)
A plurality of user terminals that input jobs to be executed; a plurality of execution devices that execute the jobs; a plurality of storage devices that store output files output from the execution devices as processing results of the jobs; and a queue management device A job processing system comprising:
The queue management device includes:
Registration means for registering the jobs in a queue in the order of input from the user terminal;
Allocating means for allocating the storage device that is the storage destination of the output file of the job to the job;
Distribution means for distributing the job to the execution device capable of processing the job;
Monitoring means for monitoring the job processing stage and excess storage capacity of the storage device;
When the monitoring unit determines that the storage device exceeds the capacity, a stopping unit that stops processing of the job being executed with the storage device as a storage destination;
An assignment changing unit for changing the assignment of the storage device to another storage device with respect to another job before execution having the same storage destination as the job when processing of the job is stopped;
A job processing system comprising:
(Invention 20)
In the job processing system according to Invention 19,
The job processing system according to claim 1, wherein the user terminal includes display means for displaying monitoring information acquired from the monitoring means.
(Invention 21)
In the job processing system according to the invention 19 or 20,
The queue management device includes:
Reduction means for reducing the used capacity of the storage device that has exceeded the capacity;
As a result of reducing the used capacity of the storage device, when the monitoring unit determines that the storage device does not exceed the capacity, a restart unit that resumes processing of the job that has been stopped;
A job processing system comprising:
(Invention 22)
In the job processing system according to the invention 21,
The queue management device includes:
A license assigning means for assigning a license for each job;
License management means for managing the number of assigned licenses so as not to exceed the number of contracts;
A license releasing means for releasing the license of the job that has been stopped;
A license reassignment unit that reassigns the license to the stopped job that can be resumed;
A job processing system comprising:
(Invention 23)
A method for controlling a job processing system,
Registering jobs in the queue in the order submitted by the user terminal;
Allocating the job to a storage device that is a storage destination of the output file of the job;
Allocating the job to execution devices capable of processing the job;
If it is determined that the storage device is over capacity, stopping the processing of the job being executed with the storage device as a storage destination;
When the processing of the job is stopped, changing the storage device assignment to another storage device for another job before execution whose storage destination is the same as the job;
The control method characterized by including.
(Invention 24)
In the control method of the job processing system according to the invention 23,
Reducing the used capacity of the storage device that has exceeded capacity;
Resuming processing of the job that has been stopped;
The control method characterized by including.
(Invention 25)
In the control method of the job processing system according to invention 24,
Assigning a license for each job;
Releasing the license for the suspended job;
Re-assigning the license to the suspended job that has become resumable;
The control method characterized by including.

1 is a configuration diagram of a queue management device according to a first embodiment and a job processing system including the same. FIG. It is a lineblock diagram of a queue management device concerning a 2nd embodiment, and a job processing system provided with the same. It is a block diagram of the queue management apparatus which concerns on 3rd Embodiment, and a job processing system provided with the same. It is a block diagram of the queue management apparatus which concerns on 4th Embodiment, and a job processing system provided with the same. It is an example of the table registered into the database contained in 4th Embodiment. It is an example of the table registered into the database contained in 4th Embodiment. It is an example of the table registered into the database contained in 4th Embodiment. 7 is an example of a table created by associating the tables of FIGS. 5 and 6 with a user ID. It is a flowchart which shows the processing flow of 4th Embodiment.

Explanation of symbols

DESCRIPTION OF SYMBOLS 11 Queue management apparatus 111 Registration part 112 Allocation part 113 Distribution part 114 Monitoring part 115 Stop part 116 Allocation change part 12 (121-123) User terminal 13 (131-133) Execution apparatus 14 (141-143) Storage device 21 Queue management Device 211 Registration unit 212 Allocation unit 213 Distribution unit 214 Monitoring unit 215 Stop unit 216 Allocation change unit 217 Reduction unit 218 Resume unit 22 (221-223) User terminal 23 (231-233) Execution device 24 (241-243) Storage device 31 Queue management device 311 Registration unit 312 Allocation unit 313 Distribution unit 314 Monitoring unit 315 Stop unit 316 Allocation change unit 317 Reduction unit 318 Resume unit 319 License allocation unit 3110 License management unit 3111 License release unit 3112 License re-allocation unit 32 (32 1 to 323) User terminal 33 (331 to 333) Execution device 34 (341 to 343) Storage device 41 Queue management device 411 Registration unit 412 Allocation unit 413 Distribution unit 414 Monitoring unit 415 Stop unit 416 Allocation change unit 417 Reduction unit 418 Resume Unit 419 License allocation unit 4110 License management unit 4111 License release unit 4112 License re-allocation unit 4113 Database 42 (421-423) User terminal 43 (431-433) Execution device 44 (441-443) Storage device

Claims (25)

A network is connected to a plurality of user terminals that input jobs to be executed, a plurality of execution devices that execute the jobs, and a plurality of storage devices that store output files output from the execution devices as processing results of the jobs. A queue management device connected via
The network connects the plurality of execution devices and the plurality of storage devices in a many-to-many manner.
The queue management device includes:
Registration means for registering the job submitted from the user terminal in a queue;
Allocating means for allocating the storage device that is the storage destination of the output file of the job to the job;
Distribution means for distributing the job to the execution device capable of processing the job;
Monitoring means for monitoring excess storage capacity of the storage device;
When the monitoring unit determines that the storage device exceeds the capacity, a stopping unit that stops processing of the job being executed with the storage device as a storage destination;
An assignment changing unit for changing the assignment of the storage device to another storage device with respect to another job before execution whose processing destination is the same as the job when processing of the job is stopped;
A queue management device comprising: The queue management device according to claim 1,
The monitoring means acquires the used capacity information of the storage device, stores the output file, and determines that the storage device exceeds the capacity when the used capacity of the storage device exceeds a predetermined upper limit value. A featured queue management device. The queue management device according to claim 1,
The monitoring means acquires the free space information of the storage device, and determines that the storage device is over capacity when the capacity required for storing the output file exceeds the free space . The queue management device according to any one of claims 1 to 3,
The queue management apparatus according to claim 1, wherein the processing steps include “cueing”, “running”, “stopping”, and “ending”. The queue management device according to any one of claims 1 to 4,
The queue management device includes:
Reduction means for reducing the used capacity of the storage device that has exceeded the capacity;
As a result of reducing the used capacity of the storage device, when the monitoring unit determines that the storage device does not exceed the capacity, a restart unit that resumes processing of the job that has been stopped;
A queue management device comprising: The queue management device according to claim 5, wherein
The queue management apparatus, wherein the reduction unit compresses an uncompressed and stored file that is not used by the job and stored in the storage device that has exceeded the capacity. In the queue management device according to claim 5 or 6,
The queue management apparatus, wherein the reduction means deletes the unnecessary stored file stored in the storage device that has exceeded its capacity. The queue management device according to any one of claims 5 to 7,
The queue management apparatus according to claim 1, wherein the reduction unit moves a part or all of the stored files stored in the storage device whose capacity has been exceeded to another storage device. The queue management device according to any one of claims 5 to 8,
The queue management device includes:
A license assigning means for assigning a license for each job;
License management means for managing the number of assigned licenses so as not to exceed the number of contracts;
A license releasing means for releasing the license of the job that has been stopped;
A license reassignment unit that reassigns the license to the stopped job that can be resumed;
A queue management device comprising: The queue management device according to any one of claims 1 to 9,
A table associating the user terminal, the job input from the user terminal, the processing stage of the job, the storage device for storing the output file of the job, and an overcapacity determination of the storage device; A queue management device comprising a database having the same. The queue management device according to claim 10, wherein
The queue management device, wherein the allocating unit allocates the storage device serving as a storage destination for the job using information from the database. The queue management device according to claim 10 or 11,
The queue management apparatus, wherein the monitoring unit monitors an excess capacity of the storage device for each of the user terminals using information from the database. The queue management device according to claim 12, wherein
When the processing of the job is stopped, the monitoring unit changes the allocation so as to change the storage device corresponding to the user terminal that has input the job to another storage device that is not determined to have exceeded the capacity. A queue management apparatus characterized by causing the database to be changed. The queue management device according to claim 13, wherein
The allocation unit is not determined to have exceeded the capacity of another job before execution whose storage destination is the same as the stopped job, using information from the database changed by the allocation change unit. A queue management device characterized by assigning another storage device. The queue management device according to any one of claims 10 to 14,
The database includes contact information of the user terminal, and the monitoring unit uses the contact information for the user terminal that has input the job when processing of the job is stopped. A queue management apparatus that reports that the job is stopped. A network is connected to a plurality of user terminals that input jobs to be executed, a plurality of execution devices that execute the jobs, and a plurality of storage devices that store output files output from the execution devices as processing results of the jobs. A control program for controlling a queue management device connected via
The network connects the plurality of execution devices and the plurality of storage devices in a many-to-many manner.
The control program provides the queue management device with
And registering the job in the queue in the order it was input from said user terminal,
A step of pre-assigning the crisis憶device to the job,
A step of allocating the job to the front you line device,
If it is determined that the storage device is over capacity, stopping the processing of the job being executed with the storage device as a storage destination;
When the processing of the job is stopped, changing the storage device assignment to another storage device for another job before execution whose storage destination is the same as the job;
A control program to execute. The control program according to claim 16, wherein the queue management device
Reducing the used capacity of the storage device that has exceeded capacity;
Resuming processing of the job that has been stopped;
A control program to execute. The control program according to claim 17, wherein for the queue management device,
Assigning a license for each job;
Releasing the license for the suspended job;
Re-assigning the license to the suspended job that has become resumable;
A control program to execute. A plurality of user terminals for inputting a job to be executed; a plurality of execution devices for executing the job; a plurality of storage devices for storing output files output from the execution device as processing results of the job ; A job processing system comprising: a queue management device connected to a network in which an execution device and the plurality of storage devices are connected in a many-to-many manner;
The queue management device includes:
Registration means for registering the jobs in a queue in the order of input from the user terminal;
Allocating means for allocating the storage device that is the storage destination of the output file of the job to the job;
Distribution means for distributing the job to the execution device capable of processing the job;
Monitoring means for monitoring excess storage capacity of the storage device;
When the monitoring unit determines that the storage device exceeds the capacity, a stopping unit that stops processing of the job being executed with the storage device as a storage destination;
An assignment changing unit for changing the assignment of the storage device to another storage device with respect to another job before execution having the same storage destination as the job when processing of the job is stopped;
A job processing system comprising: The job processing system according to claim 19, wherein
The job processing system according to claim 1, wherein the user terminal includes display means for displaying monitoring information acquired from the monitoring means. The job processing system according to claim 19 or 20,
The queue management device includes:
Reduction means for reducing the used capacity of the storage device that has exceeded the capacity;
As a result of reducing the used capacity of the storage device, when the monitoring unit determines that the storage device does not exceed the capacity, a restart unit that resumes processing of the job that has been stopped;
A job processing system comprising: The job processing system according to claim 21, wherein
The queue management device includes:
A license assigning means for assigning a license for each job;
License management means for managing the number of assigned licenses so as not to exceed the number of contracts;
A license releasing means for releasing the license of the job that has been stopped;
A license reassignment unit that reassigns the license to the stopped job that can be resumed;
A job processing system comprising: A plurality of user terminals for inputting a job to be executed; a plurality of execution devices for executing the job; a plurality of storage devices for storing output files output from the execution device as processing results of the job; A control method of a job processing system comprising: a queue management device connected to a network in which an execution device and the plurality of storage devices are connected in a many-to-many manner;
And registering the job in the queue in the order it was input from said user terminal,
And allocating the job to the front listen憶device,
A step of allocating the job to the front you line device,
If it is determined that the storage device is over capacity, stopping the processing of the job being executed with the storage device as a storage destination;
When the processing of the job is stopped, changing the storage device assignment to another storage device for another job before execution whose storage destination is the same as the job;
The control method characterized by including. The method of controlling a job processing system according to claim 23,
Reducing the used capacity of the storage device that has exceeded capacity;
Resuming processing of the job that has been stopped;
The control method characterized by including. The method of controlling a job processing system according to claim 24,
Assigning a license for each job;
Releasing the license for the suspended job;
Re-assigning the license to the suspended job that has become resumable;
The control method characterized by including.

Images