CN1889045A - Cocurrent event processing device and method in multi-task software system - Google Patents

Abstract

The invention relates to a processing device and method for concurrent events in a multi-task software system. The device mainly includes: a task module: used for submitting the event to the concurrent processing module when a concurrent event in the multi-task software system needs to be processed, and according to the concurrency control information of the event returned by the concurrent processing module, The event is processed accordingly; concurrent processing module: used to maintain the concurrency rules of the concurrency event type in the multi-tasking software system and the status information of the events submitted by the task module, and generate the received submission according to the concurrency rules and status information The concurrency control information of the event, and pass the concurrency control information to the task module. The device of the invention can make the design and implementation of concurrent event processing in the multi-task software system simpler, and make the maintenance work of the multi-task software system more convenient.

Description

Device and method for processing concurrent events in multi-task software system

technical field

The invention relates to the communication field, in particular to a device and method for processing concurrent events in a multi-task software system.

Background technique

A multi-tasking software system refers to a software system that can process multiple events at the same time. In practical applications, the concurrency of multiple events may be very complicated. For example: if a multi-tasking software system has 10 concurrent events, then there will be 10 concurrent events of these 10 events! /9! +10! /8! +10! /7! +10! /6! +10! /5! +10! /4! +10! /3! +10! /2! +10! /1! = 6,235,300 species. Therefore, if the realization of the multitasking software system is to deal with the various concurrent situations of multiple events separately, the development process of the multitasking software system will be very difficult and painful, and the realization of the multitasking software system will be very large and expensive. complicated.

Due to the different event types and event processing methods of multiple events processed by the multi-tasking software system at the same time, there may be concurrency conflicts among the multiple events, that is, when one type of event among the multiple events is processed, the other Events of one type cannot be processed at the same time. Therefore, it is usually necessary to formulate a concurrency rule for a multitasking software system, which specifies how the multitasking software system handles all concurrent events according to the conflicts among all concurrent events in the multitasking software system.

A method for processing concurrent events in a multitasking software system in the prior art is: setting a status flag for each concurrent event in a multitasking software system, and the status flag identifies whether the event is being processed. When an event needs to be processed, it is determined whether the event can be processed concurrently and how to handle other events according to the status flags of all concurrent events of the multitasking software system and the concurrency rules of the multitasking software system.

The disadvantage of this method is: this method is only suitable for multi-task software systems with relatively few concurrent events. Since the concurrency rules of the above-mentioned multitasking software system are fixed in the code, when new events are added or the original events need to be removed, the concurrency rules need to be adjusted, because the concurrency rules are fixed in the multitasking In the coding of all event processing processes of the software system, the adjustment of the concurrency rules will involve all event processing processes of the multitasking software system, making the maintenance work of the multitasking software system extremely heavy.

Contents of the invention

In view of the problems existing in the above-mentioned prior art, the object of the present invention is to provide a scheduling device and method for concurrent events in a multi-tasking software system, so as to make the design and implementation of concurrent event processing in a multi-tasking software system simpler and make multi-tasking The maintenance work of the software system is more convenient.

The purpose of the present invention is achieved through the following technical solutions:

A device for processing concurrent events in a multitasking software system, comprising:

Task module: when a concurrent event in the multitasking software system needs to be processed, submit the event to the concurrent processing module, and process the event accordingly according to the concurrency control information of the event returned by the concurrent processing module;

Concurrency processing module: used to maintain the concurrency rules of concurrency event types in the multi-task software system and the state information of the events submitted by the task module, according to the concurrency rules and state information, generate the concurrency control information of the received submitted events, and Pass the concurrency control information to the task module.

The task modules specifically include:

Event submission module: used to submit the event to the concurrent processing module when a concurrent event needs to be processed, receive the concurrency control information of the event returned by the concurrent processing module, pass the concurrency control information to the event processing module, and send the event The event processing status information returned by the processing module is passed to the concurrent processing module;

Event processing module: used to perform corresponding transaction processing on the corresponding concurrent event or suspend the concurrent event or discard the concurrent event according to the received concurrency control information, and return the event processing status information to the event submission module.

The task modules also include:

Event identification module: used to generate an event identification that uniquely identifies the event during the entire operation period of the multi-tasking software system when a concurrent event needs to be processed, and pass the event identification to the event processing module and the event submission module.

The concurrent processing module specifically includes:

Concurrency rule module: used to define and maintain concurrency rules for all concurrency event types in the multi-tasking software system, and pass the concurrency rules to the concurrency control and scheduling module through the interface;

Concurrency control and scheduling module: used to maintain the status information of all received submission events, and generate the concurrency control information of the received submission events according to the status information and the received concurrency rules, and return the concurrency control information to task module.

The concurrent rules module includes:

