CN112328202B - A flow control method, device, electronic equipment, and storage medium - Google Patents

Abstract

The application discloses a flow control method, a flow control device, an electronic device and a computer readable storage medium, wherein the method comprises the following steps: receiving first target data sent by an upstream module, and storing the first target data into a cache; the flow of the first target data is larger than the preset flow; when the flow count value is smaller than a first threshold value, accumulating the flow meter values in the cache under the back pressure action of a downstream module; when the flow count value is accumulated to a first threshold value, performing back pressure on the upstream module, stopping receiving the first target data, and under the condition that the back pressure of the downstream module is released, outputting the first target data in the cache to the downstream module, and reducing the flow meter value; when the flow count value is reduced to a second threshold value, the back pressure of the upstream module is released, and the first target data is continuously received; wherein the second threshold is less than the first threshold. Therefore, the flow control method provided by the application can improve the stability and the correctness of the flow transmission system.

Description

A flow control method, device, electronic equipment, and storage medium

technical field

The present application relates to the field of computer technology, and more specifically, to a flow control method and device, an electronic device, and a computer-readable storage medium.

Background technique

In the flow system, because the processing flow is very long, in order to simplify the design and clear the hierarchy, the system is classified and divided into different modules for processing. FIFO (full name in Chinese: First In First Out, full name in English: First Input First Output) is usually used for isolation between modules and sub-modules inside the module. When traffic is transmitted between upstream and downstream modules and sub-modules inside the module, the empty (empty) and full (full) flags of the FIFO are used for processing. After detecting that the FIFO empty flag of the upstream module is not empty (empty==0), and the FIFO full flag of the current level is not full (full=0), the traffic is received, and after corresponding traffic processing is performed, it is cached in the FIFO of the current level. In the above scheme, when the flow rate is large or the flow jitter is large, the downstream modules or sub-modules will back-pressure the upstream modules or sub-modules step by step, and the back-pressure will be frequent and the flow will be unstable.

Therefore, how to improve the stability of flow control is a technical problem to be solved by those skilled in the art.

application content

The purpose of the present application is to provide a flow control method and device, an electronic device and a computer-readable storage medium, which improve the stability of flow control.

In order to achieve the above purpose, this application provides a flow control method, which is applied to the target module, including:

receiving the first target data sent by the upstream module, and storing the first target data in the cache; wherein, the flow of the first target data is greater than the preset flow;

When the flow count value in the cache is less than the first threshold, under the back pressure of the downstream module, the flow count value is accumulated;

When the flow count value has accumulated to the first threshold, back pressure is applied to the upstream module, and the first target data is stopped to be received; when the back pressure of the downstream module is released, the The module outputs the first target data in the cache, and the traffic count value decreases;

When the flow count value decreases to a second threshold, the back pressure on the upstream module is released and continues to receive the first target data; wherein the second threshold is smaller than the first threshold.

Among them, also include:

receiving the second target data sent by the upstream module, storing the second target data in the cache, and accumulating the traffic count value; wherein, the traffic of the second target data is less than or equal to the preset flow;

When the flow count value is less than or equal to the second threshold value, the flow count value is accumulated;

When the flow count value is greater than the second threshold, the second target data in the cache is output to the downstream module, and when the flow output speed is greater than the flow input speed, the flow count value is decreased.

Wherein, when the flow output speed is greater than the flow input speed, after the flow count value is reduced, it also includes:

When the flow count value is zero, stop outputting data.

Wherein, before receiving the first target data sent by the upstream module, it also includes:

Initializing the first pipeline identifier and the second pipeline identifier as a first preset value;

Correspondingly, when the flow count value is less than the first threshold, under the back pressure of the downstream module, the flow count value in the cache is accumulated, including:

When the flow count value is less than or equal to the second threshold, the first pipeline identifier and the second pipeline identifier are both the first preset value, and under the back pressure of the downstream module, the The traffic count value in the cache is accumulated;

When the flow count value is greater than the second threshold and less than the first threshold, the first pipeline is identified as the first preset value, and the second pipeline is identified as the second preset value, so The above flow counter value continues to accumulate.

Wherein, when the flow count value is accumulated to the first threshold, back pressure is applied to the upstream module to stop receiving the first target data, and when the back pressure of the downstream module is released, the The downstream module outputs the first target data in the cache, and the traffic count value decreases, including:

When the flow count value has accumulated to the first threshold, the first pipeline identifier and the second pipeline identifier are both the second preset value, and the upstream module is back-pressurized to stop receiving the the first target data;

When the upstream module responds to the back pressure and the back pressure of the downstream module is released, the first target data in the buffer is output to the downstream module, and the flow count value decreases.

Wherein, before receiving the second target data sent by the upstream module, it also includes:

Initialize the second pipeline identification as the first preset value;

When the flow count value is less than or equal to the second threshold value, the flow count value is accumulated, including:

When the flow count value is less than or equal to the second threshold value, the second pipeline is identified as the first preset value, and the flow count value is accumulated;

When the flow count value is greater than the second threshold, output the second target data in the cache to the downstream module, and when the flow output speed is greater than the flow input speed, the flow count value is reduced, including :

When the flow count value is greater than the second threshold, the second pipeline is identified as the second preset value, and outputs the second target data in the cache to the downstream module, and when the flow output speed is greater than In case of flow input speed, the flow count value decreases.

In order to achieve the above purpose, the present application provides a flow control device, which is applied to the target module, including:

The first receiving module is configured to receive the first target data sent by the upstream module, and store the first target data in the cache; wherein, the flow of the first target data is greater than the preset flow;

A first accumulation module, configured to accumulate the flow count value in the cache under the back pressure of the downstream module when the flow count value is less than the first threshold;

The first output module is configured to apply back pressure to the upstream module when the flow count value reaches the first threshold, stop receiving the first target data, and when the back pressure of the downstream module is released In this case, the first target data in the cache is output to the downstream module, and the traffic count value is reduced;

A release module, configured to release the back pressure on the upstream module and continue to receive the first target data when the flow count value decreases to a second threshold; wherein the second threshold is smaller than the first threshold .

Among them, also include:

The second receiving module is configured to receive the second target data sent by the upstream module, store the second target data in the cache, and accumulate the traffic count value; wherein, the traffic of the second target data less than or equal to the preset flow rate;

A second accumulation module, configured to accumulate the flow count value when the flow count value is less than or equal to the second threshold;

The second output module is configured to output the second target data in the cache to the downstream module when the flow count value is greater than the second threshold, and when the flow output speed is greater than the flow input speed, the The flow counter value decreases.

In order to achieve the above purpose, the application provides an electronic device, including:

memory for storing computer programs;

A processor, configured to implement the steps of the above flow control method when executing the computer program.

To achieve the above purpose, the present application provides a computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the steps of the flow control method described above are implemented.

It can be known from the above solutions that a flow control method provided by the present application includes: receiving the first target data sent by the upstream module, and storing the first target data in the cache; wherein, the flow rate of the first target data is greater than Preset flow rate; when the flow count value is less than the first threshold, under the back pressure of the downstream module, the flow count value in the cache is accumulated; when the flow count value is accumulated to the first threshold value, Putting back pressure on the upstream module, stopping receiving the first target data, and outputting the first target data in the cache to the downstream module when the back pressure of the downstream module is released, the traffic The count value decreases; when the flow count value decreases to a second threshold, the back pressure on the upstream module is released, and the first target data continues to be received; wherein, the second threshold is smaller than the first threshold.

In this application, flow control is performed in a FIFO high and low pipeline manner, that is, the first threshold is the high pipeline, and the second threshold is the low pipeline. When the flow count value in the buffer is smaller than the first threshold, the downstream module performs back pressure on the target module, and the flow count value is accumulated. When the flow count value reaches the first threshold value, the back pressure of the downstream module is released, the target module exerts back pressure on the upstream module, and the flow count value decreases. It can be seen that the flow control method provided by the present application does not frequently perform back pressure. When the back pressure is released, it can at least cache the data of the difference between the first threshold and the second threshold, thereby improving the stability and stability of the flow of the flow transmission system. correctness. The application also discloses a flow control device, an electronic device and a computer-readable storage medium, which can also achieve the above-mentioned technical effects.

It is to be understood that both the foregoing general description and the following detailed description are exemplary only and are not restrictive of the application.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present application or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present application. Those skilled in the art can also obtain other drawings based on these drawings without creative work. The accompanying drawings are used to provide a further understanding of the present disclosure, and constitute a part of the description, together with the following specific embodiments, are used to explain the present disclosure, but do not constitute a limitation to the present disclosure. In the attached picture:

Fig. 1 is a flow chart showing a flow control method according to an exemplary embodiment;

