JP5086934B2 - Data processing apparatus and program - Google Patents

Description

  The present invention relates to a data processing apparatus and a program, and in particular, a data processing apparatus for updating update target data stored in a storage area of a storage unit based on update data that is sequentially input, and a computer to the data The present invention relates to a data processing program for functioning as a processing device.

  In a computer system of a financial institution, in a transaction details management system that updates and manages a database (transaction details DB) that stores transaction details of various financial transactions, in order to immediately determine individual financial transactions that are instructed to be executed Every time a message representing an individual financial transaction is received, as shown in FIG. 7 as an example, the contents of the received message are immediately reflected in the transaction details DB. In addition, although the priority is lower than the immediate reflection to the transaction details DB, there is a need to grasp the cash flow and settlement status of the financial institution as a whole, and in order to satisfy this need, in the above transaction details management system, Multiple types of status management tables for registering information representing the status of cash flow and settlement (in the example of FIG. 7, “number of cases by status”, “status of cash flow”, “planned cash flow” and “monitoring information” Each situation management table) is appropriately updated according to the contents of the received message, and the contents of each situation management table are displayed on the display in accordance with instructions from the operator.

  As shown in FIG. 7 in detail, the status management table is updated by generating update data for updating any status management table based on the contents of the received message every time a message is received. The generated update data is put at the end of the queue (queue), the update data is taken out from the head of the queue, and the status management table corresponding to the taken out update data is updated according to the fetched update data. Made by. In addition, since it is not desirable that the delay time until the change in the actual cash flow or settlement status is reflected on the display is increased, the transaction detail management system takes out the update data from the head of the queue and deals with it. The process of updating the status management table is performed in parallel by a plurality of processes (table update process).

  In relation to the above, Patent Document 1 discloses that when a data file is updated based on a record update request from a transaction, simultaneous access to the record of the requested data file is exclusively controlled, and the record of the requested data file is updated. Is executed on the first buffer, and the record update history on the first buffer is generated for each record. When the transaction is confirmed, the record unit corresponding to the generated transaction is recorded. A technique for recording an update history in a journal file and updating a data file in units of blocks through a second buffer based on the update history recorded in the journal file has been disclosed. By performing exclusive control between transactions in units of records Improve the parallel effectiveness of transactions It is.

Further, in Patent Document 2, all processing data is temporarily placed in a memory and data update processing is performed on the memory. When all processing is completed or a certain unit of updating is completed, the data is stored on the disk. A technique for realizing high-speed transaction processing by storing is disclosed.
JP 9-62550 A JP 2007-314691 A

  In a configuration in which multiple processes (also referred to as instances, threads, or middle) that operate in parallel perform processing for updating the same table or DB asynchronously as in the transaction details management system described above, different processes are used. Access to the same table or DB may compete and data inconsistency may occur. Regarding this data inconsistency, as in the technique described in Patent Document 1, for example, while a certain process is updating a table or the like, exclusive control such as applying a lock that prohibits updating of the same table by another process is performed. It can be avoided by doing. However, when exclusive control is performed, there is a problem that overhead is increased and processing efficiency is lowered by waiting for the other access until one access is completed when access conflict occurs.

  As an example, in the configuration of FIG. 7, when the number of received messages in the transaction details management system reaches tens of thousands / minute, tens of thousands of update data stays in the queue, and the update data enters the queue. It takes about several minutes before the status management table is updated based on the update data.

  On the other hand, the technique described in Patent Document 1 is a technique for reducing the frequency of occurrence of access competition by reducing the unit for performing exclusive control, and the overhead due to performing exclusive control cannot be reduced. Since the frequency of occurrence of competition cannot be reduced to 0, a significant improvement in processing efficiency cannot be expected. In addition, since the technology described in Patent Document 2 saves data on a disk when a certain unit of update is completed, it takes time until the update target table or DB is actually updated. As in the transaction details management system described above, it is not suitable when early update of the update target table or DB is required.

  The present invention has been made in consideration of the above facts, and obtains a data processing apparatus and a data processing program capable of achieving both prevention of data inconsistency and improvement in processing efficiency when updating update target data in parallel Is the purpose.