Concurrency rule matrix module: used to use matrix to centrally represent concurrency rules of all concurrency event types in a multi-tasking software system.

The concurrency control and scheduling module specifically includes:

Concurrent scheduling module: used to maintain the state information of all events being processed and all events waiting to be processed, including the type and priority information of the event, and pass the event state information to the concurrency control module;

Concurrency control module: used to determine the status information of the received submitted event according to the received concurrency rules and the event status information passed by the concurrency scheduling module, and generate corresponding concurrency control information, and pass the concurrency control information to the task module ;

Event processing status information receiving module: used to receive the event processing status information returned by the task module. After receiving the status information that the event processing is completed, it will notify the concurrent scheduling module to submit the event with the highest priority among the events waiting to be processed to Concurrency control module.

Described concurrent scheduling module includes:

List of events currently being processed: used to arrange all events being processed in descending order of priority;

List of events waiting to be processed: used to arrange all events that are in the state of waiting to be processed according to the priority from high to low.

The concurrency control module specifically includes:

Concurrency Judgment Module: It is used to judge whether the received submission event can be concurrent according to the received concurrency rules. If it can be concurrent, it will notify the concurrent scheduling module to add the event to the list of events currently being processed, and generate the concurrency control of the event information, and pass the information to the task module; if it cannot be concurrent, submit the event to the priority judgment module;

Priority judging module: used to find out all events that have concurrency conflicts with the submission event in the list of events currently being processed, and then judge whether the priority of the submission event is greater than the priority of all found events, and if so, notify The concurrent scheduling module adds the event to the list of events currently being processed, and adds all found events to the list of events waiting to be processed or discards them; otherwise, adds the event to the list of events waiting to be processed, and then generates corresponding concurrency control information, and Pass that information to the task module.

The concurrency control module includes:

The current concurrency rule generation module: used for obtaining the current concurrency rule list through AND operation according to the concurrency rules of all types of events being processed in the multi-tasking software system, and passing the list to the concurrency judgment module.

A method for processing concurrent events in a multitasking software system, comprising:

A. Set concurrency rules and priority information of concurrent event types in the multi-tasking software system;

B. According to the set information, correspondingly process the concurrent events that need to be processed in the multi-tasking software system.

Described step A also includes:

According to the concurrency rules of all event types being processed in the multi-tasking software system, the current concurrency rule list is obtained by performing an AND operation.

Described step B specifically comprises:

B1. According to the concurrency rules of all types of events being processed in the multi-tasking software system, judge whether the concurrent events that need to be processed can be concurrent, and if so, perform step B2; otherwise, perform step B3;

B2. Determine that the current state of the concurrent event that needs to be processed is the processing state, and perform corresponding transaction processing on the event;

B3. According to the relationship between the priorities of the concurrent events that need to be processed and the priorities of all events that have concurrency conflicts, determine whether the concurrent events that need to be processed can be concurrent.

Described step B3 specifically comprises:

B31. Find all events that have concurrency conflicts with the concurrent events that need to be processed in the events that are currently being processed. If the priority of the concurrent events that need to be processed is greater than the priority of all found events, then Execute step B32; otherwise, execute step B33;

B32. Determine that the state of the concurrent event that needs to be processed is the processing state, perform corresponding transaction processing on the event, update the state of the found event to the waiting processing state and suspend the event, or, find the event events are discarded directly;

B33. Determine that the current state of the concurrent event that needs to be processed is a waiting state, and suspend the event.

Described step B also includes:

After an event being processed in the multi-tasking software system is processed, the event with the highest priority among the events waiting to be processed becomes a concurrent event that needs to be processed currently.

As can be seen from the technical scheme provided by the above-mentioned invention, the present invention has the following advantages compared with the prior art:

1. The present invention adopts a centralized concurrency control and concurrent scheduling processing strategy, which makes the concurrent event processing design and implementation of the multitasking software system easier, and makes the concurrent event processing modification and maintenance of the multitasking software system more convenient.

2. The present invention separates the concurrency control and scheduling of events from the specific processing of events, and separates the concurrency control of events from the concurrent scheduling of events, so that developers of multi-task software systems can concentrate on the definition of event concurrency rules , the optimization of event concurrency scheduling algorithm, and the correct processing of events, without having to care about the intricate concurrency of events and event concurrency conflicts.

3. In the present invention, the task can access the processing event list and obtain all event information currently being processed, so that the task can properly optimize the processing process and processing method of the corresponding event according to the event information currently being processed or adjust.

Description of drawings

Fig. 1 is the specific structural diagram of device of the present invention;

Fig. 2 is the basic structural diagram of the embodiment of the present invention;

3 is a structural diagram of multiple event concurrency control and concurrency scheduling devices in the embodiment of the present invention;