Fig. 2 is a schematic diagram of a large flow input according to an exemplary embodiment;

FIG. 3 is a schematic diagram of a large flow input using the FIFO empty and full marking method in the related art;

Fig. 4 is a flow chart showing another flow control method according to an exemplary embodiment;

Fig. 5 is a schematic diagram of a small flow input according to an exemplary embodiment;

Fig. 6 is a schematic diagram of small flow input using the FIFO empty and full marking method in the related art;

Fig. 7 is a structural diagram of a flow control device according to an exemplary embodiment;

Fig. 8 is a structural diagram of an electronic device according to an exemplary embodiment.

Detailed ways

The technical solutions in the embodiments of the present application will be clearly and completely described below in conjunction with the drawings in the embodiments of the present application. Apparently, the described embodiments are only some of the embodiments of this application, not all of them. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of this application. In addition, in the embodiments of the present application, "first", "second", etc. are used to distinguish similar objects, and are not necessarily used to describe a specific sequence or sequence.

The embodiment of the present application discloses a flow control method, which improves the stability of the flow control.

Referring to FIG. 1, a flow chart of a flow control method shown according to an exemplary embodiment, as shown in FIG. 1, includes:

S101: Receive the first target data sent by the upstream module, and store the first target data in the cache; wherein, the traffic of the first target data is greater than the preset traffic;

The execution subject of this embodiment is the target module, and the purpose is to realize large flow control, where the large flow refers to the first target data whose flow rate is greater than the preset flow rate. In a specific implementation, the upstream module sends the first target data to the target module, the target module stores it in a cache, such as FIFO, and the target module sends the first target data to the downstream module.

S102: When the flow count value in the buffer is smaller than the first threshold, under the back pressure of the downstream module, the flow count value is accumulated;

In this step, the traffic count value in the buffer starts to accumulate from zero. If it is less than the first threshold, the downstream module backpressures the target module, and the target module does not backpressure the upstream module, so the traffic count value continues to accumulate .

In this embodiment, the empty and full flags in the related art can be replaced with the high and low pipeline flags, that is, the first pipeline flag is used to replace the full flag (full) in the related technology, and the second pipeline flag is used to replace the empty flag ( empty). Specifically, before receiving the first target data sent by the upstream module, it also includes: initializing the first pipeline identification and the second pipeline identification to the first preset value; correspondingly, when the flow count value is less than the first threshold , under the back pressure of the downstream module, the traffic count value in the cache is accumulated, including: when the traffic count value is less than or equal to the second threshold, the first pipeline identifier and the second pipeline The flags are all the first preset value, and under the back pressure of the downstream module, the flow count value in the buffer is accumulated; when the flow count value is greater than the second threshold and less than the first threshold , the first pipeline is identified as the first preset value, the second pipeline is identified as the second preset value, and the flow count value continues to accumulate.

The above-mentioned first preset value may be 0, and the second preset value may be 1. It can be understood that the cached queue depth (FIFO_DEPTH)≥the first threshold (high_wl_cfg)≥the second threshold (low_wl_cfg)≥0. In a specific implementation, when the flow count value (counter) ≥ high_wl_cfg, the first pipeline flag (high_wl_flag) = 1, until counter ≤ the second pipeline flag (low_wl_cfg), high_wl_flag = 0. When counter>low_wl_cfg, the second pipeline flag (low_wl_flag)=1, until counter=0, low_wl_flag=0.

S103: When the flow count value has accumulated to the first threshold, apply back pressure to the upstream module, stop receiving the first target data, and send to the downstream module when the back pressure of the downstream module is released The downstream module outputs the first target data in the cache, and the traffic count value decreases;

In this step, the flow count value is accumulated to the first threshold, the target module exerts back pressure on the upstream module, and the downstream module releases the back pressure on the target module, that is, the target module stops receiving the first target data from the upstream module and starts sending to the downstream module The first target data in the cache.

Further, considering that the upstream module needs to respond to the back pressure of the target module, there is a response time, that is, when the flow count value has accumulated to the first threshold, the upstream module will be back pressured and stop receiving the For the first target data, when the back pressure of the downstream module is released, output the first target data in the cache to the downstream module, and the flow count value decreases, including: when the flow count value is accumulated When the first threshold is reached, the first pipeline identifier and the second pipeline identifier are both the second preset value, and the upstream module is back pressured to stop receiving the first target data; When the upstream module responds to the back pressure and the back pressure of the downstream module is released, output the first target data in the cache to the downstream module, and the flow count value decreases.

S104: When the flow count value decreases to a second threshold, release the back pressure on the upstream module, and continue to receive the first target data; wherein, the second threshold is smaller than the first threshold.

In this step, the flow count value decreases to the second threshold, the back pressure on the upstream module is released, and the first target data is continued to be received from the upstream module. It can be understood that, in the extreme case where the downstream module immediately continues to backpressure the target module, the upstream module can also continuously input the data of the difference between the first threshold and the second threshold to the target module before receiving the backpressure signal.

In the following, FIFO_DEPTH=16, high_wl_cfg=12, low_wl_cfg=4 will be described, and the technical solution provided by this embodiment may include the following steps:

Step A: counter=0. The upstream module has a large flow input buffer into the FIFO, and the downstream module backpressures the FIFO. The counter count value is accumulated;

Step B: counter＝5, counter>low_wl_cfg, so low_wl_flag＝1; the upstream module has a large flow input buffer into the FIFO, and the counter count value continues to accumulate;

Step C: counter=12, counter>high_wl_cfg, so high_wl_flag=1; this module performs back pressure on the upstream module, the upstream module does not deal with the back pressure in time, responds to the back pressure after outputting 1 flow, stops the output, counter=13;

Step D: The back pressure of the downstream module on the current module is released intermittently, the current module outputs flow to the downstream module, the counter count value becomes smaller, counter=10, counter<high_wl_cfg, but high_wl_flag=1, maintain the back pressure on the upstream module ;

Step E: The back pressure of the downstream module on the current module is intermittently released, the current module outputs flow to the downstream module, the counter count value becomes smaller, counter=4, counter<=low_wl_cfg, high_wl_flag=0, the back pressure on the upstream module is released , the upstream flow can be output to the current module; in the extreme case where the downstream module immediately exerts continuous back pressure on the current module, the upstream module can continuously input 8 flows before receiving the back pressure signal and stopping the output;

Step F: Repeat Step B to Step E. If counter=0 during the process, repeat steps A to E.

In the case of back pressure at the large flow outlet, the flow input schematic diagram using the FIFO high and low waterline method is shown in Figure 2, and the flow input schematic diagram using the FIFO empty and full mark method in the related technology is shown in Figure 3. It can be seen that the FIFO empty and full mark method is adopted, the upstream module is frequently back-pressed, the flow input is frequently switched on and off, and only a small amount of flow can be input each time; the FIFO high and low waterline method is adopted, and there is no frequent back-pressure, when the back-pressure is released , at least high_wl_cfg-low_wl_cfg traffic can be cached, and at least FIFO_DEPTH-high_wl_cfg backpressure response untimely traffic can be cached. While ensuring flow stability, it can also provide certain flow system correctness. It should be noted that the beneficial effect brought by the above-mentioned single-level cache, but in the traffic processing system, the number of cache levels is relatively large, and the cumulative beneficial effect will be more obvious.

In the embodiment of the present application, the FIFO high and low pipeline method is adopted for flow control, that is, the first threshold is the high pipeline, and the second threshold is the low pipeline. When the flow count value in the buffer is smaller than the first threshold, the downstream module performs back pressure on the target module, and the flow count value is accumulated. When the flow count value reaches the first threshold value, the back pressure of the downstream module is released, the target module exerts back pressure on the upstream module, and the flow count value decreases. It can be seen that the flow control method provided by the embodiment of the present application does not perform frequent back pressure. When the back pressure is released, at least the data of the difference between the first threshold and the second threshold can be cached to improve the stability of the flow of the flow transmission system. sex and correctness.

The technical solution for small flow control is introduced below, specifically:

Referring to FIG. 4 , a flow chart of another flow control method shown according to an exemplary embodiment, as shown in FIG. 4 , includes:

S201: Receive the second target data sent by the upstream module, store the second target data in the cache, and accumulate the traffic count value; wherein, the traffic of the second target data is less than or equal to the preset traffic;

The execution subject of this embodiment is the target module, and the purpose is to realize the small flow control, and the large flow here refers to the second target data whose flow rate is less than or equal to the preset flow rate. In a specific implementation, the upstream module sends the second target data to the target module, the target module stores it in the cache, and the target module sends the second target data to the downstream module.

S202: When the flow count value is less than or equal to the second threshold, accumulate the flow count value;