In order to achieve the above object, the data processing apparatus according to the first aspect of the present invention includes update means used for updating the update target data in order, and holding means for holding the input update data, Storage means for storing the data to be updated in m (m ≧ 2) storage areas, respectively, operate in parallel with each other, take out the update data from the holding means, and store m data in the storage means N (n ≧ 2 and n ≦ m) processing means for repeating the process of updating the update target data stored in different storage areas of the areas based on the extracted update data, and a variable viewed contains a variable storage means for storing the total number n of x and the processing unit, wherein the processing means, each time retrieving the update data from said holding means, the values and the total number n of the variable x from the variable storage unit Read the value, update the value of the variable x stored in the variable storage means, and based on the remainder value obtained by dividing the value of the read variable x by the total number n of the processing means, m of the storage means A storage area for updating the update target data is determined among the storage areas .

  According to the first aspect of the present invention, update data used for updating the update target data is sequentially input, and the input update data is respectively held in the holding means. The storage means has m storage areas for storing update target data (m ≧ 2), and the update target data is stored in m storage areas. The invention described in claim 1 is provided with n (n ≧ 2 and n ≦ m) processing means operating in parallel with each other, and each processing means takes out update data from the holding means, and stores the storage means. The process of updating the update target data stored in different storage areas among the m storage areas is repeated based on the extracted update data.

  Thus, according to the first aspect of the present invention, the n processing means operating in parallel with each other update different update target data stored in different storage areas, so that they are stored in the individual storage areas. Each update target data is updated by a single processing unit, and a certain update target data is updated almost simultaneously by a plurality of processing means, so that it is possible to prevent data inconsistencies and the like from occurring. At the same time, it is possible to prevent access conflicts from occurring when a plurality of processing means attempt to update the same update target data almost simultaneously.

In addition, as described in claim 7 , the update target data is output by reading each of the update target data stored in the m storage areas of the storage unit, and outputting the read m update target data as a single unit. However, in this case, only the update target data is read and no update is performed. Therefore, for some update target data, the update by the processing means and the above integration are performed. Even if the reading is performed almost simultaneously, there will be no contradiction in the updated data. Therefore, according to the first aspect of the present invention, it is possible to achieve both the prevention of data inconsistency and the improvement of the processing efficiency when the update target data is updated in parallel.

  In the first aspect of the present invention, the configuration in which the individual processing means updates the update target data stored in different storage areas means, for example, that the update target data is updated with respect to the individual processing means. As identification information for identifying the storage area to be updated, identification information that points to different storage areas is set, and when updating the update target data, the update target data is updated by referring to the set identification information. This method can be realized by configuring individual processing means so as to identify the storage area to be performed. However, this method can be realized, for example, because the number of update data input per unit time has changed significantly. This is not appropriate when there is a possibility of increasing or decreasing the number of processing means during operation of the data processing apparatus.

This consideration, invention of claim 1, further comprising a variable storage means for storing the total number n of the variable x and processing means, the processing means, each time retrieving the update data from the holding means, the variable storage unit reads the value of the values and the total number n of the variable x, and updates the value of the variable x stored in the variable storage unit (e.g., either incremented by 1, you decremented by 1) together with the value of the read variable x based on the value of the remainder obtained by dividing by the total number n of processing means is configured to determine a storage area for updating the update target data among the m storage area of the storage means. According to the first aspect of the present invention, each time the processing means fetches the update data from the holding means, the value of the total number n of the processing means is confirmed, and the update target data is updated using the confirmed total number n. Therefore, when the number of processing means is increased or decreased during operation of the data processing apparatus, it is not necessary to temporarily stop the processing of the processing means in operation.

According to the first aspect of the present invention, each processing means reads and updates the value of the variable x stored in the variable storage means, so that the reading and updating of the value of the variable x can be performed in a very short time. Although it is an extremely rare case because it is a simple process to complete, the value of the variable x stored in the variable storage means is simultaneously read out by a plurality of processing means, so that the variable x read out by a plurality of processing means The same update target data is updated almost simultaneously by a plurality of processing means, and there is a risk of inconsistency in the update target data. This problem can be solved by performing exclusive control for access to the variable x or performing exclusive control for access to individual storage areas (update of update target data) by individual processing means. In this case, although the overhead is increased by performing exclusive control, as is clear from the above description, the frequency of access contention is very low. It can be suppressed to the limit.

Further, in the first aspect of the present invention, the number of processing means may be increased or decreased manually during operation of the data processing apparatus according to the present invention. For example, as described in the second aspect , the processing means Control means for determining whether or not it is necessary to increase or decrease the number, and increasing or decreasing the number of processing means according to the determination result and updating the value of the total number n stored in the variable storage means May be provided.

Further, in the invention described in claim 2, the determination as to whether the number of processing means needs to be increased or decreased by the control means is held in the holding means as described in claim 3 , for example. This can be done based on the number of update data. As a result, for example, when the number of update data input per unit time changes significantly, the number of processing means is automatically increased or decreased according to the change, and the operation is performed. The number of processing means can be optimized in accordance with the number of update data input per unit time and changes thereof.

Further, in the invention according to claim 2 , when each processing means is realized by executing a predetermined process for executing a program for causing a computer to function as a processing means by the computer, the control means includes, for example, According to a fourth aspect of the present invention, the number of processing means is increased by additionally generating a predetermined process, and the number of processing means is decreased by stopping the operation of the predetermined process in operation. be able to.