FIG. 4 is a flow chart of concurrency control and concurrent scheduling processing in the event of task submission in the embodiment of the present invention;

FIG. 5 is a flow chart of concurrency control and concurrent scheduling processing after receiving an event processing completion confirmation message according to the embodiment of the present invention;

Fig. 6 is a specific processing flowchart of the method of the present invention.

Detailed ways

The invention provides a scheduling device and method for concurrent events in a multi-task software system. The core of the present invention is: in the multi-task software system, adopt centralized concurrent control and concurrent scheduling processing strategy, separate the concurrent control and concurrent scheduling of events from the specific processing of events, and separate the concurrent control of events from the concurrent scheduling of events phase separation.

Describe the present invention in detail below in conjunction with accompanying drawing, the specific structural diagram of device of the present invention is as shown in Figure 1, comprises following module:

The task module is used for submitting the event to the concurrent processing module when a concurrent event in the multi-task software system needs to be processed, and correspondingly processing the event according to the concurrency control information of the event returned by the concurrent processing module. The task module includes: event identification module, event submission module and event processing module.

Wherein, the event identification module is configured to generate a unique event identification according to the received application delivered by the event submission module, and then transmit the event identification to the event processing module and the event submission module. The event identification is uniformly assigned and managed by the event identification module, and uniquely identifies the event during the entire operation period of the multi-tasking software system.

Wherein, the event submitting module is used for submitting the event identified by the event identification to the concurrent processing module after receiving the event identification passed by the event identification module, and receiving the concurrency control information of the event returned by the concurrent processing module. The concurrency control information is passed to the event processing module.

Wherein, the event processing module is used to process the event correspondingly according to the concurrency control information and event identifier of the received event, including temporarily suspending or discarding the event, or performing other appropriate processing and Return status information to the concurrent processing module.

The concurrent processing module is used to maintain the concurrency rules of all concurrency event types in the multi-tasking software system. According to the concurrency rules and the type and priority information of all the events being processed, generate the events that need to be processed submitted by the task module Concurrency control information, and return the concurrency control information to the task module. The concurrent processing module includes: a concurrent control and scheduling module and a concurrent rule module.

Among them, the concurrency rule module is used to define and maintain concurrency rules of all concurrency event types in the multi-task software system, and pass the concurrency rules to the concurrency control and scheduling module, and the concurrency rules can be represented by a matrix. Therefore, the concurrency rule module may include a concurrency rule matrix module, and the concurrency rule matrix module is used to use a matrix to centrally represent concurrency rules of all concurrency event types in the multi-task software system.

Among them, the concurrency control and scheduling module is used to generate information for The concurrency control information of the event submitted by the task module, and returns the concurrency control information to the task module. The concurrency control and scheduling module includes: a concurrency control module, a concurrency scheduling module and an event processing status information receiving module.

Among them, the concurrent scheduling module is used to maintain event status information such as the type and priority information of all events being processed and waiting to be processed, and all events being processed and waiting to be processed are sorted according to their priorities from high to low , which respectively constitute the list of events currently being processed and the list of events waiting to be processed.

Among them, the event processing status information receiving module is used to receive the event processing status information returned by the task module. After receiving the status information that the event processing is completed, the concurrent scheduling module will be notified that the event with the highest priority among the events waiting to be processed Submitted to the concurrency control module.

Wherein, the concurrency control module is used for generating and maintaining the current concurrency rule list of the multi-task software system according to the received concurrency rules and the types of all events being processed. According to the current concurrency rule list and the event information delivered by the concurrency scheduling module, the submission event is processed accordingly, corresponding concurrency control information is generated, and the concurrency control information is returned to the task module. The concurrency control module includes: a concurrency judging module, a priority judging module and a current concurrency rule generating module.

Concurrency Judgment Module: It is used to judge whether the received submission event can be concurrent according to the received concurrency rules. If it can be concurrent, it will notify the concurrent scheduling module to add the event to the current event list being processed, and notify the current concurrency rule generation The module updates the current concurrency rule list, generates the concurrency control information of the event, and passes the information to the task module, which can notify the task responsible for processing the submitted event to process the corresponding event; if it cannot be concurrent, submit the event To the priority judgment module;

Priority judging module: used to find out all events that have concurrency conflicts with the submission event in the list of events currently being processed, and then judge whether the priority of the submission event is greater than the priority of all found events, and if so, notify The concurrent scheduling module adds the event to the list of events currently being processed, adds all found events to the list of events waiting to be processed or discards them, and notifies the current concurrent rule generation module to update the current list of concurrent rules; otherwise, adds the event to the waiting list The list of events processed, and then generate the corresponding concurrency control information, and pass this information to the task module.

The current concurrency rule generation module: used for obtaining the current concurrency rule list through AND operation according to the concurrency rules of all types of events being processed in the multi-tasking software system, and passing the list to the concurrency judgment module.