In this step, the traffic count value in the buffer starts to accumulate from zero, and if the traffic count value is less than the first threshold, the traffic count value continues to accumulate.

S203: When the flow count value is greater than the second threshold, output the second target data in the cache to the downstream module, and decrease the flow count value when the flow output speed is greater than the flow input speed .

In this step, the flow count value is greater than the second threshold, and the target module starts to send the second target data in the cache to the downstream module. Since the flow output speed is greater than the flow input speed, the flow count value decreases. When the flow count value is zero, stop outputting data.

Preferably, before receiving the second target data sent by the upstream module, it further includes: initializing the second pipeline identification as the first preset value; when the flow count value is less than or equal to the second threshold, the flow Count value accumulation, including: when the flow count value is less than or equal to the second threshold value, the second pipeline is identified as the first preset value, and the flow count value is accumulated; when the flow count value When it is greater than the second threshold, output the second target data in the cache to the downstream module, and when the flow output speed is greater than the flow input speed, the flow count value is reduced, including: when the flow count When the value is greater than the second threshold, the second pipeline is identified as the second preset value, and the second target data in the cache is output to the downstream module, and when the flow output speed is greater than the flow input speed Down, the flow count value decreases.

In the following, FIFO_DEPTH=16, high_wl_cfg=12, low_wl_cfg=4 will be described, and the technical solution provided by this embodiment may include the following steps:

Step A: counter=0. The upstream module has a small flow input buffer into the FIFO, and the counter count value is accumulated;

Step B: counter=5, counter>low_wl_cfg, so low_wl_flag=1; this module outputs traffic to the downstream module, the output rate>input rate, and the counter count value decreases;

Step C: counter=0, low_wl_flag=0; this module stops flow output;

Step D: Repeat Step A to Step C.

In the case of back pressure at the large flow outlet, the flow input schematic diagram using the FIFO high and low waterline method is shown in Figure 5, and the flow input schematic diagram using the FIFO empty and full mark method in the related technology is shown in Figure 6. It can be seen that with the FIFO empty and full mark method, the flow output is frequently switched on and off for the downstream module, and only a small amount of flow can be output each time; the FIFO high and low watermark method is used, and the output will not be frequent, and at least low_wl_cfg can be output each time Flow, to ensure flow stability. It should be noted that the beneficial effect brought by the above-mentioned single-level cache, but in the traffic processing system, the number of cache levels is relatively large, and the cumulative beneficial effect will be more obvious.

A flow control device provided in an embodiment of the present application is introduced below, and a flow control device described below and a flow control method described above may refer to each other.

Referring to FIG. 7 , a structural diagram of a flow control device according to an exemplary embodiment, as shown in FIG. 7 , includes:

The first receiving module 701 is configured to receive the first target data sent by the upstream module, and store the first target data in the cache; wherein, the traffic of the first target data is greater than the preset traffic;

The first accumulation module 702 is configured to accumulate the flow count value in the cache under the back pressure of the downstream module when the flow count value is less than the first threshold;

The first output module 703 is configured to apply back pressure to the upstream module when the flow count value reaches the first threshold, stop receiving the first target data, and release the back pressure on the downstream module In the case of , output the first target data in the cache to the downstream module, and the traffic count value decreases;

The release module 704 is configured to release the back pressure on the upstream module and continue to receive the first target data when the flow count value decreases to a second threshold; wherein the second threshold is smaller than the first threshold.

In the embodiment of the present application, the FIFO high and low pipeline method is adopted for flow control, that is, the first threshold is the high pipeline, and the second threshold is the low pipeline. When the flow count value in the buffer is smaller than the first threshold, the downstream module performs back pressure on the target module, and the flow count value is accumulated. When the flow count value is accumulated to the first threshold, the back pressure of the downstream module is released, the target module exerts back pressure on the upstream module, and the flow count value decreases. It can be seen that the flow control device provided by the embodiment of the present application does not perform frequent back pressure, and can at least buffer the data of the difference between the first threshold and the second threshold when the back pressure is released, improving the stability of the flow of the flow transmission system sex and correctness.

On the basis of the foregoing embodiments, as a preferred implementation manner, it also includes:

The second receiving module is configured to receive the second target data sent by the upstream module, store the second target data in the cache, and accumulate the traffic count value; wherein, the traffic of the second target data less than or equal to the preset flow rate;

A second accumulation module, configured to accumulate the flow count value when the flow count value is less than or equal to the second threshold;

