CN107179942B - Real-time data analysis task distribution processing method based on multithreading - Google Patents
Real-time data analysis task distribution processing method based on multithreading Download PDFInfo
- Publication number
- CN107179942B CN107179942B CN201710344177.7A CN201710344177A CN107179942B CN 107179942 B CN107179942 B CN 107179942B CN 201710344177 A CN201710344177 A CN 201710344177A CN 107179942 B CN107179942 B CN 107179942B
- Authority
- CN
- China
- Prior art keywords
- data
- thread
- data processing
- distribution
- unprocessed
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000007405 data analysis Methods 0.000 title claims abstract description 19
- 238000003672 processing method Methods 0.000 title claims abstract description 11
- 238000012545 processing Methods 0.000 claims abstract description 182
- 238000000034 method Methods 0.000 claims abstract description 30
- 238000012544 monitoring process Methods 0.000 claims abstract description 21
- 239000013307 optical fiber Substances 0.000 claims abstract description 21
- 238000001514 detection method Methods 0.000 claims abstract description 6
- 230000009286 beneficial effect Effects 0.000 abstract description 2
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 230000005540 biological transmission Effects 0.000 description 2
- 238000010586 diagram Methods 0.000 description 2
- 238000013480 data collection Methods 0.000 description 1
- 230000007547 defect Effects 0.000 description 1
- 230000002349 favourable effect Effects 0.000 description 1
- 239000000835 fiber Substances 0.000 description 1
- 238000011160 research Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/48—Program initiating; Program switching, e.g. by interrupt
- G06F9/4806—Task transfer initiation or dispatching
- G06F9/4843—Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
- G06F9/4881—Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/48—Indexing scheme relating to G06F9/48
- G06F2209/483—Multiproc
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/48—Indexing scheme relating to G06F9/48
- G06F2209/486—Scheduler internals
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Complex Calculations (AREA)
Abstract
The invention discloses a real-time data analysis task distribution processing method based on multithreading, which comprises the following steps: (1) the data acquisition thread of the MZ optical fiber perimeter intrusion monitoring instrument acquires data in real time and stores the acquired data into a circular queue buffer pool; (2) the data distribution thread judges whether a new data processing thread needs to be created or not according to the number of unprocessed data in the circular queue buffer pool, and distributes the data in the circular queue buffer pool to the data processing thread in the form of a data task; (3) and the data processing thread receives and processes the data tasks distributed by the data distribution thread, and after the processing is finished, the data processing thread automatically sets the working state of the data processing thread to be idle. The invention realizes the multi-thread task distribution processing by dynamically creating a new data processing thread, and the threads are mutually matched, thereby having the advantages of high real-time performance and low missing report rate and being beneficial to improving the reliability of the overall performance of the perimeter detection early warning system.
Description
Technical Field
The invention relates to the field of optical fiber sensing data processing, in particular to a real-time data analysis task distribution processing method based on multiple threads.
Background
The MZ optical fiber perimeter intrusion monitoring instrument is based on Mach-Zehnder interference principle, utilizes the optical fiber cable to detect external vibration and distinguish illegal intrusion, is strong in anti-electromagnetic interference, and can realize long-distance real-time monitoring and positioning of vibration caused by perimeter intrusion. The MZ optical fiber perimeter intrusion monitoring instrument has the advantages of electromagnetic interference resistance, easiness in remote transmission and the like, can effectively overcome the defects of an electric sensor, and is rapidly developed in nearly ten years. As a key technology of a perimeter security system, the real-time and low-missing report rate positioning of intrusion is one of the main research directions of the perimeter monitoring and early warning system.
In practical application, a data acquisition thread of an MZ optical fiber perimeter intrusion detection instrument acquires and stores signals into a circular queue buffer pool in real time, and currently, a single thread is mostly adopted in the data analysis process, so that intrusion data generated in the processing process cannot be processed in real time, delay of intrusion data analysis is caused, the real-time performance is poor, and the requirement of the real-time performance of a system cannot be met; meanwhile, the delay of data analysis is accumulated continuously, data in the circular queue buffer pool overflows, and partial data is lost, so that the intrusion missing report rate is increased.
Therefore, there is a need for improvement of the above prior art to meet the requirement of monitoring the intrusion of the perimeter of the optical fiber fence in real time and with low false alarm rate during the information transmission process.
Disclosure of Invention
The invention provides a real-time data analysis task distribution processing method based on multithreading, which solves the problems and can dynamically create a data processing thread according to the actual situation by adopting a multithreading task distribution processing method with dynamic coordination among a data acquisition thread, a data distribution thread and a plurality of data processing threads.
In order to achieve the purpose, the invention adopts the following technical scheme:
a real-time data analysis task distribution processing method based on multithreading comprises the following steps:
(1) the data acquisition thread of the MZ optical fiber perimeter intrusion monitoring instrument acquires data in real time and stores the acquired data into a circular queue data buffer pool for temporarily storing the data;
(2) the data distribution thread of the MZ optical fiber perimeter intrusion monitoring instrument detects unprocessed data in a circular queue buffer pool and detects whether idle data processing threads exist or not, if all the data processing threads are in a busy state, a new data processing thread is dynamically established to form a task distribution processing process of multiple threads which are dynamically matched, the data distribution thread distributes the data in the circular queue buffer pool to the idle data processing threads of the MZ optical fiber perimeter intrusion monitoring instrument in a data task mode, and meanwhile, the working state of the data processing thread is set to be busy;
(3) and after the data processing thread receives the data tasks distributed by the data distribution thread, the data processing thread processes the data tasks, and after the processing is finished, the data processing thread automatically sets the working state of the data processing thread to be idle.
In the step (1), the starting state of the circular queue buffer pool is a circular empty queue, the circular queue buffer pool has a front representing the start of unprocessed data and a rear representing the end of unprocessed data, and the initial values of the front and the rear are both 0.
After the data acquisition thread stores the acquired data in the circular queue data buffer pool, the subscript front representing the starting position of unprocessed data in the circular queue data buffer pool is moved clockwise, and the value of the front is added with 1 every time one data is stored.
Further, in the step (2), the specific step of the data distribution thread distributing the unprocessed data to the data processing thread is as follows:
I. checking whether unprocessed data exists at present, and judging whether the unprocessed data in the circular queue buffer pool meets the processing condition;
II, inquiring the number of idle data processing threads;
and III, copying the unprocessed data by the data distribution thread, distributing the copied data to the data processing thread, adding b to the subscript value of the real in the circular queue buffer pool after each time of distributing the unprocessed data, wherein the distribution speed of the data distribution thread is higher than the acquisition speed of the data acquisition thread, and b represents the number of data points processed by a single data processing thread at one time.
Further, the specific method for the data distribution thread to check whether unprocessed data exists currently and to judge whether the unprocessed data in the circular queue buffer pool meets the processing condition is as follows: judging whether the number a of unprocessed data is not less than the processing number b of a single data processing thread, if a is less than b, the processing condition is not met, and the data distribution thread continues to monitor the circular queue buffer pool; if a is larger than or equal to b, the processing condition is met, the data distribution thread copies unprocessed data and distributes the data to the data processing threads in the idle state for processing, if all the data processing threads are in the busy state, a new data processing thread is created, the unprocessed data is distributed to the newly created data processing thread, and meanwhile, the working state of the data processing thread is set to be busy. The number of points of the unprocessed data is the number of subscripts passed by the real to reach the front clockwise.
Further, the specific method for copying unprocessed data by the data distribution thread is as follows: and copying b continuous Data into new Data [ k ] [ b ] by taking the real as a starting position, and after copying is finished, clockwise moving the real subscript representing the end position of unprocessed Data by b positions, wherein k represents the kth Data processing thread, and b represents the number of Data points processed by a single Data processing thread at one time.
Furthermore, each data processing thread is provided with a status Flag bit, the status Flag bit of the ith data processing thread is Flag [ i ], wherein i belongs to [0, M-1 ], and M is the total number of the data processing threads; in the step (2), the specific method for setting the working state of the data processing thread to be busy comprises the following steps: the data distribution thread detects the state Flag bit of each existing data processing thread in sequence, if the value of the state Flag bit is 0, the data processing thread is in an idle state, if the value of the state Flag bit is 1, the data processing thread is in a busy state, the detection sequence starts from Flag [0] until a data processing thread k in a first idle state is found, and the state Flag bit Flag [ k ] of the kth data processing thread is set to be 1; if all the existing data processing threads are in a busy state, a new data processing thread is created.
Further, in the step (3), a specific method for the data processing thread to set its own working state to idle is as follows: and assigning the Flag bit Flag [ k ] of the working state of the self to be 0, wherein the value range of k is [0, M-1 ], wherein k represents that the data processing thread is the kth data processing thread, and M represents the total number of the data processing threads.
A multithreading real-time data analysis task distribution processing system applying the method comprises a data acquisition thread, a data distribution thread, a data processing thread and a circular queue buffer pool of an MZ optical fiber perimeter intrusion monitoring instrument, wherein the data acquisition thread is used for acquiring data information in real time and storing the acquired data information into the circular queue buffer pool, the data distribution thread distributes data in the circular queue buffer pool to the data processing thread, and the data distribution thread creates a new data processing thread in real time to process unprocessed data under the working state that the existing data processing threads are busy, so that the dynamic distribution and processing processes of data processing are realized, and the data processing thread analyzes and processes the data.
Furthermore, the data processing threads all have a working state flag bit, and the data distribution thread judges whether the data processing threads are in an idle state according to the value of the working state flag bit of the data processing threads.
Compared with the prior art, the invention has the beneficial effects that:
by adopting a multi-thread task distribution processing method with dynamic coordination among a data acquisition thread, a data distribution thread and a plurality of data processing threads, the problem that the intrusion miss-report rate of the MZ optical fiber perimeter intrusion monitoring instrument is increased due to data analysis delay, buffer pool data overflow and partial data loss caused by single-thread data processing of the traditional MZ optical fiber perimeter intrusion monitoring instrument is solved;
the invention can automatically and dynamically create the data processing thread according to the needs, ensures the real-time processing of the data analysis task, and has the advantages of high real-time performance and low missing report rate; the reliability of the overall performance of perimeter detection early warning systems such as MZ optical fiber perimeter intrusion monitoring instruments is improved.
Drawings
The accompanying drawings, which are incorporated in and constitute a part of this application, illustrate embodiments of the application and, together with the description, serve to explain the application and are not intended to limit the application.
FIG. 1 is a flow chart of the algorithm of the present invention;
FIG. 2 is a diagram illustrating an initial state of a circular queue buffer pool according to the present invention;
FIG. 3 is a diagram illustrating the circular queue buffer pool with unprocessed data according to the present invention.
The specific implementation mode is as follows:
the invention is further described with reference to the following figures and examples.
It should be noted that the following detailed description is exemplary and is intended to provide further explanation of the disclosure. Unless defined otherwise, all technical and scientific terms used herein have the same meaning as commonly understood by one of ordinary skill in the art to which this application belongs.
It is noted that the terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of example embodiments according to the present application. As used herein, the singular forms "a", "an" and "the" are intended to include the plural forms as well, and it should be understood that when the terms "comprises" and/or "comprising" are used in this specification, they specify the presence of stated features, steps, operations, devices, components, and/or combinations thereof, unless the context clearly indicates otherwise.
The following embodiments are typical embodiments of the present application, and as shown in fig. 1, a data processing system for real-time data analysis task distribution processing based on multiple threads includes a data acquisition thread, a data distribution thread, a data processing thread and a circular queue buffer pool of an MZ fiber perimeter intrusion monitoring instrument, where the data acquisition thread is used to acquire data information in real time and store the acquired data information in the circular queue buffer pool, the data distribution thread distributes data in the circular queue buffer pool to the data processing thread, the data processing thread analyzes and processes the data, and in a busy working state of existing data processing threads, the data distribution thread creates a new data processing thread in real time to process unprocessed data, thereby implementing dynamic distribution, and processing of data processing, The processing process ensures real-time processing of data, is favorable for avoiding the problems of data analysis delay, buffer pool data overflow and partial data loss caused by single-thread data processing of the traditional MZ optical fiber perimeter intrusion monitoring instrument, improves the real-time performance of data processing and reduces the missing report rate.
A real-time data analysis task distribution processing method based on multithreading comprises the following specific steps:
step 1, collecting data in real time by a data collecting thread of an MZ optical fiber perimeter intrusion monitoring instrument
A data acquisition thread of the MZ optical fiber perimeter intrusion monitoring instrument acquires data in real time at a speed of 16MB/s and stores the acquired data into a circular queue buffer pool for temporarily storing unprocessed data; the memory of the circular queue buffer pool is 240MB, one single precision point is 4B, the initial state of the circular queue buffer pool is shown in fig. 2, wherein front represents the start of processing unprocessed data in the circular queue buffer pool, and rear represents the end of processing the unprocessed data, and in the initial state, front and rear are both 0, and the circular queue buffer pool is in a blank state, wherein 1MB =1024 × 1024B;
as shown in FIG. 3, each time a data collection thread collects a data, the data is stored in the circular queue buffer pool for front
Is the position of the queue at the index, and at the same time, the value of the index front indicating the position of the start of the queue is incremented by 1.
The data distribution thread monitors the circular queue buffer pool in real time and judges whether unprocessed data in the circular queue buffer pool meets processing conditions, specifically, the size relation between the number a of data points in the circular queue buffer pool and the number b of processing points of a single data processing thread is judged, if a < b, the processing conditions are not met, and the data distribution thread continues to monitor the circular queue buffer pool; if a is larger than or equal to b, the processing condition is met, whether a data processing thread in an idle state exists is detected, if the data processing thread in the idle state exists, a data distribution thread copies unprocessed data and distributes the data to the data processing thread in the idle state for processing, and meanwhile, the status flag position of the data processing thread is set to be 1, which indicates that the data processing thread is in a busy state; if all the data processing threads are in a busy state, dynamically creating new data processing threads, forming a multithread task distribution processing process which is dynamically matched with each other, distributing unprocessed data to the newly created data processing threads, and setting the status flag position of the data processing threads to be 1 to indicate that the data processing threads are in the busy state. The number of the unprocessed data is the number of subscripts passed by the real to reach the front clockwise.
The duration time of a general intrusion event is 200ms, that is, the corresponding point is 0.8M, in order to reduce the situation that the intrusion event is intercepted, the point of a single data processing thread is 2M, that is, b is 2M, in this embodiment, at a certain time, the value of a is 3M, a > b, the data processing condition is met, the data distribution thread sequentially detects the working state of the data processing thread, and the detection result is that the existing data processing threads are all in a busy state, therefore, the data distribution thread needs to create 1 new data processing thread to process 2M unprocessed data, and copy the unprocessed data into the new data processing thread to perform data processing, determine whether the data is the intrusion event, at the same time, mark the state of the newly created data processing thread at position 1, after the copying is completed, the index of real, which indicates the end position of unprocessed data, is shifted clockwise by 2M positions, where b indicates the number of data processed at a time by a single data processing thread.
The copying process comprises the following steps: and copying 2M continuous points of real-real +2M-1 into new Data [ k ] [ b ] by taking real as a starting position, and after copying is completed, clockwise moving the subscript of REAR representing the end position of unprocessed Data by 2M positions, wherein k represents the kth Data processing thread, and b represents the number of Data points processed by a single Data processing thread at one time.
After a data processing thread k is created, assigning a working state Flag [ k ] of the data processing thread k to 1, processing a data processing task distributed by a data distribution thread, after the processing is completed, assigning the working state Flag [ k ] of the data processing thread to 0 by the data processing thread, and suspending the data processing thread, wherein the value range of k is [0, M-1 ], wherein k represents that the data processing thread is the kth data processing thread, and M is the total number of the data processing threads.
The above description is only a preferred embodiment of the present application and is not intended to limit the present application, and various modifications and changes may be made by those skilled in the art. Any modification, equivalent replacement, improvement and the like made within the spirit and principle of the present application shall be included in the protection scope of the present application.
Although the embodiments of the present invention have been described with reference to the accompanying drawings, it is not intended to limit the scope of the present invention, and it should be understood by those skilled in the art that various modifications and variations can be made without inventive efforts by those skilled in the art based on the technical solution of the present invention.
Claims (4)
1. A real-time data analysis task distribution processing method based on multithreading is characterized in that: the method comprises the following steps:
(1) the data acquisition thread of the MZ optical fiber perimeter intrusion monitoring instrument acquires data in real time and stores the acquired data into a circular queue buffer pool for temporarily storing the data;
(2) the data distribution thread of the MZ optical fiber perimeter intrusion monitoring instrument detects unprocessed data in a circular queue buffer pool and detects whether idle data processing threads exist or not, if all the data processing threads are in a busy state, a new data processing thread is dynamically established to form a task distribution processing process of multiple threads which are dynamically matched, the data distribution thread distributes the data in the circular queue buffer pool to the idle data processing threads of the MZ optical fiber perimeter intrusion monitoring instrument in a data task mode, and meanwhile, the working state of the idle data processing threads is set to be busy;
(3) after receiving the data tasks distributed by the data distribution thread, the data processing thread processes the data tasks, and after the processing is finished, the data processing thread automatically sets the working state of the data processing thread to be idle;
in the step (1), the starting state of the circular queue buffer pool is a circular empty queue, the circular queue buffer pool has a subscript front representing the starting position of unprocessed data and a subscript rear representing the ending position of unprocessed data, and the initial values of the two are both 0;
in the step (2), the specific step of distributing the unprocessed data to the data processing thread by the data distribution thread is as follows:
I. checking whether unprocessed data exists at present, and judging whether the unprocessed data in the circular queue buffer pool meets the processing condition;
II, inquiring the number of idle data processing threads;
copying unprocessed data by the data distribution thread, distributing the copied data to the data processing thread, adding b to the subscript value of the real in the circular queue buffer pool after distributing one unprocessed data, wherein the distribution speed of the data distribution thread is higher than the acquisition speed of the data acquisition thread; b represents the processing point number of the single data processing thread;
the specific method for the data distribution thread to check whether unprocessed data exists currently and judge whether the unprocessed data in the circular queue buffer pool meets the processing condition is as follows: judging whether the number a of unprocessed data is not less than the processing number b of a single data processing thread, if a is less than b, the processing condition is not met, and the data distribution thread continues to monitor the circular queue buffer pool; if a is larger than or equal to b, the processing condition is met, the data distribution thread copies unprocessed data and distributes the unprocessed data to the data processing threads in the idle state for processing, if all the data processing threads are in the busy state, a new data processing thread is created, the unprocessed data is distributed to the newly created data processing thread, and meanwhile, the working state of the newly created data processing thread is set to be busy; wherein, the point number a of the unprocessed data is the subscript number of the real which reaches the front clockwise;
the specific method for copying the unprocessed data by the data distribution thread comprises the following steps: copying b continuous Data into new Data [ k ] [ b ] by taking the real as a starting position, and after copying is finished, clockwise moving a subscript real representing an end position of unprocessed Data by b positions, wherein k represents a kth Data processing thread;
each data processing thread is provided with a state Flag bit, the state Flag bit of the ith data processing thread is Flag [ i ], wherein i belongs to [0, M-1 ], and M is the total number of the data processing threads; in the step (2), the specific method for setting the working state of the idle data processing thread to be busy comprises the following steps: the data distribution thread detects the state Flag bit of each existing data processing thread in sequence, if the value of the state Flag bit is 0, the data processing thread is in an idle state, if the value of the state Flag bit is 1, the data processing thread is in a busy state, the detection sequence starts from Flag [0] until a data processing thread k in a first idle state is found, and the state Flag bit Flag [ k ] of the kth data processing thread is set to be 1; if the existing data processing threads are all in a busy state, a new data processing thread is created;
in the step (3), the specific method for setting the working state of the data processing thread to be idle by the data processing thread is as follows: and assigning the Flag bit Flag [ k ] of the working state of the self to be 0, wherein the value range of k is [0, M-1 ].
2. The multithreading-based real-time data analysis task distribution processing method according to claim 1, wherein: in the step (1), after the data acquisition thread stores the acquired data in the circular queue buffer pool, the subscript front representing the starting position of unprocessed data in the circular queue buffer pool is moved clockwise, and the value of front is increased by 1 every time data is stored.
3. A multithread-based real-time data analysis task distribution processing system to which the method according to claim 1 or 2 is applied, characterized in that: the data distribution device comprises a data acquisition thread, a data distribution thread, a data processing thread and a circular queue buffer pool of the MZ optical fiber perimeter intrusion monitoring instrument, wherein the data acquisition thread is used for acquiring data information in real time and storing the acquired data information into the circular queue buffer pool, the data distribution thread distributes the data in the circular queue buffer pool to the data processing thread, and under the working state that the existing data processing thread is busy, the data distribution thread creates a new data processing thread in real time to process unprocessed data meeting conditions, so that the dynamic distribution and processing process of data processing are realized, and the data processing thread analyzes and processes the data.
4. The multithreading-based real-time data analysis task distribution processing system of claim 3, wherein: the data processing threads are all provided with status flag bits, and the data distribution thread judges whether the data processing threads are in an idle state or not according to the numerical value of the working status flag bits of the data processing threads.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710344177.7A CN107179942B (en) | 2017-05-16 | 2017-05-16 | Real-time data analysis task distribution processing method based on multithreading |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710344177.7A CN107179942B (en) | 2017-05-16 | 2017-05-16 | Real-time data analysis task distribution processing method based on multithreading |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN107179942A CN107179942A (en) | 2017-09-19 |
| CN107179942B true CN107179942B (en) | 2020-12-01 |
Family
ID=59831132
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710344177.7A Active CN107179942B (en) | 2017-05-16 | 2017-05-16 | Real-time data analysis task distribution processing method based on multithreading |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107179942B (en) |
Families Citing this family (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108303396A (en) * | 2017-12-29 | 2018-07-20 | 深圳市太赫兹科技创新研究院 | Terahertz time-domain pulse signal acquisition methods, devices and systems |
| CN108390779A (en) * | 2018-02-11 | 2018-08-10 | 山东省农业信息中心 | A kind of data processing method and device |
| CN109284194B (en) * | 2018-08-16 | 2024-05-24 | 平安科技（深圳）有限公司 | Data acquisition method, credit investigation main body equipment, computer equipment and storage medium |
| CN112637173B (en) * | 2020-12-16 | 2024-02-27 | 南京丹迪克科技开发有限公司 | Upper computer control communication method for calibrating device of electric energy quality test analyzer |
| CN112637355B (en) * | 2020-12-25 | 2023-05-23 | 新天科技股份有限公司 | Multi-concurrency single-channel based wireless data processing method, device, equipment and medium |
| CN113596117B (en) * | 2021-07-14 | 2023-09-08 | 北京淇瑀信息科技有限公司 | Real-time data processing method, system, equipment and medium |
| CN118101899B (en) * | 2024-02-23 | 2025-02-11 | 宜兴市公安局 | A security monitoring storage information intelligent analysis management method and system |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103078812A (en) * | 2013-02-01 | 2013-05-01 | 北京傲天动联技术股份有限公司 | Method and equipment for forwarding data |
| CN103197968A (en) * | 2013-03-18 | 2013-07-10 | 焦点科技股份有限公司 | Thread pool processing method and system capable of fusing synchronous and asynchronous features |
| CN206039816U (en) * | 2016-08-16 | 2017-03-22 | 西安建筑科技大学 | Wireless Building Node Data Acquisition System and Fire Monitoring System Utilizing the System |
Family Cites Families (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9928034B2 (en) * | 2014-12-17 | 2018-03-27 | Nvidia Corporation | Work-efficient, load-balanced, merge-based parallelized consumption of sequences of sequences |
-
2017
- 2017-05-16 CN CN201710344177.7A patent/CN107179942B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103078812A (en) * | 2013-02-01 | 2013-05-01 | 北京傲天动联技术股份有限公司 | Method and equipment for forwarding data |
| CN103197968A (en) * | 2013-03-18 | 2013-07-10 | 焦点科技股份有限公司 | Thread pool processing method and system capable of fusing synchronous and asynchronous features |
| CN206039816U (en) * | 2016-08-16 | 2017-03-22 | 西安建筑科技大学 | Wireless Building Node Data Acquisition System and Fire Monitoring System Utilizing the System |
Also Published As
| Publication number | Publication date |
|---|---|
| CN107179942A (en) | 2017-09-19 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107179942B (en) | Real-time data analysis task distribution processing method based on multithreading | |
| US11747175B2 (en) | Utility pole location specifying system, utility pole location specifying apparatus, utility pole location specifying method, and non-transitory computer readable medium | |
| CN105277968B (en) | A kind of automatic excitation control method and device in earthquake stimulation source | |
| DE69421707D1 (en) | METHOD AND DEVICE FOR MONITORING AND DETERMINING A SYNCHRONOUS OPTICAL NETWORK | |
| WO2001077820A3 (en) | Method and apparatus for partitioning a resource between multiple threads within a multi-threaded processor | |
| DE112011101759B4 (en) | Sampling of idle transitions | |
| CN109558348A (en) | Data-moving method, apparatus and system | |
| CN106095413A (en) | The collocation method of a kind of bluetooth driver and device | |
| CN112291538A (en) | Video monitoring data storage method and device | |
| CN116388858A (en) | Fiber breakage detection method and device based on phase demodulation | |
| CN109766028B (en) | Touch control sub-management system and method for infrared touch screen | |
| CN105865611B (en) | A kind of method and device adjusting fiber-optic vibration detection threshold value | |
| CN110660225A (en) | Red light running behavior detection method, device and equipment | |
| CN110779614B (en) | Submarine cable anchor damage monitoring and positioning method and system based on distributed optical fiber sensing | |
| CN118376878A (en) | Cable fault determining system and method based on artificial intelligence and acquisition parameters | |
| CN103530173A (en) | Dynamic weighted event processing system and method | |
| CN103019869A (en) | Detection method for time series fault tree | |
| CN107067608B (en) | A kind of effective vibrational waveform intercept method based on three-level threshold determination | |
| CN117239617A (en) | Overhead cable routing inspection path determining system and method based on sensor parameters | |
| CN117436940A (en) | Filling station layout rationality analysis method and system, electronic equipment and storage medium | |
| CN106228718B (en) | System and method for detecting security threat by network | |
| CN116310782A (en) | Overhead cable fault prediction system | |
| CN106375113B (en) | Method, device and system for recording faults of distributed equipment | |
| CN110956770A (en) | Library network anti-theft system and use method thereof | |
| DE102020208206A1 (en) | Inertial sensor unit and method for detecting speech activity |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |