CN115525402A - Timer task processing method, software timer and storage medium - Google Patents

Abstract

The invention discloses a processing method of a timer task, a software timer and a storage medium, wherein a first task is provided with a threaded first timer queue, when the first task sets a timer, the timer is set to the first timer queue, and the earliest time-out timer in the first task is set to a timer scanning task; if the timer scanning task detects that a timer which is the earliest in time in the first task is up, sending a timer up-time notice to the first task; the first task scans the first timer queue according to the timer expiration notification. The main timer scanning work is shared by different tasks to be completed, the problem that the scanning work is concentrated on one task to cause bottleneck under the condition of using the timer in a large scale is avoided, and the problem of software timer lock conflict is avoided by adopting a threading idea, so that the system throughput rate is improved, and the method is suitable for the scene that the system uses a large number of software timers in a multi-core and multi-thread concurrent environment.

Description

Timer task processing method, software timer and storage medium

technical field

The invention relates to the technical field of computers, in particular to a timer task processing method, a software timer and a storage medium.

Background technique

At present, the existing software timer implementation idea is that the timer scan and timeout are completed by a dedicated timer scan task. Under the multi-core and multi-thread concurrent architecture, since the timer setting task and the timer scan task need to access the same Timer resources, resulting in more lock conflicts between multiple tasks that set timers, between tasks that set timers and timer scanning tasks, and the scanning work is concentrated in one task. In the case of large-scale use of timers It is easy to cause bottlenecks, especially in high CAPS (Call Attempts Per Second, the number of calls established per second) scenarios, and the impact on system performance is very obvious.

Contents of the invention

The purpose of the present invention is to at least solve one of the technical problems existing in the prior art, and provide a processing method, a software timer and a storage medium for a timer task, which can avoid the concentration of scanning work in the case of large-scale use of timers. A task causes a bottleneck.

In a first aspect, an embodiment of the present invention provides a method for processing a timer task, including:

The first task is provided with a threaded first timer queue, and when the first task sets a timer, set the timer to the first timer queue, and set the earliest time in the first task The timer setting for the timer scan task;

If the timer scanning task detects that the earliest timer in the first task expires, send a timer expiration notification to the first task;

The first task scans the first timer queue according to the timer expiration notification.

In a second aspect, an embodiment of the present invention provides a software timer, including a timer setting module and a timer scanning module, wherein:

The timer setting module is used to set the timer set by the first task to the threaded first timer queue of the first task, and set the earliest due timer in the first task to a given time device scan tasks;

The timer scanning module is used to detect whether the earliest timer in the first task expires, and when the earliest timer in the first task expires, report to the first task sending a timer expiration notification; and scanning the first timer queue when the first task receives the timer expiration notification.

In a third aspect, an embodiment of the present invention provides an operation control device, including at least one control processor and a memory for communicating with the at least one control processor; the memory stores information that can be processed by the at least one control processor. Instructions executed by the processor, the instructions are executed by the at least one control processor, so that the at least one control processor can execute the timer task processing method described in the embodiment of the first aspect above.

In a fourth aspect, an embodiment of the present invention provides a computer-readable storage medium, the computer-readable storage medium stores computer-executable instructions, and the computer-executable instructions are used to make a computer perform the above-mentioned first aspect embodiment. The processing method of the timer task.

The embodiment of the present invention includes: a timer task processing method, a software timer, an operation control device and a computer-readable storage medium. According to the scheme provided by the embodiment of the present invention, the first task sets the timer to the threaded first timer queue, and the scanning work of the first timer queue is done by the first task itself which sets the timer, and the timer scans The task only plays a basic role of timeout. The main timer scanning work is allocated to different tasks to complete, avoiding the bottleneck caused by the concentration of scanning work on one task in the case of large-scale use of timers, and avoiding software by using the idea of threading The problem of timer lock conflicts, thereby improving the system throughput rate, is suitable for scenarios where the system uses a large number of software timers in a multi-core and multi-threaded concurrent environment.

Additional features and advantages of the invention will be set forth in the description which follows, and in part will be apparent from the description, or may be learned by practice of the invention. The objectives and other advantages of the invention may be realized and attained by the structure particularly pointed out in the written description and claims hereof as well as the appended drawings.

Description of drawings

The accompanying drawings are used to provide a further understanding of the technical solution of the present invention, and constitute a part of the description, and are used together with the embodiments of the present invention to explain the technical solution of the present invention, and do not constitute a limitation to the technical solution of the present invention.

Below in conjunction with accompanying drawing and embodiment the present invention is further described;

FIG. 1 is an overall block diagram of a method for processing a timer task provided by an embodiment of the present invention;

FIG. 2 is a functional block diagram of a method for processing a timer task provided by an embodiment of the present invention;

Fig. 3 is the working flowchart of the software timer that the embodiment of the present invention provides from timer setting to overtime;

FIG. 4 is a schematic structural diagram of a software timer provided by an embodiment of the present invention;

Fig. 5 is a schematic structural diagram of an operation control device provided by an embodiment of the present invention.

detailed description

This part will describe the specific embodiment of the present invention in detail, and the preferred embodiment of the present invention is shown in the accompanying drawings. Each technical feature and overall technical solution of the invention, but it should not be understood as a limitation on the protection scope of the present invention.

In the description of the present invention, if the first and the second are described only for the purpose of distinguishing technical features, it cannot be understood as indicating or implying relative importance or implicitly indicating the number of indicated technical features or implicitly indicating The sequence of the indicated technical features.

In the description of the present invention, unless otherwise clearly defined, words such as setting, installation, and connection should be understood in a broad sense, and those skilled in the art can reasonably determine the specific meanings of the above words in the present invention in combination with the specific content of the technical solution.

Embodiments of the present invention provide a timer task processing method, a software timer and a storage medium, which can avoid bottlenecks caused by concentrating scanning tasks into one task in the case of large-scale use of timers.

The embodiments of the present invention will be further described below in conjunction with the accompanying drawings.

Referring to FIG. 1 and FIG. 2, FIG. 1 is an overall block diagram of a method for processing a timer task provided by an embodiment of the present invention;

FIG. 2 is a functional block diagram of a timer task processing method provided by an embodiment of the present invention.

The embodiment of the first aspect of the present invention provides a method for processing a timer task, including:

The first task is provided with a threaded first timer queue, and when the first task sets a timer, set the timer to the first timer queue, and set the earliest time in the first task The timer setting for the timer scan task;

If the timer scanning task detects that the earliest timer in the first task expires, send a timer expiration notification to the first task;

The first task scans the first timer queue according to the timer expiration notification.

According to the processing method of the timer task provided by the embodiment of the present invention, the first task sets the timer to the threaded first timer queue, and the scanning work of the first timer queue is performed by the first task itself which sets the timer Do, the timer scan task only plays a basic role of timeout, the main timer scan work is allocated to different tasks to complete, to avoid the bottleneck caused by the concentration of scan work on one task in the case of large-scale use of timers, by adopting threading The idea is to avoid the problem of software timer lock conflicts, thereby improving the system throughput rate, which is suitable for scenarios where the system uses a large number of software timers in a multi-core and multi-threaded concurrent environment.

In the processing method of the above-mentioned timer task, the second task is provided with a threaded second timer queue, and when the second task sets a timer, the timer is set to the second timer queue, and The earliest timer in the second task is set to the timer scanning task; the timer scanning task is provided with a timer array, and the timer array stores the earliest timing of the first task timer and the earliest expiry timer of the second task.

It can be understood that there may also be a third task, a fourth task, and more tasks. The method used by these tasks to process the timer task is the same as that of the first task and the second task, and these tasks are all provided with their own timing. When setting the timer, set the timer to its own timer queue, and set the earliest timer in its own timer queue to the timer array of the timer scanning task, and the timer of the timer scanning task The array stores the earliest timers for each task. When the timer scanning task detects that the earliest timer of a certain task expires, it sends a timer expiration notification to the task, so that the task scans its own timer queue according to the received timer expiration notification.

In the above method for processing the timer task, the timer scanning task polls and detects the earliest expired timers of all the tasks in the timer array.

In the timer array of the timer scanning task, the earliest timer for the first task may be stored, and the earliest timer for other tasks may be stored, that is, how many timer arrays may be stored in the timer array? The earliest timer of a task, by querying and detecting the earliest timers of all tasks in the timer array, it can be detected one by one whether the earliest timers of multiple tasks are due, and if it is time, it will be sent The corresponding task will be notified when the time comes.

With reference to Fig. 2, in the processing method of above-mentioned timer task, described first task is also provided with and is used for the timer that is set to described first timer queue is checked the heavy checking queue, and described heavy checking queue adopts Red-black tree data structure.

By setting up the duplicate checking queue, it is used to check the timers that are set repeatedly, and the red-black tree data structure is used to organize the duplicate checking queue, which can balance the two operations of searching and adding and deleting, with fast speed and low resource occupation.

In the above timer task processing method, the first timer queue adopts a red-black tree data structure, a binary tree data structure, a multi-fork data structure, an array data structure or a linked list data structure.