Further, in the invention according to any one of claims 1 to 4 , the processing means updates the update target data itself among a plurality of storage areas of the storage means, for example, as described in claim 5. After the storage area is locked and the update target data stored in the locked storage area is updated, the storage area may be unlocked. In particular, in the invention described in claim 2, in order to eliminate the possibility of inconsistency or the like in the update target data, exclusive control is performed on the access to the variable x, or each storage area is accessed by each processing means ( Update of the data to be updated) must be performed, but the inventor of the present application has confirmed that performing the exclusive control on the access to the storage area can suppress an increase in load and a decrease in processing efficiency. Therefore, the invention described in claim 5 is particularly effective when the invention described in claim 1 is carried out.

Further, in the invention according to any one of claims 1 to 5 , the number of storage means is not limited to one. For example, as described in claim 6 , p storage means are provided, The storage areas of the individual storage units store different types of update target data among the p types of update target data, and the update data input to the holding unit includes the p types of update target data. P types of update data used for different update target data may be mixed. In this case, the processing means takes out the update data from the holding means, selects a storage means corresponding to the type of the update data taken out from the p storage means, and stores it in any storage area of the selected storage means. The stored update target data can be updated based on the extracted update data.

Further, in the invention according to any one of claims 1 to 6 , for example, as described in claim 7 , each update target data stored in m storage areas of the storage means is read and read. It is preferable to further provide integration means for integrating the m update target data into a single data and outputting it. As a result, the plurality of processing means repeats the process of updating the update target data stored in different storage areas among the m storage areas of the storage means based on the update data extracted from the holding means. In the configuration (configuration of the present invention), it is possible to obtain an output equivalent to a configuration in which only the single update target data is updated and the single update target data is appropriately output.

Further, in the invention described in claim 2, as described in claim 8, the total number n is read from the variable storage means, and the first to nth n number of m storage areas of the storage means are read out. The system further includes an integration unit that reads each update target data stored in the storage area, and integrates and outputs the read n update target data into a single data, and the control unit reduces the number of processing units. If the update target data stored in the nth storage area of the m storage areas of the storage means is integrated with the update target data stored in another storage area, the total number n is decreased. It is preferable to constitute so as to be.
As a result, the number of storage areas in which the update target data is stored among the m storage areas of the storage means always matches the total number n of the processing means. Therefore, the number of pieces of update target data to be integrated and output by the integration unit into a single data is n, and the update target data stored in m storage areas is always integrated into a single data and output. Compared with the case where it does, the efficiency improvement of the process by an integrated means is realizable.