The second output module is configured to output the second target data in the cache to the downstream module when the flow count value is greater than the second threshold, and when the flow output speed is greater than the flow input speed, the The flow counter value decreases.

On the basis of the foregoing embodiments, as a preferred implementation manner, it also includes:

A stop module, configured to stop outputting data when the flow count value is zero.

On the basis of the foregoing embodiments, as a preferred implementation manner, it also includes:

The first initialization module is used to initialize the first pipeline identifier and the second pipeline identifier to a first preset value;

Correspondingly, the first accumulation module 702 includes:

The first accumulating unit is configured to: when the flow count value is less than or equal to the second threshold value, the first pipeline identifier and the second pipeline identifier are both the first preset value, and in the downstream module Under the action of back pressure, the traffic count value in the cache is accumulated;

The second accumulating unit is configured to, when the flow count value is greater than the second threshold and less than the first threshold, identify the first pipeline as the first preset value, and identify the second pipeline as The second preset value, the flow count value continues to accumulate.

On the basis of the above embodiments, as a preferred implementation manner, the first output module 703 includes:

a stop unit, configured to react to the upstream module when the flow count value has accumulated to the first threshold, and the first pipeline identifier and the second pipeline identifier are both the second preset value. press, stop receiving the first target data;

An output unit, configured to output the first target data in the cache to the downstream module when the upstream module responds to the back pressure and the back pressure of the downstream module is released, and the flow count value decreases.

On the basis of the foregoing embodiments, as a preferred implementation manner, it also includes:

The second initialization module is used to initialize the second pipeline identification as the first preset value;

The second accumulation module is specifically a module for accumulating the flow count value when the flow count value is less than or equal to the second threshold, the second pipeline is identified as the first preset value;

The second output module is specifically that when the flow count value is greater than the second threshold, the second pipeline is identified as the second preset value, and outputs the second value in the cache to the downstream module. Target data, when the flow output speed is greater than the flow input speed, the flow count value is reduced by the module.

Regarding the apparatus in the foregoing embodiments, the specific manner in which each module executes operations has been described in detail in the embodiments related to the method, and will not be described in detail here.

Based on the hardware implementation of the above-mentioned program modules, and in order to implement the method of the embodiment of the present application, the embodiment of the present application also provides an electronic device. FIG. 8 is a structural diagram of an electronic device according to an exemplary embodiment, as shown in As shown in Figure 8, the electronic equipment includes:

Communication interface 1, which can exchange information with other devices such as network devices;

The processor 2 is connected to the communication interface 1 to realize information exchange with other devices, and is used to execute the flow control method provided by one or more of the above technical solutions when running a computer program. Instead, the computer program is stored on the memory 3 .

Of course, in actual application, various components in the electronic device are coupled together through the bus system 4 . It can be understood that the bus system 4 is used to realize connection and communication between these components. In addition to the data bus, the bus system 4 also includes a power bus, a control bus and a status signal bus. However, for the sake of clarity, the various buses are labeled as bus system 4 in FIG. 8 .

The memory 3 in the embodiment of the present application is used to store various types of data to support the operation of the electronic device. Examples of such data include: any computer program used to operate on an electronic device.

It can be understood that the memory 3 may be a volatile memory or a non-volatile memory, and may also include both volatile and non-volatile memories. Wherein, the non-volatile memory can be a read-only memory (ROM, Read Only Memory), a programmable read-only memory (PROM, Programmable Read-Only Memory), an erasable programmable read-only memory (EPROM, Erasable Programmable Read-Only Memory), Only Memory), Electrically Erasable Programmable Read-Only Memory (EEPROM, Electrically Erasable Programmable Read-Only Memory), Magnetic Random Access Memory (FRAM, ferromagnetic random access memory), Flash Memory (Flash Memory), Magnetic Surface Memory , CD, or CD-ROM (CD-ROM, Compact Disc Read-Only Memory); the magnetic surface storage can be disk storage or tape storage. The volatile memory may be random access memory (RAM, Random Access Memory), which is used as an external cache. By way of illustration and not limitation, many forms of RAM are available, such as Static Random Access Memory (SRAM, Static Random Access Memory), Synchronous Static Random Access Memory (SSRAM, Synchronous Static Random Access Memory), Dynamic Random Access Memory Memory (DRAM, Dynamic Random Access Memory), Synchronous Dynamic Random Access Memory (SDRAM, Synchronous Dynamic Random Access Memory), Double Data Rate Synchronous Dynamic Random Access Memory (DDRSDRAM, Double Data Rate Synchronous Dynamic Random Access Memory), Enhanced Synchronous Dynamic Random Access Memory (ESDRAM, Enhanced Synchronous Dynamic Random Access Memory), Synchronous Link Dynamic Random Access Memory (SLDRAM, SyncLink Dynamic Random Access Memory), Direct Memory Bus Random Access Memory (DRRAM, Direct Rambus Random Access Memory) . The memory 2 described in the embodiment of the present application is intended to include but not limited to these and any other suitable types of memory.

The methods disclosed in the foregoing embodiments of the present application may be applied to the processor 2 or implemented by the processor 2 . Processor 2 may be an integrated circuit chip with signal processing capabilities. In the implementation process, each step of the above method can be completed by an integrated logic circuit of hardware in the processor 2 or instructions in the form of software. The aforementioned processor 2 may be a general-purpose processor, DSP, or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, and the like. The processor 2 may implement or execute various methods, steps, and logic block diagrams disclosed in the embodiments of the present application. A general purpose processor may be a microprocessor or any conventional processor or the like. The steps of the method disclosed in the embodiments of the present application may be directly implemented by a hardware decoding processor, or implemented by a combination of hardware and software modules in the decoding processor. The software module can be located in the storage medium, and the storage medium is located in the memory 3, and the processor 2 reads the program in the memory 3, and completes the steps of the foregoing method in combination with its hardware.

When the processor 2 executes the program, the corresponding processes in the various methods of the embodiments of the present application are implemented, and details are not repeated here for the sake of brevity.

In an exemplary embodiment, the embodiment of the present application also provides a storage medium, that is, a computer storage medium, specifically a computer-readable storage medium, for example, including a memory 3 storing a computer program, and the above-mentioned computer program can be executed by the processor 2, To complete the steps described in the aforementioned method. The computer-readable storage medium may be memory such as FRAM, ROM, PROM, EPROM, EEPROM, Flash Memory, magnetic surface memory, optical disk, or CD-ROM.

Those of ordinary skill in the art can understand that all or part of the steps for realizing the above-mentioned method embodiments can be completed by hardware related to program instructions, and the aforementioned program can be stored in a computer-readable storage medium. When the program is executed, the It includes the steps of the above method embodiments; and the aforementioned storage medium includes: various media that can store program codes such as removable storage devices, ROM, RAM, magnetic disks or optical disks.

Alternatively, if the above-mentioned integrated units of the present application are realized in the form of software function modules and sold or used as independent products, they can also be stored in a computer-readable storage medium. Based on this understanding, the technical solution of the embodiment of the present application is essentially or the part that contributes to the prior art can be embodied in the form of a software product. The computer software product is stored in a storage medium and includes several instructions for Make an electronic device (which may be a personal computer, a server, or a network device, etc.) execute all or part of the methods described in the various embodiments of the present application. The aforementioned storage medium includes: various media capable of storing program codes such as removable storage devices, ROM, RAM, magnetic disks or optical disks.

The above is only a specific implementation of the application, but the scope of protection of the application is not limited thereto. Anyone familiar with the technical field can easily think of changes or substitutions within the technical scope disclosed in the application. Should be covered within the protection scope of this application. Therefore, the protection scope of the present application should be determined by the protection scope of the claims.

Claims (9)

