CN109508228A - A kind of data processing method, task execution device and task generating device - Google Patents
A kind of data processing method, task execution device and task generating device Download PDFInfo
- Publication number
- CN109508228A CN109508228A CN201710844524.2A CN201710844524A CN109508228A CN 109508228 A CN109508228 A CN 109508228A CN 201710844524 A CN201710844524 A CN 201710844524A CN 109508228 A CN109508228 A CN 109508228A
- Authority
- CN
- China
- Prior art keywords
- task
- waiting
- waiting task
- execution device
- operating status
- 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.)
- Pending
Links
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
-
- 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/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5061—Partitioning or combining of resources
- G06F9/5072—Grid computing
-
- 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/481—Exception handling
-
- 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/484—Precedence
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Mathematical Physics (AREA)
- Debugging And Monitoring (AREA)
Abstract
The embodiment of the invention discloses a kind of data processing method, task execution device and task generating devices, and wherein method includes: that task execution device obtains at least one waiting task that task generating device generates；Detect the operating status of any waiting task at least one described waiting task；If detecting, the operating status of target waiting task is untreated state, the operating status of the target waiting task is then updated to execution state, and the target waiting task is handled, the target waiting task is any waiting task at least one described waiting task, it can be based on the operating status of detection waiting task, waiting task is handled, to improve the efficiency of processing task.
Description
Technical field
The present invention relates to field of computer technology more particularly to a kind of data processing methods, task execution device and task
Generating device.
Background technique
With the fast development of Internet technology, task execution device task to be treated is more and more, is actually answering
In, since the task amount that individual task executes equipment processing is excessive, it will lead to task execution device and delay machine occur.Therefore, lead to
Multiple waiting tasks are often distributed into multiple tasks and execute equipment, the assigned task of each task execution device processing can
There is the problem of delay machine to avoid task execution device, still, if some task execution device breaks down, distributes to this
The task that business executes equipment cannot be performed, and cause the efficiency of processing task lower.
Summary of the invention
The embodiment of the present invention provides a kind of data processing method, task execution device and task generating device, can be based on inspection
The operating status for surveying waiting task, is handled waiting task, to improve the efficiency of processing task.
In a first aspect, being applied to task execution device, this method the embodiment of the invention provides a kind of data processing method
Include:
At least one waiting task that acquisition task generating device generates；
Detect the operating status of any waiting task at least one described waiting task；
If the operating status for detecting target waiting task is untreated state, by the target waiting task
Operating status is updated to execution state, and handles the target waiting task, and the target waiting task is institute
State any waiting task at least one waiting task.
Second aspect, the embodiment of the invention provides another data processing methods, are applied to task generating device, the hair
Method includes:
Generate at least one waiting task；
At least one described waiting task is sent to each task execution that task execution device set is included to set
It is standby.
The third aspect, the embodiment of the invention provides a kind of task execution device, which includes for holding
The unit of the method for the above-mentioned first aspect of row.
Fourth aspect, the embodiment of the invention provides a kind of task generating devices, which includes for holding
The unit of the method for the above-mentioned second aspect of row.
5th aspect, the embodiment of the invention provides a kind of task execution devices, including processor, input equipment, output
Equipment and memory, the processor, input equipment, output equipment and memory are connected with each other, wherein the memory is used for
Storage supports terminal to execute the computer program of the above method, and the computer program includes program instruction, the processor quilt
It is configured to call described program instruction, the method for executing above-mentioned first aspect.
6th aspect, the embodiment of the invention provides a kind of task generating devices, including processor, input equipment, output
Equipment and memory, the processor, input equipment, output equipment and memory are connected with each other, wherein the memory is used for
Storage supports terminal to execute the computer program of the above method, and the computer program includes program instruction, the processor quilt
It is configured to call described program instruction, the method for executing above-mentioned second aspect.
7th aspect, the embodiment of the invention provides a kind of computer readable storage medium, the computer storage medium
It is stored with computer program, the computer program includes program instruction, and described program instruction makes institute when being executed by a processor
State the method that processor executes above-mentioned first aspect or second aspect.
In the embodiment of the present invention, each task execution device passes through the operating status for detecting any waiting task, to fortune
Row state is that the waiting task of untreated state is handled, and can break down, cause to avoid some task execution device
The problem of task cannot be performed, and reduce the efficiency of task processing, and then the efficiency of processing task can be improved.
Detailed description of the invention
Technical solution in order to illustrate the embodiments of the present invention more clearly, below will be to needed in embodiment description
Attached drawing is briefly described, it should be apparent that, drawings in the following description are some embodiments of the invention, general for this field
For logical technical staff, without creative efforts, it is also possible to obtain other drawings based on these drawings.
Fig. 1 is a kind of schematic flow diagram of data processing method provided in an embodiment of the present invention；
Fig. 2 is the schematic flow diagram of another data processing method provided in an embodiment of the present invention；
Fig. 3 is the schematic flow diagram of another data processing method provided in an embodiment of the present invention；
Fig. 4 is a kind of structural representation block diagram of task execution device provided in an embodiment of the present invention；
Fig. 5 is a kind of structural representation block diagram of task generating device provided in an embodiment of the present invention；
Fig. 6 is the structural representation block diagram of another task execution device provided in an embodiment of the present invention；
Fig. 7 is the structural representation block diagram of another task generating device provided in an embodiment of the present invention.
Specific embodiment
Following will be combined with the drawings in the embodiments of the present invention, and technical solution in the embodiment of the present invention carries out clear, complete
Site preparation description, it is clear that described embodiments are some of the embodiments of the present invention, instead of all the embodiments.Based on this hair
Embodiment in bright, every other implementation obtained by those of ordinary skill in the art without making creative efforts
Example, shall fall within the protection scope of the present invention.
With the fast development of Internet technology, task execution device task to be treated is more and more, is actually answering
In, since the task amount that individual task executes equipment processing is excessive, it will lead to task execution device and delay machine occur.Therefore, lead to
Multiple waiting tasks are often distributed into multiple tasks and execute equipment, the assigned task of each task execution device processing can
There is the problem of delay machine to avoid task execution device, still, if some task execution device breaks down, distributes to this
The task that business executes equipment cannot be performed, and cause the efficiency of processing task lower, be proposed at a kind of data based on this present invention
Reason method, task execution device and task generating device, can based on detection waiting task operating status to waiting task
It is handled, to improve the efficiency of processing task.
In the present invention, task generating device can refer to terminal or server, and batch can be generated in task generating device
Waiting task such as can be generated and send the waiting task of PUSH message to multiple terminals or be generated as the game of multiple terminals
The waiting task that interface is rendered.
In addition, task generating device can passively generate waiting task, i.e. task generating device can receive equipment
Event request, and waiting task can be generated, if task generating device receives the message subscribing request of equipment, can be generated
The waiting task of PUSH message.Task generating device can also actively generate waiting task, as task generating device can be with
It detects that network video updates, and the waiting task of the notification message updated about pushing video can be generated.
In the present invention, task execution device can refer to terminal or server, and task generating device, which can be generated, to be criticized
Waiting task is measured, the rendering of PUSH message or the interface to multiple terminals is such as sent to multiple terminals.
In addition, the task execution device can execute the waiting task generated in task generating device, the task execution
Equipment can waiting task to be generated in executing tasks parallelly generating device, can also serially execute raw in task generating device
At waiting task.
It should be noted that above-mentioned task execution device and task generating device can be deployed in the same terminal or clothes
It is engaged in device, if terminal receives the process instruction for picture, which carries picture adjustment parameter, and terminal can basis
Picture adjustment parameter generates the waiting task for being directed to picture, and can execute the waiting task, completes to waiting task
Processing.
It is raw in order to be best understood from a kind of data processing method provided in an embodiment of the present invention and task execution device and task
Forming apparatus first describes the data processing method of the embodiment of the present invention below.
Referring to Figure 1, Fig. 1 is a kind of schematic flow diagram of data processing method provided in an embodiment of the present invention, this method
Equipment is executed applied to task generating device, multiple tasks, this method comprises:
S101, task generating device generate at least one waiting task.
In the embodiment of the present invention, task generating device can passively generate waiting task, i.e. task generating device can be with
The event request of receiving device, and at least one waiting task can be generated, as task generating device receives disappearing for equipment
Breath subscribes to request, and the waiting task of PUSH message can be generated.Task generating device can also actively generate at least one and wait for
Processing task updates as task generating device can detecte network video, and can be generated and lead to about what pushing video updated
Know the waiting task of message.
At least one waiting task is sent to each task execution device by S102, task generating device.
In the embodiment of the present invention, which is sent to each task execution and set by task generating device
It is standby, so that each task execution device can handle at least one waiting task.
For example, at least one waiting task can be generated in task generating device, at least one waiting task packet
Include task A, task B and task C.Task A, task B and task C are sent to task execution device F1 in task generating device, and
Task A, task B and task C are sent to task execution device F2.
S103, task execution device detect the operation shape of any waiting task at least one described waiting task
State.
It, can be with random after task execution device receives at least one waiting task in the embodiment of the present invention
Each waiting task operating status in sequence or preset sequence detection at least one waiting task.If detecting
The operating status of target waiting task is untreated state, thens follow the steps S104；If detecting target waiting task
Operating status is processed state or executes state, then the target waiting task can be skipped, to detect other to be processed
The operating status of business.
Wherein, above-mentioned preset sequence can refer to task generating device according to the preferential of at least one waiting task
Grade setting, the priority of a waiting task can refer to task generating device according to the generation of each waiting task
Time, or be arranged according to the processing processing grade of each waiting task.The processing grade can be task generating device
It may include that processing waiting task takes according to the setting of the attribute information of each waiting task, such as attribute information
The information such as long or waiting task source.
For example, it is preferential can to generate being sequentially generated for time according to task A, task B and task C for task generating device
Grade task A, task B and task C generates the time to have the sequence after arriving first is task C, task B, task A if detecting, can be with
The priority of setting task A, task B and task C are the highest priority of task C, and the priority of task A is minimum, and task B's is excellent
First grade is medium, and the priority of task A, task B and task C can be sent to task execution device, task by task generating device
Executing equipment can be according to the priority of task A, task B and task C, the operating status of first Detection task C, in Detection task B
Operating status, the operating status of last Detection task C.
If S104, the operating status for detecting target waiting task are untreated state, task execution device should
The operating status of target waiting task is updated to execution state, and handles the target waiting task.
In the embodiment of the present invention, if the operating status for detecting target waiting task is untreated state, task is held
The operating status of the target waiting task is updated to execution state by row equipment, and to the target waiting task at
Reason, can be repeatedly processed through vaporization, condensation and absorption to avoid to target waiting task, the efficiency of processing can be improved.
If S105, detecting that the target waiting task has been dealt with into, task execution device waits for the target
The operating status of processing task is updated to processed state.
In the embodiment of the present invention, if detecting, the target waiting task is had been dealt with into, task execution device
The operating status of the target waiting task can be updated to processed state, so as to obtain waiting task again.
Wherein, if task execution device to target waiting task operating status update after, other task execution devices can
To detect the updated operating status of target waiting task.I.e. task execution device can be by the target waiting task
Updated operating status be sent to other task execution devices；Task execution device can be by the target waiting task
Updated operating status is sent to task generating device, and task generating device can will be after the update of the target waiting task
Operating status be transmitted to other task execution devices, so that other task execution devices can detecte the target to be processed
It is engaged in updated operating status.
S106, by after prefixed time interval by least one waiting task generated again be sent to it is each this
Business executes equipment.
In the embodiment of the present invention, task generating device can pass through prefixed time interval will generate again later at least one
A waiting task is sent to each task execution device, so as to the more waiting tasks of task execution device processing.
For example, task execution device can detecte the operating status of task C, if the operating status of task C is not
Processing status, the operating status of task C can be updated to execution state by task execution device, and handle task C, located
After having managed task C, the operating status of task C can be updated to processed state.And it can successively Detection task B and task C
Operating status, if the state of task B and task C be processed state or execute state, task B and task can not be handled
C can obtain waiting task from task generating device again.
In the embodiment of the present invention, each task execution device passes through the operating status for detecting any waiting task, to fortune
Row state is that the waiting task of untreated state is handled, and can break down, cause to avoid some task execution device
The problem of task cannot be processed, reduces the efficiency of task processing, can also avoid waiting task from repeating processed, Jin Erke
To improve the efficiency of processing task.
Based on a kind of above-mentioned description to data processing method, present invention implementation provides another data processing method,
This method is applied to task generating device, and execution cluster tool belonging to the task execution device includes that multiple tasks execution is set
It is standby, refer to Fig. 2, as shown in Figure 2 the method may include:
S201, at least one waiting task that task generating device generates is obtained.
In the embodiment of the present invention, at least one to be processed of the available task generating device generation of task execution device
Business, so as to execute at least one waiting task.
S202, the operating status for detecting any waiting task at least one waiting task.
In the embodiment of the present invention, task execution device can any waiting task at least one waiting task
Operating status can repeat to task duplication to be processed processing to avoid the task execution device, and then processing task can be improved
Efficiency.
Wherein, the original state of the operating status of the waiting task can be the setting of task generating device, can also be with
It is task execution device setting.
Wherein, task execution device can be to be processed according to random order or preset sequence detection this at least one
The operating status of each waiting task in task, preset sequence can refer to that at least one is waited for task generating device according to this
Processing task priority setting, the priority of a waiting task can refer to task generating device according to it is each to
The generation time of processing task, or be arranged according to the processing processing grade of each waiting task.The processing grade can be with
It is that task generating device is arranged according to the attribute information of each waiting task, if the attribute information may include handling wait locate
Manage the information such as the source of required by task duration or waiting task.
As an alternative embodiment, available at least one waiting task of task execution device is preferential
Grade, according to the priority of at least one waiting task, is detected each to be processed at least one waiting task respectively
The operating status of task.
In the embodiment of the present invention, the priority of available at least one waiting task of task execution device, according to
The priority of at least one waiting task detects the fortune of each waiting task at least one waiting task respectively
Row state, task execution device can prioritize processing the high waiting task of priority, the flexibility of processing task can be improved.
If S203, the operating status for detecting target waiting task are untreated state, by the target to be processed
The operating status of business is updated to execution state, and handles the target waiting task, and the target waiting task is
Any waiting task at least one waiting task.
During the present invention is implemented, if detecting, the operating status of target waiting task is untreated state, task execution
The operating status of the target waiting task can be updated to execution state by equipment, and can be to the target waiting task
It is handled, can break down to avoid other task execution devices causes the target waiting task that cannot be performed, and causes
The lower problem of the efficiency of processing task.If detecting, the operating status of the target waiting task is processed state or execution
State illustrates that the target waiting task has been processed or just in processed, then the task execution device can not be held
The row target waiting task can be handled the target waiting task to avoid repetition.
As an alternative embodiment, if detecting, the target waiting task is had been dealt with into, should
The operating status of target waiting task is updated to processed state.
In the embodiment of the present invention, task execution device can determine that the target waits for when executing next waiting task
Processing task has been dealt with into, then the operating status of the target waiting task can be updated to processed state, can
To avoid repetition to target waiting task processing.
As an alternative embodiment, if detecting all waiting tasks at least one waiting task
Operating status be processed state, and from obtain at least one waiting task begin to pass through prefixed time interval, then obtain
At least one waiting task for taking the task generating device to generate.
In the embodiment of the present invention, since task generating device is generating waiting task, task execution device processing
Complete at least one waiting task can obtain waiting task again.It even detects at least one waiting task
All waiting tasks operating status be processed state, and from obtain at least one waiting task begin to pass through it is pre-
If time interval, then at least one waiting task that the available task generating device generates, to handle more wait locate
Reason task.
Wherein, above-mentioned prefixed time interval can be user setting, is also possible to task execution device and is appointed according to processing
The dynamic setting of the factors such as time needed for the speed of business or at least one waiting task, it can also be that the task execution is set
Standby device manufacturer's equipment, 1s is set by the prefixed time interval as task execution device can be set.
In the embodiment of the present invention, each task execution device passes through the operating status for detecting any waiting task, to fortune
Row state is that the waiting task of untreated state is handled, and can break down, cause to avoid some task execution device
The problem of task cannot be processed, reduces the efficiency of task processing, can also avoid waiting task from repeating processed, Jin Erke
To improve the efficiency of processing task.
Based on a kind of above-mentioned description to data processing method, present invention implementation provides another data processing method,
This method be applied to task generating device, refer to Fig. 3, as shown in Figure 3 the method may include:
S301, at least one waiting task is generated.
During the present invention is implemented, at least one waiting task is can be generated in task generating device.
S302, at least one waiting task is sent to each task execution that task execution device set is included
Equipment.
In the embodiment of the present invention, task generating device can be when receiving the acquisition request for waiting task, can
At least one waiting task is sent to each task execution device that task execution device set is included；Or appoint
At least one waiting task is sent to each task that task execution device set is included automatically and held by business generating device
Row equipment, so that each task execution device can handle at least one waiting task.
As a kind of optional embodiment mode, task generating device will be secondary again after can passing through prefixed time interval
At at least one waiting task be sent to each task execution device.
In the embodiment of the present invention, task generating device can pass through prefixed time interval will generate again later at least one
A waiting task is sent to each task execution device, so that each task execution device can handle more to be processed
Business.
As an alternative embodiment, task execution device can be according to each at least one waiting task
The generation time of a waiting task obtains the priority of each waiting task, or according to each waiting task
Processing grade obtains the priority of each waiting task, and the priority of at least one waiting task is sent respectively to
Each task execution device.
In the embodiment of the present invention, task execution device can be according to each to be processed at least one waiting task
The generation time of task obtains the priority of each waiting task, or the processing grade according to each waiting task
The priority for obtaining each waiting task, by the priority of at least one waiting task be sent respectively to it is each this
Business executes equipment, so that each task execution device can detect each be somebody's turn to do wait locate according to the priority of each waiting task
The operating status of reason task.
It is somebody's turn to do as an alternative embodiment, task generating device can store at least one waiting task to arrive
In the buffer area of task generating device, at least one waiting task is obtained from the buffer area, will acquire at least one
A waiting task is sent to each task execution device.
In the embodiment of the present invention, which can be stored to the task and be generated by task generating device
In the buffer area of equipment, at least one waiting task is obtained from the buffer area, at least one that will acquire is to be processed
Task is sent to each task execution device, and the efficiency for obtaining at least one waiting task can be improved.
In the embodiment of the present invention, at least one waiting task is can be generated in task execution device, and can be by this at least
One waiting task is sent to each task execution device, so that each task execution device can handle this, at least one is waited for
Processing task.Task execution device can store at least one waiting task to the buffer area of the task execution device,
The efficiency for obtaining the waiting task can be improved.
Based on a kind of above-mentioned description to data processing method, present invention implementation provides a kind of task execution device, asks
Referring to fig. 4, the task execution device may include: as shown in Figure 4
Acquiring unit 401, for obtaining at least one waiting task of task generating device generation.
Detection unit 402, for detecting the operating status of any waiting task at least one described waiting task.
Processing unit 403 will be described if the operating status for detecting target waiting task is untreated state
The operating status of target waiting task is updated to execution state, and handles the target waiting task, the mesh
Marking waiting task is any waiting task at least one described waiting task.
Optionally, the acquiring unit 401 is also used to obtain the priority of at least one waiting task；
Optionally, the detection unit 402 is divided specifically for the priority according at least one waiting task
Not Jian Ce at least one described waiting task each waiting task operating status.
Optionally, processing unit 403, if for detecting that the target waiting task has been dealt with into, it will
The operating status of the target waiting task is updated to processed state.
Optionally, the acquiring unit 401 is needed at least one described waiting task if being also used to detect
The operating status of processing task is processed state, and begins to pass through preset time from least one described waiting task is obtained
Interval then obtains at least one waiting task that the task generating device generates.
In the embodiment of the present invention, task execution device passes through the operating status for detecting each waiting task, to operation shape
State is that the waiting task of untreated state is handled, and can break down to avoid some task execution device, lead to task
Cannot be processed, the problem of reducing the efficiency of task processing, waiting task can also be avoided to repeat processed, and then can mentioned
The efficiency of high disposal task.
Based on a kind of above-mentioned description to data processing method, present invention implementation provides a kind of task generating device, asks
Referring to Fig. 5, the task generating device as shown in Figure 5 may include:
Generation unit 501, for generating at least one waiting task.
Transmission unit 502 included at least one described waiting task to be sent to task execution device set
Each task execution device.
Optionally, the transmission unit 502, be also used to by after prefixed time interval by generate again at least one
Waiting task is sent to each task execution device.
Optionally, acquiring unit 503, for according to each waiting task at least one described waiting task
The generation time obtains the priority of each waiting task；Or it is obtained according to the processing grade of each waiting task
Take the priority of each waiting task.
Optionally, acquiring unit 502 are also used to for the priority of at least one waiting task being sent respectively to respectively
A task execution device.
Optionally, storage unit 504, for storing at least one described waiting task to the task generating device
Buffer area in.
Optionally, acquiring unit 503 are also used to obtain at least one described waiting task from the buffer area.
Optionally, the transmission unit 502, at least one waiting task for being also used to will acquire are sent to each institute
State task execution device.
In the embodiment of the present invention, at least one waiting task is can be generated in task execution device, and can be by this at least
One waiting task is sent to each task execution device, so that each task execution device can handle this, at least one is waited for
Processing task.Task execution device can store at least one waiting task to the buffer area of the task execution device,
The efficiency for obtaining the waiting task can be improved.
Referring to Fig. 6, be another embodiment of the present invention provides a kind of task execution device schematic block diagram.Sheet as shown in the figure
Task execution device in embodiment may include: one or more processors 601；One or more input equipments 602, one
Or multiple output equipments 603 and memory 604.Above-mentioned processor 601, input equipment 602, output equipment 603 and memory 604
It is connected by bus 605.For memory 602 for storing computer program, the computer program includes program instruction, processor
601 for executing the program instruction of the storage of memory 602.Wherein, processor 601 is configured for that described program instruction is called to hold
Row following steps:
At least one waiting task that acquisition task generating device generates；
Detect the operating status of any waiting task at least one described waiting task；
If the operating status for detecting target waiting task is untreated state, by the target waiting task
Operating status is updated to execution state, and handles the target waiting task, and the target waiting task is institute
State any waiting task at least one waiting task.
Optionally, processor 601 is configured for calling described program instruction, and following steps can also be performed:
Obtain the priority of at least one waiting task；
The operating status of any waiting task at least one waiting task described in the detection, comprising:
According to the priority of at least one waiting task, detect respectively each at least one described waiting task
The operating status of a waiting task.
Optionally, processor 601 is configured for calling described program instruction, and following steps can also be performed:
If detecting, the target waiting task is had been dealt with into, by the operation of the target waiting task
State is updated to processed state.
Optionally, processor 601 is configured for calling described program instruction, and following steps can also be performed:
If detecting, the operating status of all waiting tasks at least one described waiting task is processed shape
State, and begin to pass through prefixed time interval from least one described waiting task is obtained, then obtain the task generating device
At least one waiting task generated.
In the embodiment of the present invention, task execution device passes through the operating status for detecting each waiting task, to operation shape
State is that the waiting task of untreated state is handled, and can break down to avoid some task execution device, lead to task
Cannot be processed, the problem of reducing the efficiency of task processing, waiting task can also be avoided to repeat processed, and then can mentioned
The efficiency of high disposal task.
It should be appreciated that in embodiments of the present invention, alleged processor 601 can be central processing unit (Central
Processing Unit, CPU), which can also be other general processors, digital signal processor (Digital
Signal Processor, DSP), specific integrated circuit (Application Specific Integrated Circuit,
ASIC), ready-made programmable gate array (Field-Programmable Gate Array, FPGA) or other programmable logic
Device, discrete gate or transistor logic, discrete hardware components etc..General processor can be microprocessor or this at
Reason device is also possible to any conventional processor etc..
Input equipment 602 may include that Trackpad, fingerprint adopt sensor (for acquiring the finger print information and fingerprint of user
Directional information), microphone etc., output equipment 603 may include display (LCD etc.), loudspeaker etc..
The memory 604 may include read-only memory and random access memory, and to processor 601 provide instruction and
Data.The a part of of memory 604 can also include nonvolatile RAM.For example, memory 604 can also be deposited
Store up the information of device type.
In the specific implementation, processor 601 described in the embodiment of the present invention, input equipment 602, output equipment 603 can
Implementation described in the first embodiment of the method for data processing provided in an embodiment of the present invention is executed, this hair also can be performed
The implementation of task execution device described in bright embodiment, details are not described herein.
Referring to Fig. 7, be another embodiment of the present invention provides a kind of task generating device schematic block diagram.Sheet as shown in the figure
Task generating device in embodiment may include: one or more processors 701；One or more input equipments 702, one
Or multiple output equipments 703 and memory 704.Above-mentioned processor 701, input equipment 702, output equipment 703 and memory 704
It is connected by bus 705.For memory 702 for storing computer program, the computer program includes program instruction, processor
701 for executing the program instruction of the storage of memory 702.Wherein, processor 701 is configured for that described program instruction is called to hold
Row following steps:
Generate at least one waiting task；
At least one described waiting task is sent to each task execution that task execution device set is included to set
It is standby.
Optionally, processor 701 is configured for calling described program instruction that following steps can also be performed:
By at least one waiting task generated again is sent to each task after prefixed time interval
Execute equipment.
Optionally, processor 701 is configured for calling described program instruction that following steps can also be performed:
According to the generation time of each waiting task at least one described waiting task obtain it is each it is described to
The priority of processing task；Or each waiting task is obtained according to the processing grade of each waiting task
Priority；
The priority of at least one waiting task is sent respectively to each task execution device.
Optionally, processor 701 is configured for calling described program instruction that following steps can also be performed:
By the storage of at least one described waiting task into the buffer area of the task generating device；
It is described at least one described waiting task is sent to each task that task execution device set is included to hold
Row equipment, comprising:
At least one described waiting task is obtained from the buffer area；
At least one waiting task that will acquire is sent to each task execution device.
It should be appreciated that in embodiments of the present invention, alleged processor 701 can be central processing unit (Central
Processing Unit, CPU), which can also be other general processors, digital signal processor (Digital
Signal Processor, DSP), specific integrated circuit (Application Specific Integrated Circuit,
ASIC), ready-made programmable gate array (Field-Programmable Gate Array, FPGA) or other programmable logic
Device, discrete gate or transistor logic, discrete hardware components etc..General processor can be microprocessor or this at
Reason device is also possible to any conventional processor etc..
Input equipment 702 may include that Trackpad, fingerprint adopt sensor (for acquiring the finger print information and fingerprint of user
Directional information), microphone etc., output equipment 703 may include display (LCD etc.), loudspeaker etc..
The memory 704 may include read-only memory and random access memory, and to processor 701 provide instruction and
Data.The a part of of memory 704 can also include nonvolatile RAM.For example, memory 704 can also be deposited
Store up the information of device type.
In the specific implementation, processor 701 described in the embodiment of the present invention, input equipment 702, output equipment 703 can
Implementation described in the second embodiment of the method for data processing provided in an embodiment of the present invention is executed, this also can be performed
The implementation of task generating device described in inventive embodiments, details are not described herein.
In the embodiment of the present invention, at least one waiting task is can be generated in task execution device, and can be by this at least
One waiting task is sent to each task execution device, so that each task execution device can handle this, at least one is waited for
Processing task.Task execution device can store at least one waiting task to the buffer area of the task execution device,
The efficiency for obtaining the waiting task can be improved.
A kind of computer readable storage medium, the computer-readable storage medium are provided in another embodiment of the invention
Matter is stored with computer program, and the computer program includes program instruction, realization when described program instruction is executed by processor
Above-mentioned data processing method.
The computer readable storage medium can be the internal storage unit of terminal described in aforementioned any embodiment, example
Such as the hard disk or memory of terminal.The computer readable storage medium is also possible to the External memory equipment of the terminal, such as
The plug-in type hard disk being equipped in the terminal, intelligent memory card (Smart Media Card, SMC), secure digital (Secure
Digital, SD) card, flash card (Flash Card) etc..Further, the computer readable storage medium can also be wrapped both
The internal storage unit for including the terminal also includes External memory equipment.The computer readable storage medium is described for storing
Other programs and data needed for computer program and the terminal.The computer readable storage medium can be also used for temporarily
When store the data that has exported or will export.
Those of ordinary skill in the art may be aware that list described in conjunction with the examples disclosed in the embodiments of the present disclosure
Member and algorithm steps, can be realized with electronic hardware, computer software, or a combination of the two, in order to clearly demonstrate hardware
With the interchangeability of software, each exemplary composition and step are generally described according to function in the above description.This
A little functions are implemented in hardware or software actually, the specific application and design constraint depending on technical solution.Specially
Industry technical staff can use different methods to achieve the described function each specific application, but this realization is not
It is considered as beyond the scope of this invention.
The above description is merely a specific embodiment, but scope of protection of the present invention is not limited thereto, any
Those familiar with the art in the technical scope disclosed by the present invention, can readily occur in various equivalent modifications or replace
It changes, these modifications or substitutions should be covered by the protection scope of the present invention.Therefore, protection scope of the present invention should be with right
It is required that protection scope subject to.
Claims (10)
1. a kind of data processing method is applied to task execution device, execution cluster tool belonging to the task execution device
Equipment is executed including multiple tasks characterized by comprising
At least one waiting task that acquisition task generating device generates；
Detect the operating status of any waiting task at least one described waiting task；
If the operating status for detecting target waiting task is untreated state, by the operation of the target waiting task
State is updated to execution state, and handles the target waiting task, the target waiting task be it is described extremely
Any waiting task in a few waiting task.
2. the method according to claim 1, wherein the method also includes:
Obtain the priority of at least one waiting task；
The operating status of any waiting task at least one waiting task described in the detection, comprising:
According to the priority of at least one waiting task, detect respectively at least one described waiting task it is each to
The operating status of processing task.
3. method according to claim 1 or 2, which is characterized in that the operation shape by the target waiting task
State is updated to execution state, and after handling the target waiting task, further includes:
If detecting, the target waiting task is had been dealt with into, by the operating status of the target waiting task
It is updated to processed state.
4. according to the method described in claim 3, it is characterized by further comprising:
If detecting, the operating status of all waiting tasks at least one described waiting task is processed state, and
Prefixed time interval is begun to pass through from least one described waiting task is obtained, then obtains what the task generating device generated
At least one waiting task.
5. a kind of data processing method is applied to task generating device characterized by comprising
Generate at least one waiting task；
At least one described waiting task is sent to each task execution device that task execution device set is included.
6. according to the method described in claim 5, it is characterized in that, described be sent at least one described waiting task is appointed
Business executes after each task execution device that cluster tool is included, further includes:
By at least one waiting task generated again is sent to each task execution after prefixed time interval
Equipment.
7. method according to claim 5 or 6, which is characterized in that further include:
It is obtained according to the generation time of each waiting task at least one described waiting task each described to be processed
The priority of task；Or the preferential of each waiting task is obtained according to the processing grade of each waiting task
Grade；
The priority of at least one waiting task is sent respectively to each task execution device.
8. according to the method described in claim 5, it is characterized by further comprising:
By the storage of at least one described waiting task into the buffer area of the task generating device；
It is described at least one described waiting task is sent to each task execution that task execution device set is included to set
It is standby, comprising:
At least one described waiting task is obtained from the buffer area；
At least one waiting task that will acquire is sent to each task execution device.
9. a kind of task execution device, which is characterized in that including for executing as described in claim 1-4 any claim
The unit of method.
10. a kind of task generating device, which is characterized in that including for executing as described in claim 5-8 any claim
Method unit.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710844524.2A CN109508228A (en) | 2017-09-15 | 2017-09-15 | A kind of data processing method, task execution device and task generating device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710844524.2A CN109508228A (en) | 2017-09-15 | 2017-09-15 | A kind of data processing method, task execution device and task generating device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109508228A true CN109508228A (en) | 2019-03-22 |
Family
ID=65745224
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710844524.2A Pending CN109508228A (en) | 2017-09-15 | 2017-09-15 | A kind of data processing method, task execution device and task generating device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109508228A (en) |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102279730A (en) * | 2010-06-10 | 2011-12-14 | 阿里巴巴集团控股有限公司 | Parallel data processing method, device and system |
| CN104407848A (en) * | 2014-10-29 | 2015-03-11 | 中国建设银行股份有限公司 | Data processing method and device |
| CN104750549A (en) * | 2015-04-13 | 2015-07-01 | 飞狐信息技术（天津）有限公司 | Computational task processing device, method and system |
| CN105760234A (en) * | 2016-03-17 | 2016-07-13 | 联动优势科技有限公司 | Thread pool management method and device |
| CN105991737A (en) * | 2015-02-26 | 2016-10-05 | 阿里巴巴集团控股有限公司 | Distributed task scheduling method and system |
| CN107066519A (en) * | 2017-02-13 | 2017-08-18 | 阿里巴巴集团控股有限公司 | A kind of task detection method and device |
-
2017
- 2017-09-15 CN CN201710844524.2A patent/CN109508228A/en active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102279730A (en) * | 2010-06-10 | 2011-12-14 | 阿里巴巴集团控股有限公司 | Parallel data processing method, device and system |
| CN104407848A (en) * | 2014-10-29 | 2015-03-11 | 中国建设银行股份有限公司 | Data processing method and device |
| CN105991737A (en) * | 2015-02-26 | 2016-10-05 | 阿里巴巴集团控股有限公司 | Distributed task scheduling method and system |
| CN104750549A (en) * | 2015-04-13 | 2015-07-01 | 飞狐信息技术（天津）有限公司 | Computational task processing device, method and system |
| CN105760234A (en) * | 2016-03-17 | 2016-07-13 | 联动优势科技有限公司 | Thread pool management method and device |
| CN107066519A (en) * | 2017-02-13 | 2017-08-18 | 阿里巴巴集团控股有限公司 | A kind of task detection method and device |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP6571277B2 (en) | Method and apparatus for loading terminal application | |
| CN105516086B (en) | Method for processing business and device | |
| CN110362401A (en) | Data run the member host in batch method, apparatus, storage medium and cluster | |
| CN105550051A (en) | Asynchronous processing method and device of business request | |
| CN110716848A (en) | Data collection method and device, electronic equipment and storage medium | |
| CN106569878A (en) | Distributed timing task management method and system | |
| CN106815080A (en) | Distributed diagram data treating method and apparatus | |
| JP6966432B2 (en) | Cloud file processing method and equipment | |
| CN107948242A (en) | More service number template message sending methods and system | |
| CN107391283A (en) | A kind of message treatment method and device | |
| CN109788251A (en) | Method for processing video frequency, device and storage medium | |
| CN107493312A (en) | A kind of service calling method and device | |
| CN109032767A (en) | Transaction processing system, method, apparatus and the storage medium of asynchronous multi-process | |
| CN109508228A (en) | A kind of data processing method, task execution device and task generating device | |
| CN106982268B (en) | Information processing method and server | |
| CN108881493A (en) | A kind of Task Progress information-pushing method, device and equipment | |
| CN113961330A (en) | Distributed timing task execution method, device, equipment and computer readable medium | |
| WO2014180396A1 (en) | Code coverage rate processing method and device | |
| CN109995863B (en) | Dynamic resource downloading method and device, electronic equipment and storage medium | |
| CN112988339A (en) | Data management method and device | |
| CN105429733B (en) | A kind of message scheduling sending method and device | |
| CN115408172A (en) | Inter-process communication method, device, equipment and medium | |
| CN110912958A (en) | HTTP connection processing method, device, equipment and medium | |
| CN109101260B (en) | Method, device and computer-readable storage medium for upgrading node software | |
| JP2019041247A (en) | Information processing apparatus, information processing method, and information processing program |
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 | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20190322 |