The data processing program according to the ninth aspect of the present invention includes update data used for updating the update target data in order, and includes holding means for holding the input update data, and m (m ≧ m ≧) 2) A storage unit for storing each of the update target data in a storage area provided, or a computer connected to the storage unit operates in parallel with each other, and the update data is extracted from the holding unit , Repeating the process of updating the update target data stored in different storage areas among the m storage areas of the storage means based on the retrieved update data (n ≧ 2 and n ≦ m), and a data processing program for functioning as a variable storage means for storing the variable x and the total number n of the processing means. The processing unit reads the value of the variable x and the value of the total number n from the variable storage unit each time the update data is extracted from the holding unit, and updates the value of the variable x stored in the variable storage unit. Based on the remainder value obtained by dividing the value of the read variable x by the total number n of the processing means, a storage area for updating the update target data is determined from the m storage areas of the storage means.
A data processing program according to a ninth aspect of the present invention includes the holding unit and the storage unit or a computer connected to the storage unit, the n processing unit and Since it is a program for functioning as variable storage means , when the computer executes the data processing program according to the invention of claim 9, the computer functions as the data processing device of claim 1, Similarly to the first aspect of the invention, it is possible to achieve both the prevention of data inconsistency and the improvement of the processing efficiency when the update target data is updated in parallel.

  According to a tenth aspect of the present invention, there is provided a data processing program according to the present invention, wherein update data used for updating the update target data are sequentially input, and each of the input update data is held, and m (m ≧ m ≧ m) 2) The data processing according to any one of claims 1 to 8, further comprising: a storage unit that stores the update target data in a storage area provided; or a computer connected to the storage unit. It is made to function as each means which comprises an apparatus.

  [10] The data processing program is a program for causing the computer to function as each means constituting the data processing device according to any one of [1] to [8]. By executing the data processing program according to the above, the computer functions as the data processing device according to any one of claims 1 to 8, and at least the data when the update target data is updated in parallel It is possible to achieve both the prevention of contradiction and the improvement of the processing efficiency.

  As described above, the present invention takes out update data from the holding means that holds the update data sequentially input in n (n ≧ 2 and n ≦ m) processing means operating in parallel with each other, Since the update target data stored in different storage areas among the m storage areas (m ≧ 2) of the storage means is updated based on the extracted update data, the update target The present invention has an excellent effect that it is possible to achieve both the prevention of data inconsistency and the improvement of processing efficiency when updating data in parallel.

  Hereinafter, an example of an embodiment of the present invention will be described in detail with reference to the drawings. FIG. 1 shows a computer system 10 according to the present embodiment. The computer system 10 according to the present embodiment is installed in a specific financial institution and includes a server computer 12 and a computer network 14 constructed in the specific financial institution. The computer network 14 includes a plurality of computers (for example, branch servers installed at each branch of a specific financial institution) and a plurality of terminals (for example, branch office terminals (for operation by employees of a specific financial institution). Terminal) and ATM (Automatic Teller Machine) are connected to each other via a communication line.

  On the other hand, the server computer 12 includes a CPU 12A, a memory 12B, a storage unit 12C, and a network interface (I / F) unit 12D, and includes a display 18 composed of a CRT, an LCD, etc., a keyboard 20, and a storage 22 for storing a transaction details DB. Are connected to each other. The transaction details DB stores information on transaction details of various financial transactions. Although only one storage 22 is shown in FIG. 1, the transaction detail DB may be stored in a plurality of storages 22. The network I / F unit 12D of the server computer 12 is connected to the above-described computer network 14 via a communication line, and also has a communication line with a computer system (BoJ system) 24 installed at the Bank of Japan. Connected through. The server computer 12, the display 18, the keyboard 20, and the storage 22 function as a transaction details management system that receives messages from the computer network 14 and the Bank of Japan system 24, and updates and manages the transaction details DB according to the received messages.

  In addition, an operating system program, a telegram receiving program, a table update program, a data integration output program, and an operation process number management program are installed in the storage unit 12C of the server computer 12 respectively. Among these programs, each program except for the operating system program is a program for realizing a function of causing the display 18 to display information representing the cash flow and settlement status of the entire specific financial institution with an instruction from the operator as a trigger. This corresponds to the data processing program according to claims 9 and 10. The server computer 12 corresponds to the computer according to the ninth aspect, and functions as a data processing apparatus according to the present invention when these programs are executed by the CPU 12A.

  The storage unit 12C of the server computer 12 stores a status management table group including a number-by-status amount table, a cash advance transition status table, a cash advance schedule record table, and a monitoring information table. The server computer 12 (transaction details management system) is capable of displaying information on a plurality of types of monitor items on the display 18 as information indicating the cash flow and settlement status of the entire specified financial institution, and a status management table group. In each table, different business data corresponding to individual monitor items are registered.

  More specifically, in the number-by-status table of status corresponding to the monitor item “number of cases by status”, as the business data corresponding to “number of cases by status”, the status of settlement (for example, “completed”, “processing in progress”, etc.) ) Data such as the number and amount of financial transactions for each transaction is registered, and in the cash flow status table corresponding to the monitor item “Cash Progress Status”, specific financial data is provided as business data corresponding to “Cash Progress Status” Data indicating the transition of cash flow performance and the future schedule (expectation) for the entire institution is registered, and the cash flow schedule performance table corresponding to the monitor item “Cash flow schedule performance” is set to “Cash flow schedule performance”. As the corresponding business data, data indicating the cash flow schedule and results for each factor is registered, and the monitoring information table corresponding to the monitoring item “monitoring information” As business data corresponding to the monitoring information ", the data representing the cash flow performance of each time zone as a whole specific financial institutions are registered. The business data registered in each table of the status management table group corresponds to the update target data according to the present invention.

  Next, the operation of this embodiment will be described. In the server computer 12, when the power is turned on and the operating system starts operating on the server computer 12, an operation process number management program is read from the storage unit 12C and executed by the CPU 12A for initialization. Thus, the operation process number management process shown in FIG. 5 is performed.

  In this operation process number management process, first, in step 60, it is determined whether or not the current activation factor of the operation process number management process is an initial setting. In this case, the determination is affirmative and the routine proceeds to step 62, where 1 is set as the initial value of the variable x in the storage area for the variable x provided in advance in the memory 12B. In the next step 64, an initial value of the table update process operation number n is set in a storage area of the table update process operation number n provided in the memory 12B in advance. The initial value of the table update process operation number n can be determined according to, for example, the number of messages received by the transaction details management system in the time zone immediately after the start of the operation of the server computer 12, but instead, You may determine according to the maximum value etc. of the message | telegram reception number of the transaction statement management system in operation of the server computer 12.

  In the next step 66, the same number of processes n (table update process) that the CPU 12A executes the table update program stored in the storage unit 12C as the operating number n set in step 64 is generated for the operating system. Instruct. As a result, n table update processes are generated by the operating system, and the generated table update process starts operation. Note that the table update process operates in parallel with each other by executing a table update program corresponding to each process in a time-sharing manner by the CPU 12A. In the next step 68, the timer is started and the operation process number management process is terminated.

  When the server computer 12 receives a message from the computer network 14 or the Bank of Japan system 24, the message reception program is read from the storage unit 12C and executed by the CPU 12A, so that the message reception process shown in FIG. Is called. In this message reception process, first, in step 30, the transaction details DB stored in the storage 22 is updated based on the contents of a single message received from the computer network 14 or the Bank of Japan system 24. In the next step 32, based on the content of the received single message, update data corresponding to each monitor item (for updating each business data registered in each table of the status management table group) Data). In step 34, the update data for each monitor item generated in step 30 is input to the end of the queue (queue) formed on the memory 12B, and the message reception process is terminated.

  The above message reception process is executed each time the server computer 12 receives a message. Accordingly, the transaction details DB is updated immediately according to the contents of the message received. Further, every time the server computer 12 receives a message, as shown in FIG. 6 as an example, the update data corresponding to the monitor item “number of cases by status”, the monitor item “fund transfer” are received from the received single message. Update data corresponding to the “transition status”, update data corresponding to the monitor item “planned cash flow”, and update data corresponding to the monitor item “monitoring information” are generated, and the generated update data is queued. Will be inserted at the end of.

  The memory 12B that stores the update data linked to the queue corresponds to the holding unit according to the present invention, together with the process of forming and managing the queue on the memory 12B. However, the holding means is not limited to this configuration, and a FIFO memory, a general buffer, or the like can be used as the holding means.

  Further, in the n table update processes generated by the operating system in accordance with the instruction from the above-described operation process number management process, the table update program stored in the storage unit 12C is executed by the CPU 12A, so that FIG. The table update process shown in FIG.