The present invention provides a specific embodiment of the device described above, and the basic structure diagram of this embodiment is shown in FIG. 2 .

In the basic structural diagram of the embodiment of the present invention shown in FIG. 2 , multiple event concurrency control and concurrency scheduling devices and task modules are included. The structure diagram of multiple event concurrency control and concurrency scheduling device is shown in FIG. 3 . It includes: an event identification module, a multiple event concurrency scheduling module based on priority, a multiple event concurrency control module and a concurrency rule module based on concurrency rules. The specific working process of this embodiment is as follows:

The task module is composed of multiple subtask modules, and each subtask module has a unique task identifier, which is responsible for the processing of predetermined events.

In order to better describe this embodiment, we first introduce the concept of concurrency rules of a multi-tasking software system.

Assume that the multi-tasking software system has 7 concurrent event types including A, B, C, D, E, F, and G. Table 1 shows the concurrency rules of events whose event type is A. Then the concurrency rule defines that when an event of event type A occurs, events of event type A, B, D, and F can be processed concurrently, and events of event type C, E, and G cannot be processed concurrently. Table 2 shows the concurrency rules for the events whose event type is B. Then the concurrency rule defines that when an event of event type B occurs, events of event type A, C, and D can be processed concurrently, while events of event type B, E, F, and G cannot be processed concurrently.

Table 1 Concurrency rules for events of event type A A B C D. E. f G A TRUE TRUE FALSE TRUE FALSE TRUE FALSE

Table 2 Concurrency rules for events of event type B A B C D. E. f G B TRUE FALSE TRUE TRUE FALSE FALSE FALSE

In this embodiment, the concurrency rule module in the multiple event concurrency control and concurrency scheduling device is responsible for defining and maintaining concurrency rules for all concurrency event types, and the concurrency rules can be represented by a concurrency rule matrix. The concurrency rule module needs to provide concurrency rules of corresponding event types to multiple event concurrency control modules based on concurrency rules through the concurrency rule module interface according to the concurrency rule matrix.

For example, assuming that the multitasking software system has 7 concurrent event types A, B, C, D, E, F, G, etc., the concurrency rule matrix of all concurrent event types of the multitasking software system can be defined as Table 3 In the form of , the row is defined as the event type being concurrent, and the column is defined as the concurrency rules of other event types corresponding to the concurrent event type.

Table 3 Concurrency rule matrix for various event types A B C D. E. f G A TRUE TRUE FALSE TRUE FALSE TRUE FALSE B TRUE FALSE TRUE TRUE FALSE FALSE FALSE C FALSE TRUE FALSE FALSE FALSE FALSE TRUE D. TRUE TRUE FALSE TRUE TRUE FALSE TRUE E. TRUE FALSE FALSE TRUE FALSE TRUE TRUE f FALSE FALSE TRUE TRUE TRUE FALSE FALSE G TRUE FALSE FALSE TRUE FALSE TRUE TRUE

When the multi-task software system is initialized or no event occurs in the current system, all items in the current concurrency rule list of the multi-task software system maintained in the multiple event concurrency control module based on concurrency rules are true. That is, any concurrent event is allowed to be concurrent at this time.

When a single event type occurs or is concurrent in the multitasking software system, the current concurrency rule list of the multitasking software system is the concurrency rule list of the event type. When multiple event types are concurrent, multiple event concurrency control modules based on concurrency rules obtain the concurrency rule list of the corresponding event type through the concurrency rule module interface, and perform an AND operation on these concurrency rule lists to obtain the current concurrency list of rules.

For example, when only events of event type A occur in the multi-tasking software system, the current list of concurrency rules is shown in Table 4. The concurrency rule list indicates that the multitasking software system only allows events of event types A, B, D, and F to be processed concurrently, while events of event types C, E, and G cannot be processed concurrently.

If the event of event type B is concurrent at this time (because according to the concurrency rule list at this time, the event of event type B can be processed concurrently), multiple event concurrency control modules based on concurrency rules can be obtained through the concurrency rule module interface The concurrency rule list of event B, and then, the concurrency rule list of event A shown in Table 1 and the concurrency rule list of event B shown in Table 2 are combined, and the current concurrency rules shown in Table 5 will be obtained list. The concurrency rule list indicates that the multitasking software system only allows events of event types A and D to be processed concurrently, while events of event types B, C, E, F, and G cannot be processed concurrently.

If the processing of the event of event type A is completed at this time (only the event of event type B is being processed in the multi-tasking software system at this time), the current concurrency rule list will be updated as shown in Table 6. The concurrency rule list indicates that the multitasking software system only allows events of event types A, C, and D to be processed concurrently, while events of event types B, E, F, and G cannot be processed concurrently.