It can be understood that the second timer queue of the second task and the timer queues of other tasks can also adopt a red-black tree data structure, a binary tree data structure, a multi-fork data structure, an array data structure or a linked list data structure, This application does not limit it.

The above-mentioned timer task processing method will be described in detail below with reference to FIG. 3 . FIG. 3 is a working flow chart of the software timer provided by the embodiment of the present invention from timer setting to timeout.

The user of the first task sets the timer, first checks whether the timer is repeatedly set through the check queue, and then sets the timer to the threaded first timer queue of the first task to determine whether the timer is the first The earliest timer of the task, if so, the earliest timer of the first task is set to the timer array of the timer scanning task; the timer scanning task detects whether the earliest timer of the first task is due, If so, send an arrival notification to the first task; the first task starts to scan its own first timer queue, and sends a timer overtime notification to the user who sets the timer in the first task, so that the user can process the timer overtime message.

Referring to FIG. 4 , FIG. 4 is a schematic structural diagram of a software timer provided by an embodiment of the present invention.

The embodiment of the second aspect of the present invention provides a software timer, including a timer setting module 410 and a timer scanning module 420, wherein:

The timer setting module 410: for setting the timer set by the first task to the threaded first timer queue of the first task, and setting the earliest timer in the first task Give the timer scan tasks. The timer queue is organized by the red tree data structure. In addition, there is also a duplicate check queue organized by a red-black tree data structure, which is used to check the timers that are set repeatedly. Occupy less.

The timer scanning module 420: includes two parts, the first part is used to detect whether the timer that expires the earliest in the first task is due, and when the timer that expires the earliest in the first task expires The second part is used to scan the first timer queue when the first task receives the timer expiration notification. The whole process adopts threading technology without locking, and uses high-efficiency algorithms such as red-black tree/hash, thereby improving performance.

It should be noted that the red-black tree/hash data structure algorithm used in this embodiment is not the only algorithm for implementing this embodiment, and other data structure algorithms such as ordinary binary trees, multi-fork numbers, arrays, linked lists, etc. can be used to achieve This example.

The user of the first task uses the interface provided by the timer setting module 410 provided by this embodiment to set the timer, sets the timer task into the threaded timer queue of the first task, and simultaneously judges whether the timer is the first task. The earliest due timer of a task, if yes, set this timer to the timer scan task. When the timer scanning task detects that the first task’s earliest timer expires, it notifies the first task, the first task starts to scan its own timer queue, and sends a timeout notification to the user who set the timer, and the user processes the timer timeout Notice. The entire process accesses threaded data resources without lock overhead, which improves system throughput. At the same time, during this process, the use of related timer resources is dynamically scaled to avoid a large occupation of system resources when using a large number of timers.

Using the timer task processing method and software timer in the embodiment of the present invention, compared with other software timer implementation methods, in the multi-core and multi-thread concurrent architecture, it can achieve lock-free operation throughout the process, avoid lock overhead, and improve system performance. Performance, and the main timer work is shared by multiple tasks, avoiding bottlenecks caused by concentrating on one task, which is conducive to the large-scale use of timers. At the same time, the use of related timer resources is dynamically scaled to avoid a large occupation of system resources when using a large number of timers. It is suitable for scenarios where the system uses a large number of software timers in a multi-core and multi-thread concurrent environment.

Referring to FIG. 5 , FIG. 5 is a schematic structural diagram of an operation control device 500 provided by an embodiment of the present invention.

The embodiment of the third aspect of the present invention provides an operation control device 500, including at least one control processor 510 and a memory 520 for communicating with the at least one control processor 510; Instructions executed by the at least one control processor 510, the instructions are executed by the at least one control processor 510, so that the at least one control processor 510 can perform the timer task as described in the embodiment of the first aspect above Approach.

According to the operation control device 500 provided in the embodiment of the present invention, the first task sets the timer to the threaded first timer queue, and the scanning work of the first timer queue is done by the first task itself that sets the timer. The timer scanning task only plays a basic role of timeout. The main timer scanning work is divided into different tasks to complete, so as to avoid the bottleneck caused by the concentration of scanning work on one task in the case of large-scale use of timers. By adopting the idea of threading To avoid the problem of software timer lock conflicts, thereby improving the system throughput rate, it is suitable for scenarios where the system uses a large number of software timers in a multi-core and multi-threaded concurrent environment.

In addition, the embodiment of the fourth aspect of the present invention provides a computer-readable storage medium, the computer-readable storage medium stores computer-executable instructions, and the computer-executable instructions are used to make the computer execute the above-mentioned embodiment of the first aspect. The processing method of the timer task.