In this table update process, first, in step 40, it is determined whether or not update data is held in the queue. If the determination is negative, the process is temporarily terminated, and the determination in step 40 is performed again in the next program execution period, so that step 40 is repeated until the above determination is affirmed. When update data is input to the queue by the above-described message reception process, the determination in step 40 is affirmed and the process proceeds to step 42, and the update data held at the head of the queue is taken out from the queue. In step 44, the variable x is read from the storage area of the variable x on the memory 12B. In the next step 46, the variable x stored in the storage area is incremented by one. In step 48, the number n of operation of the table update process is read from the storage area of the number n of operations on the memory 12B. In step 50, the variable x read in step 44 and the table update process operation number n read in step 48 are substituted into the following equation (1) and calculated to store the business data to be updated. The storage area i is determined.
i ← MOD (x / n) +1 (1)
In the equation (1), MOD () is an operator representing a remainder in the operation in parentheses.

As apparent from a comparison of the number-by-status table by status shown in FIG. 6 with the number-by-status table by status shown in FIG. 7, in this embodiment, business data to be registered in each table in each table of the status management table group. M (m ≧ 2) are provided for each storage area, and the same type of business data is stored in each storage area in a single table. In this way, the storage unit 12C that stores a single table provided with m storage areas corresponds to the storage unit according to the present invention, and p status management table groups (p = 4 in this embodiment). The storage unit 12 </ b> C that stores each of the tables corresponds to the p storage means described in claim 6 . In addition, you may make it memorize | store each table of a status management table group in a separate memory | storage part. Each storage area in each table is given a serial number (1 to m) for identifying each storage area in the same table. In step 50 above, the calculation of equation (1) is performed. Thus, the serial number i of the storage area storing the business data to be updated is determined.

  Note that the value m of the number of storage areas in a single table may be equal to or greater than the value n of the number of operating table update processes (m ≧ n). However, as will be described later, in this embodiment, the server computer While the table update process operation number n may be increased or decreased during the operation of 12, the process of increasing or decreasing the number m of storage areas in each table is complicated, so the table update process operation number n is increased. It is desirable that an upper limit value nmax is set in advance and the number m of storage areas in each table is matched with the upper limit value nmax. As a result, it is not necessary to change the number m of storage areas in each table regardless of increase / decrease in the number n of operation of the table update process while the server computer 12 is in operation, and the processing is simplified.

  By the way, when the individual table update process determines the storage area for updating the business data according to the above equation (1), the update of the business data by the individual table update process is always performed on a certain storage area. Although not limited, the serial number i of the storage area of the business data update target determined by the individual table update process is a value corresponding to the reading order of the variable x by the individual table update process, and the individual table update processes are different from each other. The business data stored in the storage area is updated.

  However, the reading of the variable x in step 44 of the table updating process and the updating (incrementing) of the variable x in step 46 are simple processes that can be completed in a very short time. When a variable x in step 44 is read by another table update process after a table update process reads the variable x in step 44 and updates the variable x in step 46, Since the value of the variable x read by the table update process in (2) becomes the same, and the value of the serial number i in the storage area of the business data update target determined by the equation (1) becomes the same, it is stored in the storage area of the serial number i Business data is updated almost simultaneously by each table update process (access contention occurs), and the business data is inconsistent. May occur.

  This problem is caused by performing exclusive control for access (reading and updating) of the variable x or by performing exclusive control in units of individual storage areas for updating business data by individual table update processes. Although this can be solved, in the present embodiment, exclusive control for updating business data is performed. That is, first, in step 52, the monitor item corresponding to the update data fetched from the queue in the previous step 42 is determined, and after selecting the table corresponding to the determined monitor item from each table of the status management table group, In the storage area of serial number i in the selected table, information that prohibits updating of business data by another table update process is set, thereby locking access to the storage area of serial number i by another table update process To do.

  In the next step 54, the business data stored in the storage area in which information prohibiting the update of business data by another table update process is set is updated based on the update data retrieved from the queue in the previous step 42. To do. In step 56, the setting performed in step 54 is canceled for the storage area where the business data has been updated, and the business data can be updated by another table update process. The table update process is temporarily terminated by the above process, but since it is executed again in the next program execution period, as described above, the update data is extracted from the queue, and the serial number i of the storage area for the business data update target is determined. Then, the process of updating the business data for the storage area of the serial number i of the table corresponding to the extracted update data is repeatedly performed in parallel by n table update processes.

  In the table update processing according to the present embodiment, in order to prevent inconsistency or the like in the business data, exclusive control is performed for the update of the business data. As described above, it is very rare that access conflicts occur because the values of the variables x read by a plurality of table update processes are the same. The update of the business data based on the update data retrieved from the queue can be completed in a very short time without waiting for the business data to be updated. The business data registered in each table of the situation management table group can be updated with high processing efficiency.

  In addition, when the operator operates the keyboard 20 to instruct the display 18 to display specific monitor item information, the CPU 12A executes the data integrated output program stored in the storage unit 12C. Thus, the data integration output process shown in FIG. 4 is performed. In this integrated data output process, first, in step 90, the monitor item instructed to display information on the display 18 by the operator is recognized. In the next step 92, the operation number n of the table update process is read from the storage area of the operation number n on the memory 12B. In step 94, among the tables of the status management table group, in the storage area of the serial numbers 1 to n (the value of n at this time is the value read in step 92) corresponding to the monitor item recognized in step 90. Acquire each stored business data.

  In the next step 96, the n pieces of business data acquired from the storage areas of serial numbers 1 to n in step 94 are integrated. As shown in FIG. 6, the business data stored in each storage area is divided into a plurality of types of primary keys, and the integration of n business data in step 96 has the same primary key. This is performed by calculating, for example, the total value or average value of n pieces of data according to the type of data. In step 98, the integrated business data is displayed on the display 18 in a display format (for example, a graph format or a table format) corresponding to the monitor item, and the data integration processing is terminated. This data integration process is performed every time an instruction is given by the operator. When another monitor item is designated, business data corresponding to the designated other monitor format is displayed on the display 18.

  Thereby, the operator performs an operation for sequentially displaying the business data corresponding to each monitor item on the display 18, and referring to the business data sequentially displayed on the display 18, for example, the cash flow and settlement of the entire specific financial institution. Can understand the current situation. As described above, in this embodiment, since the business data registered in each table of the status management table group can be updated with high processing efficiency, the update data put into the queue by the message reception process Can be shortened until the data is taken out from the queue by the table update process (the time during which the update data stays in the queue). Accordingly, the time from when the content of a certain financial transaction is reflected in the transaction details DB (after the financial transaction is confirmed) until the content of the financial transaction is reflected in the business data displayed on the display 18. It is shortened, and the operator can grasp the current situation of cash flow and settlement as a whole specific financial institution more accurately.

  In the integrated data output process shown in FIG. 4, every time the operator instructs to display business data, business data is acquired and displayed from the corresponding table. However, the present invention is not limited to this. Since the business data registered in each table of the management table group is appropriately updated by the table update process by the n table update processes, the business data corresponding to the specific monitor item is displayed on the display 18. The process of acquiring business data from a specific monitor item and updating the display on the display 18 based on the acquired business data may be repeated at regular intervals. As described above, the integrated data output process only reads the business data from each table of the status management table group, and does not update the business data. Even if data is read from the table, the processing efficiency does not decrease due to access conflict.

  By the way, the number of update data held in the queue includes the number of update data input to the queue per unit time by the message reception process and the update data retrieved from the queue per unit time by the n table update processes. If the number of messages received by the server computer 12 from the computer network 14 or the Bank of Japan system 24 per unit time greatly increases, the number of update data held in the queue increases. Since a large amount of update data stays in the queue, the content of a certain financial transaction is reflected in the transaction details DB until the content of the financial transaction is reflected in the business data displayed on the display 18. Time will be prolonged.

  On the other hand, in the present embodiment, when the timer started in step 68 of the operation process number management process (FIG. 5) described above times out, the operation process number management process is executed again using this as a trigger. When the process count management process is executed with the timer timed out as a trigger, the determination of the previous step 60 is denied, the process proceeds to step 70, and the update data held in the queue (retained) is updated. Get the number S. In the next step 72, the number S of update data acquired in step 70 is compared with a preset maximum value Smax and minimum value Smin, respectively, and the process branches according to the magnitude relationship.

  Here, if the number S of update data acquired in step 70 is not more than the maximum value Smax and not less than the minimum value Smin, the number S of update data held in the queue is appropriate, Since it can be determined that it is not necessary to change the number n of operation of the table update process, the process proceeds from step 70 to step 84, the timer is started, and the operation process number management process is terminated. In this case, after a certain time when the timer times out again, it is determined again whether or not the number S of update data is appropriate.

  On the other hand, when the number S of update data acquired in step 70 is larger than the maximum value Smax, the number S of update data held in the queue is excessive, and the job displayed on the display 18 is displayed. Since it can be determined that the data update delay time has increased, the process proceeds from step 72 to step 74 to instruct the operating system to generate an additional table update process. Thereby, only one table update process is additionally generated by the operating system, and the additionally generated table update process starts operation. In step 76, the number n of operation of the table updating process stored in the storage area of the number n of operations on the memory 12B is incremented by one. In step 84, the timer is started to end the operation process number management process.

  In this case, the number of table update processes that perform table update processing in parallel with each other is increased by one, and storage in which business data is updated among m storage areas provided in each table of the status management table group The number of areas is also increased by 1, and the update data take-out speed from the queue is increased, thereby suppressing an increase in the number S of update data staying in the queue. Also, if the additional number of table update processes (one) is not enough for the increase in the number of messages received by the server computer 12, the number of update data S is the maximum even after a fixed time until the timer times out again. When the state larger than the value Smax continues, more table update processes are additionally generated, and the number of table update processes is optimized according to the number of received messages of the server computer 12.

  If the number S of update data acquired in step 70 is smaller than the minimum value Smin, the update time of the business data displayed on the display 18 is sufficiently small, so that the processing capacity of the server computer 12 is sufficient. Is preferably distributed to another process (or transaction details DB update) executed by the server computer 12. Therefore, when the number S of update data is smaller than the minimum value Smin, the process proceeds from step 72 to step 78 to instruct the operating system to stop the operation of one operating table update process. . As a result, the operation of one table update process is stopped by the operating system.

  In addition, when the number n of table update process operations stored in the memory 12B is updated as the number of table update processes decreases, of the m storage areas provided in each table of the status management table group. Since the update of the business data is stopped in the storage area of the serial number n, the storage area of the serial number n is also excluded from the business data integration target by the data integration output process (FIG. 4). The business data stored in the storage area of the serial number n of the table is integrated with the business data stored in another storage area of the same table. In the next step 82, the table update process operation number n stored in the storage area of the operation number n on the memory 12B is decremented by 1. In step 84, the timer is started and the operation process number management process is completed. To do.

  In this case, the number of table update processes that perform table update processing in parallel with each other is reduced by one, and the business data is updated in m storage areas provided in each table of the status management table group. The number of areas is also reduced by one, and the processing speed of the server computer 12 is reduced by another process (or transaction details) executed by the server computer 12 as the speed of fetching update data from the queue decreases. System DB update).

  In the above, when updating the business data based on the update data, every time the update data is extracted from the queue, the storage area for updating the business data is determined by performing the calculation of the previous equation (1). As described above, the present invention is not limited to this, and in particular, when the number of table update processes is not increased or decreased during operation, storage for updating business data for each table update process. Different sequence numbers may be set as the sequence numbers of the areas, and the individual table update process may update the business data stored in the storage areas of the set sequence numbers. In this case, since access competition cannot occur, the exclusive control as in steps 52 and 56 in FIG. 3 can be omitted, and the processing efficiency can be further improved.

  In the above description, business data representing the cash flow and settlement status of the entire specified financial institution as the update target data according to the present invention has been described as an example, and data for updating business data as update data has been described as an example. Is not limited to this, and arbitrary data can be applied as the update target data. Further, the update data may be data that can be used indirectly for updating the update target data. The update data is obtained by performing some processing on the update data that the processing unit has fetched from the holding unit. The data may be data that can be used directly for updating.

  In the above, the data processing program (corresponding to the message reception program, the table update program, the data integration output program, and the operation process number management program) according to the present invention is stored (installed) in the storage unit 12C of the server computer 12 in advance. The data processing program according to the present invention can also be provided in a form recorded on a recording medium such as a CD-ROM, DVD-ROM, or MT.