Table 4 List of concurrency rules when an event of event type A occurs A B C D. E. f G TRUE TRUE FALSE TRUE FALSE TRUE FALSE

Table 5 List of concurrency rules when events of event type A and B occur A B C D. E. f G TRUE FALSE FALSE TRUE FALSE FALSE FALSE

Table 6 List of concurrency rules when an event of event type B occurs A B C D. E. f G TRUE FALSE TRUE TRUE FALSE FALSE FALSE

Each concurrent event in a multitasking software system has its event priority and preemption method. The event priority is used to identify the priority processing level of the event, and the preemption method is used to identify the processing method of the submission event if a high-priority event occurs and the submission event is preempted when the submission event is being processed, including the submission Events can be discarded or suspended.

When a concurrent event in the multi-task software system needs to be processed, the subtask module responsible for processing the event applies for an event identifier to multiple event concurrency control and concurrency scheduling devices. The event identification is uniformly assigned and managed by the event identification modules in the multiple event concurrency control and concurrent scheduling devices, so as to ensure that the event is uniquely identified during the entire running period of the multi-task software system. The subtask module submits the event to multiple event concurrency control and scheduling devices after obtaining the event identifiers returned by the multiple event concurrency control and concurrency scheduling devices.

Multiple event concurrency control and concurrency scheduling devices perform concurrency control and concurrent scheduling processing on the submission event after receiving the submission event. The specific processing process is shown in Figure 4, including the following steps:

Step 4-1. Submit events to multiple event concurrency control and concurrency scheduling devices.

When a concurrent event in the multi-task software system needs to be processed, the subtask module submits the event to multiple event concurrency control and scheduling devices after obtaining the event identifier from multiple event concurrency control and scheduling devices.

Step 4-2, judging whether the submission event can be processed concurrently.

After the multiple event concurrency control and concurrency scheduling device receives the submission event, the multiple event concurrency control module based on concurrency rules judges whether the submission event can be processed concurrently according to the current concurrency rule list and the type information of the submission event. If yes, go to step 4-3; otherwise, go to step 4-4.

Step 4-3. Add the submission event to the processing event list.

If multiple event concurrency control modules based on concurrency rules determine that the submission event can be concurrent according to the current concurrency rule list, that is, the submission event can be processed currently, then notify the priority-based multiple event concurrency scheduling module according to its priority. The submission event is added to the list of events currently being processed, and the current concurrency rule list is updated according to the event type of the submission event. Then, according to the task identifier of the submitted event, the subtask module responsible for processing the submitted event is notified to process the corresponding event.

Step 4-4: Determine all events that have concurrency conflicts with the submission event among the events being processed.

If multiple event concurrency control modules based on concurrency rules determine that the submission event cannot be concurrent according to the current concurrency rule list, that is, according to the current concurrency rules, there is a concurrency conflict between the event currently being processed and the submission event. Therefore, the multiple event concurrency control module based on concurrency rules checks the list of events currently being processed in the priority-based multiple event concurrency scheduling module, finds out the events that have concurrency conflicts with the submitted event one by one, and then performs step 4 -5.

Step 4-5, judging whether the priority of the submission event is higher than all events with concurrency conflicts.

The multiple event concurrency control module based on concurrency rules judges whether the priority of the submitted event is higher than all the found concurrency conflicting events, if yes, execute step 4-7; otherwise, execute step 4-6.

Steps 4-6, adding the submission event to the waiting event list.

If the priority of the submission event is lower than the highest priority event among all events with concurrency conflicts, the multiple event concurrency control module based on concurrency rules notifies the multiple event concurrency scheduling module based on priority The level adds the submission event to the list of events waiting to be processed. Then, according to the task identifier of the submission event, the subtask module responsible for processing the submission event is notified to temporarily suspend the submission event.

Steps 4-7, adding the submission event to the processing event list, and hooking or abandoning all events with concurrency conflicts.

If the commit event has a higher priority than all events with concurrency violations. Therefore, multiple event concurrency control and scheduling devices will notify the subtask modules responsible for processing all these events to discard or temporarily suspend them according to the preemption mode of all these events according to the task identifiers of all events currently being processed that have concurrency conflicts. All those currently processing events with concurrency violations. For a discarded event, the priority-based multiple event concurrent scheduling module removes the event from the list of currently processing events. For a pending event, after the priority-based multiple event concurrent scheduling module removes the event from the list of events currently being processed, it adds it to the list of events waiting to be processed according to the priority of the event. At the same time, the subtask module responsible for processing the event performs appropriate processing such as saving relevant data for the suspended event.

Then. The priority-based multiple event concurrency scheduling module adds the submission event to the current event list according to its priority, and the concurrency rule-based multiple event concurrency control module updates the current concurrency rule list according to the event type of the submission event. According to the task identifier of the submitted event, the subtask module responsible for processing the submitted event is notified to process the corresponding event.