According to the computer-readable storage medium provided by the embodiment of the present invention, the first task sets the timer to the threaded first timer queue, and the scanning work of the first timer queue is done by the first task itself that sets the timer , the timer scanning task only plays a basic role of timeout. The main timer scanning work is allocated to different tasks to complete, avoiding the bottleneck caused by the concentration of scanning work on one task in the case of large-scale use of timers. By adopting threaded The idea is to avoid the problem of software timer lock conflicts, thereby improving the system throughput rate, which is suitable for scenarios where the system uses a large number of software timers in a multi-core and multi-threaded concurrent environment.

Those skilled in the art can understand that all or some of the steps and systems in the methods disclosed above can be implemented as software, firmware, hardware and an appropriate combination thereof. Some or all of the physical components may be implemented as software executed by a processor, such as a central processing unit, digital signal processor, or microprocessor, or as hardware, or as an integrated circuit, such as an application-specific integrated circuit . Such software may be distributed on computer readable media, which may include computer storage media or non-transitory media and communication media or transitory media. As is well known to those of ordinary skill in the art, the term computer storage media includes both volatile and nonvolatile, Removable and non-removable media. Computer storage media include, but are not limited to, RAM, ROM, EEPROM, flash memory or other memory technology, CD-ROM, digital versatile disk DVD or other optical disk storage, magnetic cartridges, tape, magnetic disk storage or other magnetic storage devices, or can be used in Any other medium that stores desired information and that can be accessed by a computer. In addition, as is well known to those of ordinary skill in the art, communication media typically embodies computer readable instructions, data structures, program modules, or other data in a modulated data signal such as a carrier wave or other transport mechanism, and may include any information delivery media .

The embodiments of the present invention have been described in detail above in conjunction with the accompanying drawings, but the present invention is not limited to the above embodiments. Within the scope of knowledge possessed by those of ordinary skill in the technical field, various modifications can be made without departing from the gist of the present invention. kind of change.

Claims (10)

1. A method for processing a timer task, comprising:

setting a first timer queue of threading in a first task, setting the timer to the first timer queue when the first task sets the timer, and setting the timer which is the earliest to be reached in the first task to a timer scanning task;

if the timer scanning task detects that a timer which is the earliest to be expired in the first task is expired, sending a timer expiration notice to the first task;

and the first task scans the first timer queue according to the timer expiration notice.

2. The method for processing the timer task according to claim 1, wherein a second task is provided with a second timer queue, and when the second task sets a timer, the timer is set to the second timer queue, and the earliest timer in the second task is set to a timer scanning task; the timer scanning task is provided with a timer array, and the timer array stores a timer of the earliest time-out of the first task and a timer of the earliest time-out of the second task.

3. The method for processing the timer task according to claim 2, wherein the timer scanning task polling detects a timer that is the earliest expiration of all tasks in the timer array.

4. The method for processing the timer task according to claim 1, wherein the first task is further provided with a duplicate checking queue for checking duplicate timers set to the first timer queue, and the duplicate checking queue adopts a red-black tree data structure.

5. The method for processing the timer task according to claim 1, wherein the first timer queue adopts a red-black tree data structure, a binary tree data structure, a multi-fork data structure, an array data structure or a linked list data structure.

6. A software timer, comprising:

a timer setting module, configured to set a timer set by a first task to a threaded first timer queue of the first task, and set a timer that expires earliest in the first task to a timer scanning task;

a timer scanning module, configured to detect whether an earliest expired timer in the first task expires, and send a timer expiration notification to the first task when the earliest expired timer in the first task expires; and means for scanning the first timer queue if the first task receives the timer expiry notification.

7. The software timer of claim 6, wherein the timer setting module is further configured to set a timer set by a second task to a second timer queue of the second task for threading, and set an earliest expired timer in the second task to a timer scanning task; the timer scanning task is provided with a timer array, and the timer array stores a timer of the earliest time-out of the first task and a timer of the earliest time-out of the second task.

8. The software timer of claim 7, wherein the timer scanning module polls a timer that detects the earliest expiration of all tasks stored in the timer array.

9. An operation control device comprising at least one control processor and a memory for communicative connection with the at least one control processor; the memory stores instructions executable by the at least one control processor to enable the at least one control processor to perform a method of processing a timer task as claimed in any one of claims 1 to 5.

10. A computer-readable storage medium storing computer-executable instructions for causing a computer to perform a method of processing a timer task according to any one of claims 1 to 5.

Images