1. A flow control method, characterized in that being applied to a target module, comprising: receiving the first target data sent by the upstream module, and storing the first target data in the cache; wherein, the flow of the first target data is greater than the preset flow; When the flow count value in the cache is less than the first threshold, under the back pressure of the downstream module, the flow count value is accumulated; When the flow count value has accumulated to the first threshold, back pressure is applied to the upstream module, and the first target data is stopped to be received; when the back pressure of the downstream module is released, the The module outputs the first target data in the cache, and the traffic count value decreases; When the flow count value decreases to a second threshold, the back pressure on the upstream module is released, and the first target data continues to be received; wherein, the second threshold is smaller than the first threshold; Before receiving the first target data sent by the upstream module, it also includes: Initializing the first pipeline identifier and the second pipeline identifier as a first preset value; Correspondingly, when the flow count value is less than the first threshold, under the back pressure of the downstream module, the flow count value in the cache is accumulated, including: When the flow count value is less than or equal to the second threshold, the first pipeline identifier and the second pipeline identifier are both the first preset value, and under the back pressure of the downstream module, the The traffic count value in the cache is accumulated; When the flow count value is greater than the second threshold and less than the first threshold, the first pipeline is identified as the first preset value, and the second pipeline is identified as the second preset value, so The above flow counter value continues to accumulate. 2. The flow control method according to claim 1, further comprising: receiving the second target data sent by the upstream module, storing the second target data in the cache, and accumulating the traffic count value; wherein, the traffic of the second target data is less than or equal to the preset flow; When the flow count value is less than or equal to the second threshold value, the flow count value is accumulated; When the flow count value is greater than the second threshold, the second target data in the cache is output to the downstream module, and when the flow output speed is greater than the flow input speed, the flow count value is decreased. 3. The flow control method according to claim 1, wherein, when the flow output speed is greater than the flow input speed, after the flow count value is reduced, further comprising: When the flow count value is zero, stop outputting data. 4. The flow control method according to claim 1, wherein when the flow count value reaches the first threshold value, back pressure is applied to the upstream module, and the receiving of the first target data is stopped. When the back pressure of the downstream module is released, the first target data in the cache is output to the downstream module, and the flow count value is reduced, including: When the flow count value has accumulated to the first threshold, the first pipeline identifier and the second pipeline identifier are both the second preset value, and the upstream module is back-pressurized to stop receiving the the first target data; When the upstream module responds to the back pressure and the back pressure of the downstream module is released, the first target data in the buffer is output to the downstream module, and the flow count value decreases. 5. The flow control method according to claim 2, wherein, before receiving the second target data sent by the upstream module, further comprising: Initialize the second pipeline identification as the first preset value; When the flow count value is less than or equal to the second threshold value, the flow count value is accumulated, including: When the flow count value is less than or equal to the second threshold value, the second pipeline is identified as the first preset value, and the flow count value is accumulated; When the flow count value is greater than the second threshold, output the second target data in the cache to the downstream module, and when the flow output speed is greater than the flow input speed, the flow count value is reduced, including : When the flow count value is greater than the second threshold, the second pipeline is identified as the second preset value, and outputs the second target data in the cache to the downstream module, and when the flow output speed is greater than In case of flow input speed, the flow count value decreases. 6. A flow control device, characterized in that it is applied to a target module, comprising: The first receiving module is configured to receive the first target data sent by the upstream module, and store the first target data in the cache; wherein, the flow of the first target data is greater than the preset flow; A first accumulation module, configured to accumulate the flow count value in the cache under the back pressure of the downstream module when the flow count value is less than the first threshold; The first output module is configured to apply back pressure to the upstream module when the flow count value reaches the first threshold, stop receiving the first target data, and when the back pressure of the downstream module is released In this case, the first target data in the cache is output to the downstream module, and the traffic count value is reduced; A release module, configured to release the back pressure on the upstream module and continue to receive the first target data when the flow count value decreases to a second threshold; wherein the second threshold is smaller than the first threshold ; Before receiving the first target data sent by the upstream module, it also includes: Initializing the first pipeline identifier and the second pipeline identifier as a first preset value; Correspondingly, when the flow count value is less than the first threshold, under the back pressure of the downstream module, the flow count value in the cache is accumulated, including: When the flow count value is less than or equal to the second threshold, the first pipeline identifier and the second pipeline identifier are both the first preset value, and under the back pressure of the downstream module, the The traffic count value in the cache is accumulated; When the flow count value is greater than the second threshold and less than the first threshold, the first pipeline is identified as the first preset value, and the second pipeline is identified as the second preset value, so The above flow counter value continues to accumulate. 7. The flow control device according to claim 6, further comprising: The second receiving module is configured to receive the second target data sent by the upstream module, store the second target data in the cache, and accumulate the traffic count value; wherein, the traffic of the second target data less than or equal to the preset flow rate; A second accumulation module, configured to accumulate the flow count value when the flow count value is less than or equal to the second threshold; The second output module is configured to output the second target data in the cache to the downstream module when the flow count value is greater than the second threshold, and when the flow output speed is greater than the flow input speed, the The flow counter value decreases. 8. An electronic device, characterized in that it comprises: memory for storing computer programs; A processor, configured to implement the steps of the flow control method according to any one of claims 1 to 5 when executing the computer program. 9. A computer-readable storage medium, wherein a computer program is stored on the computer-readable storage medium, and when the computer program is executed by a processor, the flow control according to any one of claims 1 to 5 is realized method steps.

Images