In this embodiment, in order for the multiple event concurrency control and scheduling devices to know the current state of each event in a timely and correct manner, the task module needs to return event scheduling status confirmation information to the multiple event concurrency control and scheduling devices. The situations where the task module needs to return event scheduling status confirmation information are as follows:

1. When multiple event concurrency control and scheduling devices notify the task processing event, the task module returns to confirm receipt of the event processing notification;

2. When multiple event concurrency control and scheduling devices notify the task suspension event, the task module returns to confirm receipt of the event suspension notification;

3. When multiple event concurrency control and scheduling devices notify the task discarding event, the task module returns to confirm receipt of the event discarding notification;

4. When any event processing is completed, the task module returns confirmation to the multiple event concurrency control and scheduling devices that the event processing is completed.

In the above four cases, it is necessary to report the status confirmation information when the event processing is completed, and the event scheduling status confirmation in other cases is optional. After the task module returns a status confirmation message confirming the completion of event processing to multiple event concurrency control and scheduling devices, multiple event concurrency control and concurrency scheduling devices need to perform corresponding concurrency control and concurrent scheduling processing, the specific processing process is shown in Figure 5 shown, including the following steps:

Step 5-1: Return an event processing completion status report to multiple event concurrency control and concurrency scheduling devices.

After the task module finishes processing an event in the processing event list, it returns an event processing completion status report to multiple event concurrency control and concurrency scheduling devices.

Step 5-2, judging whether the highest priority event in the waiting list can be processed concurrently.

After the multiple event concurrency control and concurrency scheduling device receives the event processing completion status report, the multiple event concurrency control module based on concurrency rules judges whether the event with the highest priority in the waiting list can be processed concurrently according to the current concurrency rule list , if yes, go to step 5-3; otherwise, go to step 5-4.

Step 5-3, adding the waiting event to the processing event list.

If multiple event concurrency control modules based on concurrency rules determine that the waiting event can be concurrent according to the current concurrency rule list, that is, the waiting event can be processed currently, then notify the priority-based multiple event concurrency scheduling module according to its priority The waiting event is added to the current event list being processed, and the current concurrency rule list is updated according to the event type of the waiting event. Then, according to the task identifier submitting the waiting event, the subtask module responsible for processing the waiting event is notified to process the corresponding event.

Step 5-4: Determine all events that have concurrency conflicts with the waiting event among the events being processed.

If multiple event concurrency control modules based on concurrency rules determine that the waiting event cannot be concurrent according to the current concurrency rule list, that is, according to the current concurrency rules, there is a concurrency conflict between the event currently being processed and the waiting event. Therefore, the multiple event concurrency control module based on concurrency rules checks the list of events currently being processed in the priority-based multiple event concurrency scheduling module, finds out all events that have concurrency conflicts with the waiting event one by one, and then executes the steps 5-5.

Step 5-5, judging whether the priority of the waiting event is higher than all events with concurrency conflicts.

Multiple event concurrency control and scheduling devices compare the priority of the waiting event with the priorities of all found events that have concurrency conflicts with the waiting event, and if the priority of the waiting event is higher than that of the concurrency conflict The priority of all events for . Then execute step 5-7; otherwise, execute step 5-6.

Step 5-6, keep the waiting event in the waiting event list.

If the priority of the waiting event is lower than the event with the highest priority among all events with concurrency conflicts, the multiple event concurrency control module based on concurrency rules notifies the priority-based multiple event concurrency scheduling module to wait Events continue to stay on the pending events list.

Steps 5-7, adding the waiting event to the processing event list, and hooking or giving up all events with concurrency conflicts.

The multi-event concurrency control and scheduling device notifies the subtask modules responsible for processing all these events according to the task identifications of all the events currently being processed that have concurrency conflicts, and discards or temporarily suspends all these current events according to the preemption mode of all these events. The event being processed with a concurrency violation. For a discarded event, the priority-based multiple event concurrent scheduling module removes the event from the list of currently processing events. For a pending event, after the priority-based multiple event concurrent scheduling module removes the event from the list of events currently being processed, it adds it to the list of events waiting to be processed according to the priority of the event. At the same time, the subtask module responsible for processing the event performs appropriate processing such as saving relevant data for the suspended event.

Then. The priority-based multiple event concurrency scheduling module adds the waiting event to the current event list according to its priority, and the concurrency rule-based multiple event concurrency control module updates the current concurrency rule list according to the event type of the waiting event. According to the task identifier of the waiting event, the subtask module responsible for processing the waiting event is notified to process the corresponding event.