It is a block diagram which shows schematic structure of the computer system which concerns on this embodiment. It is a flowchart which shows the content of a message | telegram reception process. It is a flowchart which shows the content of a table update process. It is a flowchart which shows the content of a data integrated output process. It is a flowchart which shows the content of the number management process process. It is explanatory drawing for demonstrating the structure of the condition management table group in the transaction details management system which concerns on this embodiment, and its update process. It is explanatory drawing for demonstrating the process in the conventional transaction details management system.

Explanation of symbols

10 Computer System 12 Server Computer 12B Memory 12C Storage 14 Computer Network 18 Display 20 Keyboard 24 BOJ System

Claims (10)

Update data used for updating the update target data is sequentially input, and holding means for holding each of the input update data;
storage means for storing the update target data in m (m ≧ 2) storage areas;
The update data that operates in parallel with each other, takes out the update data from the holding means, and stores the update target data stored in different storage areas among the m storage areas of the storage means. N (n ≧ 2 and n ≦ m) processing means for repeating the process of updating based on
Variable storage means for storing the variable x and the total number n of the processing means;
Only including,
The processing means reads the value of the variable x and the value of the total number n from the variable storage means every time the update data is taken out from the holding means, and updates the value of the variable x stored in the variable storage means. And data for determining a storage area for updating the update target data among the m storage areas of the storage means based on the remainder value obtained by dividing the value of the read variable x by the total number n of the processing means. Processing equipment. It is determined whether or not it is necessary to increase or decrease the number of the processing means, and the number of the processing means is increased or decreased according to the determination result, and the total number n stored in the variable storage means The data processing apparatus according to claim 1, further comprising control means for updating the data. 3. The data processing apparatus according to claim 2, wherein the control means determines whether or not the number of the processing means needs to be increased or decreased based on the number of update data held in the holding means. Each of the processing means is realized by executing a predetermined process for executing a program for causing a computer to function as the processing means by the computer,
  The control unit increases the number of the processing units by additionally generating the predetermined process, and decreases the number of the processing units by stopping the operation of the predetermined process in operation. Data processing equipment. The processing means locks a storage area in which the update target data is updated among a plurality of storage areas of the storage means, and updates the update target data stored in the locked storage area. The data processing apparatus according to any one of claims 1 to 4, wherein a process for releasing the lock of the storage area is performed. P storage units are provided, and storage areas of the individual storage units store different types of update target data among p types of update target data,
The update data input to the holding means includes p types of update data used for different update target data among the p types of update target data,
The processing means takes out update data from the holding means, selects the storage means corresponding to the type of update data taken out from the p storage means, and stores any of the selected storage means The data processing apparatus according to claim 1, wherein the update target data stored in an area is updated based on the extracted update data. 2. An integration unit that reads each update target data stored in m storage areas of the storage unit, integrates the read m update target data into a single data, and outputs the integrated data. The data processing apparatus according to claim 6. The total number n is read from the variable storage means, and the update target data stored in the first to n-th n storage areas of the m storage areas of the storage means are read and read. And further comprising an integration means for integrating and outputting the update target data into a single data,
When the control means reduces the number of the processing means, the update target data stored in the nth storage area of the m storage areas of the storage means is stored in another storage area. The data processing apparatus according to claim 2, wherein the value of the total number n is decreased after being integrated into the update target data. Update data to be used for updating the update target data is sequentially input, and holding means for holding each of the input update data is provided, and the update target data is stored in m (m ≧ 2) storage areas. A computer having storage means for storing each of them, or a computer connected to the storage means,
The update data that operates in parallel with each other, takes out the update data from the holding means, and stores the update target data stored in different storage areas among the m storage areas of the storage means. processing means of n (n ≧ 2 and n ≦ m) repeating the process of updating based on,
And a data processing program for functioning as variable storage means for storing the variable x and the total number n of the processing means ,
The processing means reads the value of the variable x and the value of the total number n from the variable storage means every time the update data is taken out from the holding means, and updates the value of the variable x stored in the variable storage means. And data for determining a storage area for updating the update target data among the m storage areas of the storage means based on the remainder value obtained by dividing the value of the read variable x by the total number n of the processing means. Processing program.   Update data to be used for updating the update target data is sequentially input, and holding means for holding each of the input update data is provided, and the update target data is stored in m (m ≧ 2) storage areas. 9. Data processing for causing a computer having storage means for storing each of them or connected to the storage means to function as each means constituting the data processing apparatus according to any one of claims 1 to 8. program.

Images