Although there is a method for processing concurrent events in a multi-tasking software system according to concurrency rules in the prior art, the existing processing method does not adopt the concept of priority of concurrent event types. Therefore, the present invention combines concurrency rules and priorities of concurrent event types, and also proposes a processing method for concurrent events in a multitasking software system, which method includes the following steps:

Step 6-1, setting concurrency rules and priority information of concurrency event types in the multitasking software system.

The method of the present invention first needs to set concurrency rules and priority information of all concurrent event types in the multi-task software system. Concurrency rules for all concurrency event types can be represented by a concurrency matrix.

The method can also obtain the current concurrency rule list by performing an AND operation according to the concurrency rules of all types of events being processed in the multi-task software system.

Step 6-2. According to the concurrency rules of all types of events being processed in the multitasking software system, it is judged whether concurrent events that need to be processed can be concurrent.

When concurrent events in the multitasking software system need to be processed, according to the concurrency rules of all types of events being processed in the multitasking software system, it is judged whether the concurrent events that need to be processed currently can be concurrent.

If the current concurrency rule list of the multi-tasking software system has been generated, it is judged according to the concurrency rule list whether concurrent events that need to be processed can be concurrent.

If it is judged that the concurrent events that need to be processed can be concurrent, execute step 6-3; otherwise, execute step 6-4.

Step 6-3: Determine that the current state of the concurrent event that needs to be processed is the processing state, and perform corresponding transaction processing on the event.

If it is determined that the event can be concurrent according to the concurrency rules of all types of events being processed in the multi-tasking software system or the current list of concurrency rules, that is, the event can be processed currently, then the current concurrency event that needs to be processed will be processed according to its The priority is added to the processing state, and the event is processed accordingly. And update the current list of concurrency rules according to the concurrency rules of all event types being processed.

After an event being processed in the multi-tasking software system is processed, the event with the highest priority among the events waiting to be processed becomes a concurrent event that needs to be processed currently.

Step 6-4: According to the relationship between the priority of the concurrent event that needs to be processed and the priority of all events with concurrency conflicts, determine whether the concurrent event that needs to be processed can be concurrent.

If it is judged that the event cannot be concurrent according to the concurrency rules of all event types currently being processed in the multitasking software system or the current concurrency rule list, then find out all the events that are currently being processed by the multitasking software system. Conflicting events, and judge the relationship between the found event and the priority of the event.

If the priority of the concurrent event that needs to be processed is greater than the priorities of all found events, execute step 6-5; otherwise, execute step 6-6.

Step 6-5: Determine that the state of the concurrent event that needs to be processed is the processing state, and perform corresponding transaction processing on the event.

Add the current concurrent event that needs to be processed to the processing state according to its priority, and perform corresponding transaction processing on the event. Update the status of the found event to the pending processing state and suspend the event, or directly discard the found event.

The current concurrency rule list is updated according to the concurrency rules of all event types being processed in the multitasking software system.

Step 6-6. Determine that the state of the current concurrent event that needs to be processed is the state of waiting for processing, and suspend the event.

It is determined that the state of the current concurrent event that needs to be processed is the state of waiting for processing, adding the event to the state of waiting for processing according to its priority, and suspending the event.

The above is only a preferred embodiment of the present invention, but the scope of protection of the present invention is not limited thereto. Any person skilled in the art within the technical scope disclosed in the present invention can easily think of changes or Replacement should be covered within the protection scope of the present invention. Therefore, the protection scope of the present invention should be determined by the protection scope of the claims.

Claims (14)

1. A processing device for concurrent events in a multitasking software system, characterized in that it comprises: Task module: when a concurrent event in the multitasking software system needs to be processed, submit the event to the concurrent processing module, and process the event accordingly according to the concurrency control information of the event returned by the concurrent processing module; Concurrency processing module: used to maintain the concurrency rules of concurrency event types in the multi-task software system and the state information of the events submitted by the task module, according to the concurrency rules and state information, generate the concurrency control information of the received submitted events, and Pass the concurrency control information to the task module. 2. The device for processing concurrent events in the multi-task software system according to claim 1, wherein the task module specifically includes: Event submission module: used to submit the event to the concurrent processing module when a concurrent event needs to be processed, receive the concurrency control information of the event returned by the concurrent processing module, pass the concurrency control information to the event processing module, and send the event The event processing status information returned by the processing module is passed to the concurrent processing module; Event processing module: used to perform corresponding transaction processing on the corresponding concurrent event or suspend the concurrent event or discard the concurrent event according to the received concurrency control information, and return the event processing status information to the event submission module. 3. The device for processing concurrent events in the multi-task software system according to claim 2, wherein the task module further comprises: Event identification module: used to generate an event identification that uniquely identifies the event during the entire operation period of the multi-tasking software system when a concurrent event needs to be processed, and pass the event identification to the event processing module and the event submission module. 4. The device for processing concurrent events in the multi-tasking software system according to claim 1, 2 or 3, wherein the concurrent processing module specifically includes: Concurrency rule module: used to define and maintain concurrency rules for all concurrency event types in the multi-tasking software system, and pass the concurrency rules to the concurrency control and scheduling module through the interface; Concurrency control and scheduling module: used to maintain the status information of all received submission events, and generate the concurrency control information of the received submission events according to the status information and the received concurrency rules, and return the concurrency control information to task module. 5. The device for processing concurrent events in the multi-tasking software system according to claim 4, wherein the concurrent rule module includes: Concurrency rule matrix module: used to use matrix to centrally represent concurrency rules of all concurrency event types in a multi-tasking software system. 6. The device for processing concurrent events in the multi-tasking software system according to claim 5, wherein the concurrent control and scheduling module specifically includes: Concurrent scheduling module: used to maintain the state information of all events being processed and all events waiting to be processed, including the type and priority information of the event, and pass the event state information to the concurrency control module; Concurrency control module: used to determine the status information of the received submitted event according to the received concurrency rules and the event status information passed by the concurrency scheduling module, and generate corresponding concurrency control information, and pass the concurrency control information to the task module ; Event processing status information receiving module: used to receive the event processing status information returned by the task module. After receiving the status information that the event processing is completed, it will notify the concurrent scheduling module to submit the event with the highest priority among the events waiting to be processed to Concurrency control module. 7. The device for processing concurrent events in the multi-task software system according to claim 6, wherein the concurrent scheduling module includes: List of events currently being processed: used to arrange all events being processed in descending order of priority; List of events waiting to be processed: used to arrange all events that are in the state of waiting to be processed according to the priority from high to low. 8. The device for processing concurrent events in the multi-tasking software system according to claim 7, wherein the concurrent control module specifically includes: Concurrency Judgment Module: It is used to judge whether the received submission event can be concurrent according to the received concurrency rules. If it can be concurrent, it will notify the Concurrency Scheduling Module to add the event to the list of events currently being processed, and generate the concurrency control of the event information, and pass the information to the task module; if it cannot be concurrent, submit the event to the priority judgment module; Priority judging module: used to find out all events that have concurrent conflicts with the submitted event in the list of events currently being processed, and then judge whether the priority of the submitted event is greater than the priority of all found events, and if so, notify The concurrent scheduling module adds the event to the list of events currently being processed, and adds all found events to the list of events waiting to be processed or discards them; otherwise, adds the event to the list of events waiting to be processed, and then generates corresponding concurrency control information, and Pass that information to the task module. 9. The device for processing concurrent events in the multi-tasking software system according to claim 8, wherein the concurrent control module includes: The current concurrency rule generation module: used for obtaining the current concurrency rule list through AND operation according to the concurrency rules of all types of events being processed in the multi-tasking software system, and passing the list to the concurrency judgment module. 10. A method for processing concurrent events in a multitasking software system, comprising: A. Set concurrency rules and priority information of concurrent event types in the multi-tasking software system; B. According to the set information, correspondingly process the concurrent events that need to be processed in the multi-tasking software system. 11. The method for processing concurrent events in the multi-tasking software system according to claim 10, wherein said step A further comprises: According to the concurrency rules of all event types being processed in the multi-tasking software system, the current concurrency rule list is obtained by performing an AND operation. 12. The method for processing concurrent events in the multi-tasking software system according to claim 10 or 11, wherein the step B specifically includes: B1. According to the concurrency rules of all types of events being processed in the multi-tasking software system, judge whether the concurrent events that need to be processed can be concurrent, and if so, perform step B2; otherwise, perform step B3; B2. Determine that the current state of the concurrent event that needs to be processed is the processing state, and perform corresponding transaction processing on the event; B3. According to the relationship between the priorities of the concurrent events that need to be processed and the priorities of all events that have concurrency conflicts, determine whether the concurrent events that need to be processed can be concurrent. 13. The method for processing concurrent events in the multi-tasking software system according to claim 12, wherein said step B3 specifically comprises: B31. Find all events that have concurrency conflicts with the concurrent events that need to be processed in the events that are currently being processed. If the priority of the concurrent events that need to be processed is greater than the priority of all found events, then Execute step B32; otherwise, execute step B33; B32. Determine that the state of the concurrent event that needs to be processed is the processing state, perform corresponding transaction processing on the event, update the state of the found event to the waiting processing state and suspend the event, or, find the event events are discarded directly; B33. Determine that the current state of the concurrent event that needs to be processed is a waiting state, and suspend the event. 14. The method for processing concurrent events in the multi-tasking software system according to claim 13, wherein said step B further comprises: After an event being processed in the multi-tasking software system is processed, the event with the highest priority among the events waiting to be processed becomes a concurrent event that needs to be processed currently.

Images