CN104731663B - Task processing method and system - Google Patents
Task processing method and system Download PDFInfo
- Publication number
- CN104731663B CN104731663B CN201510150111.5A CN201510150111A CN104731663B CN 104731663 B CN104731663 B CN 104731663B CN 201510150111 A CN201510150111 A CN 201510150111A CN 104731663 B CN104731663 B CN 104731663B
- Authority
- CN
- China
- Prior art keywords
- task
- subtask
- node
- processing
- message
- 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
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
- Multi Processors (AREA)
Abstract
Task processing method provided in an embodiment of the present invention and system, waiting task can be disassembled as multiple subtasks, and distribute to task and handle node, whether task handles node and determines the quantity of its currently processed subtask not less than default amount threshold after subtask is received, if, to then message feedback be handled to task allocation node to the refusal of the subtask, after task allocation node receives refusal processing message, which is assigned to the task processing node not fed back to the refusal processing message of the subtask.So, when the subtask for distributing to a certain task processing node is more, task processing node will be refused to handle the subtask of subsequent allocations, and then other tasks processing node is distributed in the subtask that task allocation node is refused, realize the equilibrium of task processing node subtask quantity, both avoided since subtask excessively causes the task processing node speed of service to reduce, and turn avoid and cause the wasting of resources since subtask is very few.
Description
Technical field
The present invention relates to task processing technology field, more particularly to task processing method and system.
Background technology
With the development of science and technology, the disposal ability of electronic equipment is higher and higher, correspondingly, electronic equipment to be handled
Task also become increasingly complex.By the way that a complicated task is split as multiple subtasks, and subtask is assigned to multiple
Handled on task processing node, the processing speed of task can be improved.
Electronic equipment receives the detailed process after task every time：
Complicated task is split as multiple subtasks first；
Then each subtask is assigned randomly on multiple tasks processing node and is handled.
Inventor, which studies, to be found：When electronic equipment receive task it is more when, it is necessary to frequently carry out task split and
Distribution.Since the subtask of distribution is more, it is more a part of task processing node subtask to be treated easily occur,
And the situation that another part task processing node subtask to be treated is less.When subtask to be treated is more,
The load for causing task processing node is higher, and then the speed of service of task processing node is influenced, or even cause task to handle
The machine of delaying of node.And when subtask to be treated is less, task processing node processing will be in idle shape behind complete subtask
State, wastes resource.
The content of the invention
The purpose of the embodiment of the present invention is to provide a kind of task processing method and system, is excessively made to avoid sub-tasks
Into the task processing node speed of service reduce and the wasting of resources caused by sub-tasks are very few.
To reach above-mentioned purpose, the embodiment of the invention discloses a kind of task processing method, applied to task allocation node,
The task allocation node is connected with multiple tasks processing node, the described method includes：
Waiting task is obtained, the waiting task is split as multiple subtasks；
To each subtask, it is handled as follows：
The subtask is assigned to a task processing node；
Receive the notification message that the task processing node of the subtask is assigned for subtask feedback；
If the notification message is to handle message to the refusal of the subtask, which is assigned to and was not fed back
Node is handled to the task of the refusal processing message of the subtask, continues to execute receiving and the subtask being assigned for the task
The step of handling the notification message that node is fed back for the subtask, wherein, the refusal processing message is task processing node
The task allocation node is fed back to when the quantity for determining its currently processed subtask is not less than default amount threshold.
Optionally, further include：
In the case where the notification message handles message for the agreement to the subtask, the task processing node is obtained
The processing progress information of transmission；
After the processing notice extremely that task processing node is sent is received, according to sending what the processing notified extremely
Task handles the processing progress information of node, and the untreated partly or entirely subtask of task processing node is assigned to remove and is somebody's turn to do
Other tasks processing node beyond task processing node is handled, wherein, the abnormal notice of processing is task processing section
What point was sent when the speed for determining its processing subtask is less than pre-set velocity threshold value.
Optionally, the task allocation node is also connected with task interface module, and the multiple task processing node is located at
In multiple servers, each task processing node is only located in a server, the acquisition waiting task, including：Obtain
The waiting task that the task interface module receives.
Optionally, it is described that the waiting task is split as multiple subtasks, including：
According to the granularity threshold value of default subtask, rising for each subtask in the waiting task is calculated
Beginning position and each subtask final position；
To each subtask：By the task identification of the waiting task, the initial position of the subtask, the subtask
Final position and waiting task parameter information be encapsulated as the subtask object of the subtask；
It is described that the subtask is assigned to a task processing node, including：By the subtask object of the subtask
It is assigned to a task processing node.
A kind of task processing method, node, the task processing node and task allocation node phase are handled applied to task
Connection, the described method includes：
The subtask of the task allocation node distribution is obtained, wherein, which is the task allocation node right
What waiting task obtained after being split；
The quantity of the currently processed subtask of task processing node is determined whether not less than default amount threshold, if
It is then to be fed back to the task allocation node and message is handled to the refusal of the subtask, so that the task allocation node should
Subtask is assigned to not feed back handles node to the task of the refusal processing message of the subtask.
Optionally, further include：
When the quantity for determining the currently processed subtask of task processing node is less than default amount threshold, to described
Agreement processing message of distribution node of the being engaged in feedback to the subtask；
Obtain the processing progress information of task processing node processing task；
The processing progress information is sent to the task allocation node, determines task processing node processing subtask
Speed whether be less than pre-set velocity threshold value, if it is, the abnormal notice of processing is sent to the task allocation node, so that institute
Task allocation node is stated after the abnormal notice of the processing is received, the processing progress that node transmission is handled according to the task is believed
The untreated partly or entirely subtask of task processing node, is assigned to other in addition to the task handles node by breath
Business processing node is handled.
Optionally, the task allocation node is also connected with task interface module, and the multiple task processing node is located at
In multiple servers, each task processing node is only located in a server.
A kind of task processing system, applied to task allocation node, the task allocation node is saved with multiple tasks processing
Point is connected, the system comprises：Task split cells, first allocation unit, notification receiving unit and allocation unit again,
The task split cells, for obtaining waiting task, multiple subtasks are split as by the waiting task；
The allocation unit first, for each subtask, which being assigned to a task and handles node；
The notification receiving unit, the task processing node that the subtask is assigned for receiving are anti-for the subtask
The notification message of feedback, if the notification message is to handle the refusal of the subtask message, distribution is single again described in triggering
Member；Wherein, the refusal processing message is that task processing node is determining the quantity of its currently processed subtask not less than pre-
If the notification receiving unit of the task allocation node is fed back to during amount threshold；
The allocation unit again, message is handled for being assigned to the subtask not feed back to the refusal of the subtask
Task processing node, trigger the notification receiving unit.
Optionally, further include：Progress obtaining unit and task buanch unit,
The progress obtaining unit, for being the situation for agreeing to processing message to the subtask in the notification message
Under, obtain the processing progress information that the task processing node is sent；
The task buanch unit, after being notified extremely in the processing for receiving the task processing node transmission, root
According to the processing progress information for sending the task processing node that the processing notifies extremely, by the untreated part of task processing node
Or other tasks processing node that whole subtasks are assigned in addition to the task handles node is handled, wherein, the place
It is that task processing node is sent when the speed for determining its processing subtask is less than pre-set velocity threshold value to manage abnormal notice.
Optionally, the task allocation node is also connected with task interface module, and the multiple task processing node is located at
In multiple servers, each task processing node is only located in a server, and the task split cells is specifically used for：Obtain
The waiting task that the task interface module receives, multiple subtasks are split as by the waiting task.
Optionally, the task split cells, including：Task obtains subelement, position computation subunit and task encapsulation
Subelement,
The task obtains subelement, for obtaining waiting task；
The position computation subunit, for the granularity threshold value according to default subtask, is calculated and described waits to locate
The initial position of each subtask in reason task and the final position of each subtask；
The task encapsulates subelement, for each subtask：By the task identification of the waiting task, the son
The initial position of task, the final position of the subtask and waiting task parameter information are encapsulated as the subtask pair of the subtask
As；
The allocation unit first, is specifically used for：To each subtask, the subtask object of the subtask is assigned to one
The task handles node.
A kind of task processing system, node, the task processing node and task allocation node phase are handled applied to task
Connection, the system comprises：Subtask obtains module, quantity determining module and message feedback module,
The subtask obtains module, for obtaining the subtask of the task allocation node distribution, wherein, the subtask
The task allocation node obtains after being split to waiting task；
Whether the quantity determining module, the quantity for determining the currently processed subtask of task processing node are not low
In default amount threshold, if it is, triggering the message feedback module；
The message feedback module, for handling message to the refusal of the subtask to task allocation node feedback,
Do not fed back at the task to the refusal processing message of the subtask so that the subtask is assigned to by the task allocation node
Manage node.
Optionally, further include：Acceptance message feedback module, progress obtain module, progress sending module, speed determination module
With notice sending module,
The acceptance message feedback module, for determining that task processing node is currently processed in the quantity determining module
The quantity of subtask when being less than default amount threshold, the agreement processing fed back to the task allocation node to the subtask disappears
Breath；
The progress obtains module, for obtaining the processing progress information of task processing node processing task；
The progress sending module, for the processing progress information to be sent to the task allocation node；
The speed determination module, for determining the speed of task processing node processing subtask whether less than default speed
Threshold value is spent, if it is, triggering the notice sending module；
The notice sending module, for sending the abnormal notice of processing to the task allocation node, so that the task
Distribution node handles the processing progress information of node transmission according to the task, by this after the abnormal notice of the processing is received
The untreated partly or entirely subtask of task processing node is assigned to other tasks processing in addition to the task handles node
Node is handled.
Optionally, the task allocation node is also connected with task interface module, and the multiple task processing node is located at
In multiple servers, each task processing node is only located in a server.
Task processing method provided in an embodiment of the present invention and system, task handles node can be with after subtask is received
The quantity of its currently processed subtask is determined whether not less than default amount threshold, if it is, will refuse the subtask
Processing message feedback absolutely is to task allocation node, after task allocation node receives refusal processing message, by the subtask point
It is fitted on not feed back and node is handled to the task of the refusal processing message of the subtask.In this way, handled when distributing to a certain task
When the subtask of node is more, task processing node will be refused to handle the subtask of subsequent allocations, and then task distribution section
Other tasks processing node is distributed in the subtask that point is refused, it is achieved thereby that task processing node subtask quantity is equal
Weighing apparatus, had both avoided since subtask excessively causes the speed of service of task processing node to reduce, turn avoid due to subtask mistake
The waste of resource is caused less.
Brief description of the drawings
In order to illustrate more clearly about the embodiment of the present invention or technical scheme of the prior art, below will be to embodiment or existing
There is attached drawing needed in technology description to be briefly described, it should be apparent that, drawings in the following description are only this
Some embodiments of invention, for those of ordinary skill in the art, without creative efforts, can be with
Other attached drawings are obtained according to these attached drawings.
Fig. 1 is a kind of flow chart of task processing method provided in an embodiment of the present invention；
Fig. 2 is the flow chart of another task processing method provided in an embodiment of the present invention；
Fig. 3 is the flow chart of another task processing method provided in an embodiment of the present invention；
Fig. 4 is the flow chart of another task processing method provided in an embodiment of the present invention；
Fig. 5 is a kind of structure diagram of task processing system provided in an embodiment of the present invention；
Fig. 6 is the structure diagram of another task processing system provided in an embodiment of the present invention；
Fig. 7 is the structure diagram of another task processing system provided in an embodiment of the present invention；
Fig. 8 is the structure diagram of another task processing system provided in an embodiment of the present invention.
Embodiment
Below in conjunction with the attached drawing in the embodiment of the present invention, the technical solution in the embodiment of the present invention is carried out clear, complete
Site preparation describes, it is clear that described embodiment is only part of the embodiment of the present invention, instead of all the embodiments.It is based on
Embodiment in the present invention, those of ordinary skill in the art are obtained every other without making creative work
Embodiment, belongs to the scope of protection of the invention.
As shown in Figure 1, a kind of task processing method provided in an embodiment of the present invention, described applied to task allocation node
Task allocation node is connected with multiple tasks processing node, and this method can include：
S100, obtain waiting task, and the waiting task is split as multiple subtasks；
Wherein, task allocation node can also be connected with task interface module, and the multiple task processing node is positioned at more
In a server, each task processing node is only located in a server, and S100 obtains waiting task, can include：Obtain
Obtain the waiting task that the task interface module receives.
Specifically, task allocation node, task interface module and task processing node are the composition of task processing system
Part, task processing system can be communicated by task interface module with external equipment.Although in this way, task processing system
Include multiple and different equipment, but due to providing external unified interface, can be to avoid code redundancy and excessively coupling
Close.Certainly, database can also be included in task processing system, with the various data in store tasks processing procedure.
Simultaneously as multiple tasks processing node is located in multiple servers, therefore task allocation node can call respectively
Task processing node processing task in server, it is achieved thereby that distributed deployment.Wherein, task allocation node, task connect
Communication mechanism between mouth mold block and task processing node can use remote procedure call protocol to coordinate distributed application program
Coordination service zookeeper is realized.
Optionally, waiting task of the invention can be that message pushes task, such as iOS overall situation push task, batch visitor
Family end pushes task.Task interface module can also be connected with client device, and collect client device upload be used for push away
The client identification of business is taken, such as：Client on the operating system iOS of apple equipment needs to upload apple Push Service
Token information.Client on Android system need to upload the user id that its Push Service used is distributed.Task processing system
The message that can be initiated by task interface module reception system called side pushes task.Task interface module passes to task
The mode of task allocation node can have a variety of, such as directly transmit or pass through database indirect transfer.
Specifically, the process that the waiting task is split as multiple subtasks by S100 can include：
According to the granularity threshold value of default subtask, rising for each subtask in the waiting task is calculated
Beginning position and each subtask final position；
To each subtask：By the task identification of the waiting task, the initial position of the subtask, the subtask
Final position and waiting task parameter information be encapsulated as the subtask object of the subtask.
Wherein, waiting task parameter information handles node required relevant non-place in task processes for task
The parameter information of scope is managed, these parameters, when waiting task pushes task for message, are waited to locate both from waiting task
Reason task parameters information can include：Message displaying method, message redirect mode etc..
Wherein, task splits node after fractionation obtains multiple subtasks, can in the database edit and update each son
The state of task, as it is unallocated, processing in, processed armed state, can also edit in the database and update processing respectively
The information of the task processing node of subtask, such as the information of the task processing node of the currently processed subtask.Certainly, task
The information of each task processing node in task processing system can be obtained by splitting node, as address information, currently processed son are appointed
The number information of business, number information of task processing node etc..After the information of task processing node changes, task is split
The information that node obtains also accordingly updates.
To each subtask, the processing of following steps S200 to S400 is carried out：
The subtask, is assigned to a task processing node by S200；
Wherein, S200 can include：The subtask object of the subtask is assigned to a task processing node.
Specifically, it can be chosen by poll, handle in node and select from multiple tasks according to selection modes such as weight selections
Take the task processing node for distributing the subtask.
After subtask object to be assigned to task processing node, task processing node can be according in the object of subtask
Information subtask is handled.
It is specifically, corresponding from data base querying according to the subtask type in the object of subtask and the range of transmission of subtask
Facility information, and select corresponding Push Service, such as the client device selection Apple Inc. Push Service of iOS system,
Android device selects Android Push Service.Task handle node during message push task is handled can periodically to
Task allocation node feedback message pushes progress, after the subtask of distribution has been handled, sends and has handled to task allocation node
Into notice.
The task processing node that the subtask is assigned in S300, reception is directed to the notification message that the subtask is fed back；
If S400, the notification message are to handle message to the refusal of the subtask, which is assigned to not
Fed back and node is handled to the task of the refusal processing message of the subtask, and continued to execute step S300, wherein, at the refusal
Reason message is that task processing node is fed back to when the quantity for determining its currently processed subtask is not less than default amount threshold
The task allocation node.
It is understood that after subtask is assigned to task processing node by task allocation node, if task is handled
The quantity of the currently processed subtask of node is not less than default amount threshold, and task processing node will be sent out to task allocation node
Send refusal processing message.After task allocation node receives refusal processing message, the son for distributing to task processing node is appointed
Business is distributed to not feed back handles node to the task of the refusal processing message of the subtask.In this way, on the one hand it ensure that task
The quantity for handling the currently processed subtask of node will not be too many, on the other hand by the sub-distribution again of subtask, also ensure that
The subtask can be performed in time.
A kind of task processing method provided in an embodiment of the present invention, realizes the subtask quantity of task processing node processing
Equilibrium, both avoided due to subtask excessively cause task processing node the speed of service reduce, turn avoid due to son appoint
It is engaged in the very few waste for causing resource.
As shown in Fig. 2, another kind task processing method provided in an embodiment of the present invention, can also include：
S500, the notification message for the subtask agreement handle message in the case of, obtain at the task
Manage the processing progress information that node is sent；
Wherein, processing progress information can be processed complete subtask quantity and subtask mark, untreated finish
Subtask quantity and subtask mark or the mark of the current subtask just handled.
S600, after the processing notice extremely that task processing node is sent is received, it is abnormal according to the processing is sent
The processing progress information of the task processing node of notice, by the untreated partly or entirely subtask distribution of task processing node
Other tasks processing node in addition to node is handled except the task is handled, wherein, the abnormal notice of processing is task
What processing node was sent when the speed for determining its processing subtask is less than pre-set velocity threshold value.
Specifically, after the untreated subtask of task processing node that transmission processing notifies extremely is redistributed, may be used also
The son that the task processing node that the subtask distribution condition behind subtask is updated the data in storehouse is responsible for processing is redistributed with basis
The record of task.
It is understood that since task processing node is numerous and is distributed on a different server, when some clothes
When the machine of delaying or network interruption or task processing node operation error occurs in business device, it will cause what is handled on corresponding task processing node
Whole subtask pauses are performed or can not performed, and then cause whole waiting task to perform slowly or even perform failure.
Embodiment illustrated in fig. 2 can obtain task processing node when the speed for handling subtask is less than pre-set velocity threshold value
The processing of transmission notifies extremely, by the untreated partly or entirely subtask distribution of task processing node after the notice is obtained
Other tasks processing node in addition to node is handled except the task is handled.In this way, ensure that going wrong for task
Processing node is responsible for the timely execution of the subtask of processing, and then also ensure that the timely execution of waiting task.
When causing the speed of task processing node processing subtask slower when the quantity of the subtask due to processing is more,
By the task processing node be responsible for processing part subtask distribute to other tasks processing node can improve its processing son appoint
The speed of business.
As shown in figure 3, the embodiment of the present invention additionally provides another task processing method, node is handled applied to task,
The task processing node is connected with task allocation node, and this method can include：
S001, the subtask for obtaining the task allocation node distribution, wherein, which is the task allocation node
Obtained after being split to waiting task；
Wherein, task allocation node can also be connected with task interface module, and the multiple task processing node is positioned at more
In a server, each task processing node is only located in a server.
Specifically, task allocation node, task interface module and task processing node are the composition of task processing system
Part, task processing system can be communicated by task interface module with external equipment.Although in this way, task processing system
Include multiple and different equipment, but due to providing external unified interface, can be to avoid code redundancy and excessively coupling
Close.Certainly, database can also be included in task processing system, with the various data in store tasks processing procedure.
Simultaneously as multiple tasks processing node is located in multiple servers, therefore task allocation node can call respectively
Task processing node processing task in server, it is achieved thereby that distributed deployment.Wherein, task allocation node, task connect
Communication mechanism between mouth mold block and task processing node can use remote procedure call protocol to coordinate distributed application program
Coordination service zookeeper is realized.
Optionally, waiting task of the invention pushes task for message, such as iOS overall situation push task, batch client
Push task.Task interface module can also be connected with client device, and the push that is used for for collecting client device upload takes
The client identification of business, such as：Client on the operating system iOS of apple equipment needs to upload apple Push Service
Token information.Client on Android system need to upload the user id that its Push Service used is distributed.Task processing system
The message that can be initiated by task interface module reception system called side pushes task.Task interface module passes to task
The mode of task allocation node can have a variety of, such as directly transmit or pass through database indirect transfer.
S002, determine whether the quantity of the currently processed subtask of task processing node is not less than default amount threshold,
If it is, perform S003；
If specifically, the quantity that the task handles the currently processed subtask of node is less than default amount threshold, appoint
Business processing node can be handled the subtask.Specifically, when waiting task pushes task for message, at task
Reason node can be set accordingly according to the subtask type in the object of subtask and the range of transmission of subtask from data base querying
Standby information, and corresponding Push Service is selected, for example (,) the client device selection Apple Inc. Push Service of iOS system, Android
Equipment selects Android Push Service.Task processing node can be periodically to task during message push task is handled
Distribution node feedback message pushes progress, after the subtask of distribution has been handled, sends processing to task allocation node and completes to lead to
Know.
S003, the refusal processing message to task allocation node feedback to the subtask, so that the task is distributed
The subtask is assigned to not feed back by node handles node to the task of the refusal processing message of the subtask.
It is understood that after subtask is assigned to task processing node by task allocation node, if task is handled
The quantity of the currently processed subtask of node is not less than default amount threshold, and task processing node will be sent out to task allocation node
Send refusal processing message.After task allocation node receives refusal processing message, the son for distributing to task processing node is appointed
Business is distributed to not feed back handles node to the task of the refusal processing message of the subtask.In this way, on the one hand it ensure that task
The quantity for handling the currently processed subtask of node will not be too many, on the other hand by the sub-distribution again of subtask, also ensure that
The subtask can be performed in time.
A kind of task processing method provided in an embodiment of the present invention, realizes the subtask quantity of task processing node processing
Equilibrium, both avoided due to subtask excessively cause task processing node the speed of service reduce, turn avoid due to son appoint
It is engaged in the very few waste for causing resource.
On the basis of embodiment illustrated in fig. 3, as shown in figure 4, another kind task processing side provided in an embodiment of the present invention
Method, can also include：
When S004, the quantity in the currently processed subtask of definite task processing node are less than default amount threshold, to
Agreement processing message of the task allocation node feedback to the subtask；
S005, the processing progress information for obtaining task processing node processing task；
Wherein, processing progress information can be processed complete subtask quantity and subtask mark, untreated finish
Subtask quantity and subtask mark or the mark of the current subtask just handled.
S006, by the processing progress information be sent to the task allocation node, determines that the task handles node processing
Whether the speed of subtask is less than pre-set velocity threshold value, if it is, the abnormal notice of processing is sent to the task allocation node,
So that the task allocation node is after the abnormal notice of the processing is received, according to the task handle processing that node sends into
Information is spent, the untreated partly or entirely subtask of task processing node is assigned to its in addition to the task handles node
He is handled task processing node.
Specifically, task allocation node handles the untreated son of node redistributing transmission processing the notifying extremely of the task
After task, it can also be born according to redistributing the subtask distribution condition behind subtask and updating the data the task processing node in storehouse
Blame the record of the subtask of processing.
It is understood that since task processing node is numerous and is distributed on a different server, when some clothes
When the machine of delaying or network interruption or task processing node operation error occurs in business device, it will cause what is handled on corresponding task processing node
Whole subtask pauses are performed or can not performed, and then cause whole waiting task to perform slowly or even perform failure.
Embodiment illustrated in fig. 4 can be sent out when the speed for handling subtask is less than pre-set velocity threshold value to task allocation node
Send processing abnormal notice, task allocation node is assigned to the untreated partly or entirely subtask of task processing node and remove
Other tasks processing node beyond task processing node is handled.In this way, ensure that the task processing to go wrong
Node is responsible for the timely execution of the subtask of processing, and then also ensure that the timely execution of waiting task.
Corresponding with embodiment of the method shown in Fig. 1, present invention also offers a kind of task processing system.
As shown in figure 5, a kind of task processing system provided in an embodiment of the present invention, described applied to task allocation node
Task allocation node is connected with multiple tasks processing node, which can include：Task split cells 100, distribute first
Unit 200, notification receiving unit 300 and allocation unit 400 again,
The task split cells 100, for obtaining waiting task, is split as more height by the waiting task and appoints
Business；
Wherein, the task allocation node can also be connected with task interface module, the multiple task processing node position
In multiple servers, each task processing node is only located in a server, and the task split cells 100 can be specific
For：The waiting task that the task interface module receives is obtained, the waiting task is split as multiple subtasks.
Specifically, task allocation node, task interface module and task processing node are the composition of task processing system
Part, task processing system can be communicated by task interface module with external equipment.Although in this way, task processing system
Include multiple and different equipment, but due to providing external unified interface, can be to avoid code redundancy and excessively coupling
Close.Certainly, database can also be included in task processing system, with the various data in store tasks processing procedure.
Wherein, the task split cells 100, can include：Task obtains subelement, position computation subunit and task
Encapsulate subelement,
The task obtains subelement, for obtaining waiting task；
The position computation subunit, for the granularity threshold value according to default subtask, is calculated and described waits to locate
The initial position of each subtask in reason task and the final position of each subtask；
The task encapsulates subelement, for each subtask：By the task identification of the waiting task, the son
The initial position of task, the final position of the subtask and waiting task parameter information are encapsulated as the subtask pair of the subtask
As.
Wherein, task splits node after fractionation obtains multiple subtasks, can in the database edit and update each son
The state of task, as it is unallocated, processing in, processed armed state, can also edit in the database and update processing respectively
The information of the task processing node of subtask, such as the information of the task processing node of the currently processed subtask.Certainly, task
The information of each task processing node in task processing system can be obtained by splitting node, as address information, currently processed son are appointed
The number information of business, number information of task processing node etc..After the information of task processing node changes, task is split
The information that node obtains also accordingly updates.
Allocation unit 200 first, for each subtask, which to be assigned to a task processing section
Point；
When task split cells 100 includes task acquisition subelement, position computation subunit and task encapsulation subelement,
Allocation unit 200 first, can be specifically used for：To each subtask, the subtask object of the subtask is assigned to one
The task handles node.
After subtask object to be assigned to task processing node, task processing node can be according in the object of subtask
Information subtask is handled.
It is specifically, corresponding from data base querying according to the subtask type in the object of subtask and the range of transmission of subtask
Facility information, and select corresponding Push Service, such as the client device selection Apple Inc. Push Service of iOS system,
Android device selects Android Push Service.Task handle node during message push task is handled can periodically to
Task allocation node feedback message pushes progress, after the subtask of distribution has been handled, sends and has handled to task allocation node
Into notice.
The notification receiving unit 300, the task processing node that the subtask is assigned for receiving are appointed for the son
The notification message for feedback of being engaged in, if the notification message is to handle message to the refusal of the subtask, divides again described in triggering
With unit 400；Wherein, the refusal processing message is that task processing node is determining the quantity of its currently processed subtask not
The notification receiving unit 300 of the task allocation node is fed back to during less than default amount threshold；
Allocation unit 400 again, for the subtask to be assigned to the refusal processing do not fed back to the subtask
The task processing node of message, triggers the notification receiving unit 300.
It is understood that after subtask is assigned to task processing node by task allocation node, if task is handled
The quantity of the currently processed subtask of node is not less than default amount threshold, and task processing node will be sent out to task allocation node
Send refusal processing message.After task allocation node receives refusal processing message, the son for distributing to task processing node is appointed
Business is distributed to not feed back handles node to the task of the refusal processing message of the subtask.In this way, on the one hand it ensure that task
The quantity for handling the currently processed subtask of node will not be too many, on the other hand by the sub-distribution again of subtask, also ensure that
The subtask can be performed in time.
A kind of task processing system provided in an embodiment of the present invention, realizes the subtask quantity of task processing node processing
Equilibrium, both avoided due to subtask excessively cause task processing node the speed of service reduce, turn avoid due to son appoint
It is engaged in the very few waste for causing resource.
On the basis of embodiment illustrated in fig. 5, as shown in fig. 6, another kind task processing system provided in an embodiment of the present invention,
It can also include：Progress obtaining unit 500 and task buanch unit 600,
The progress obtaining unit 500, for when the notification message handles message for the agreement to the subtask, obtaining
Obtain the processing progress information that the task processing node is sent；
Wherein, processing progress information can be processed complete subtask quantity and subtask mark, untreated finish
Subtask quantity and subtask mark or the mark of the current subtask just handled.
The task buanch unit 600, after being notified extremely in the processing for receiving the task processing node transmission,
According to the processing progress information for sending the task processing node that the processing notifies extremely, by the untreated portion of task processing node
Point or other tasks processing node for being assigned in addition to the task handles node of whole subtask handled, wherein, it is described
It is that task processing node is sent when the speed for determining its processing subtask is less than pre-set velocity threshold value to handle abnormal notice.
Specifically, after the untreated subtask of task processing node that transmission processing notifies extremely is redistributed, may be used also
The son that the task processing node that the subtask distribution condition behind subtask is updated the data in storehouse is responsible for processing is redistributed with basis
The record of task.
It is understood that since task processing node is numerous and is distributed on a different server, when some clothes
When the machine of delaying or network interruption or task processing node operation error occurs in business device, it will cause what is handled on corresponding task processing node
Whole subtask pauses are performed or can not performed, and then cause whole waiting task to perform slowly or even perform failure.
Embodiment illustrated in fig. 6 can obtain task processing node when the speed for handling subtask is less than pre-set velocity threshold value
The processing of transmission notifies extremely, by the untreated partly or entirely subtask distribution of task processing node after the notice is obtained
Other tasks processing node in addition to node is handled except the task is handled.In this way, ensure that going wrong for task
Processing node is responsible for the timely execution of the subtask of processing, and then also ensure that the timely execution of waiting task.
Corresponding with embodiment of the method shown in Fig. 3, present invention also offers another task processing system.
As shown in fig. 7, another kind task processing system provided in an embodiment of the present invention, node, institute are handled applied to task
State task processing node with task allocation node to be connected, which can include：Subtask obtains module 001, quantity determines
Module 002 and message feedback module 003,
The subtask obtains module 001, for obtaining the subtask of the task allocation node distribution, wherein, the son
The task task allocation node obtains after being split to waiting task；
Wherein, task allocation node can also be connected with task interface module, and the multiple task processing node is positioned at more
In a server, each task processing node is only located in a server.
Specifically, task allocation node, task interface module and task processing node are the composition of task processing system
Part, task processing system can be communicated by task interface module with external equipment.Although in this way, task processing system
Include multiple and different equipment, but due to providing external unified interface, can be to avoid code redundancy and excessively coupling
Close.Certainly, database can also be included in task processing system, with the various data in store tasks processing procedure.
The quantity determining module 002, for determine the currently processed subtask of task processing node quantity whether
Not less than default amount threshold, if it is, triggering the message feedback module 003；
If specifically, the quantity that the task handles the currently processed subtask of node is less than default amount threshold, appoint
Business processing node can be handled the subtask.Specifically, when waiting task pushes task for message, at task
Reason node can be set accordingly according to the subtask type in the object of subtask and the range of transmission of subtask from data base querying
Standby information, and corresponding Push Service is selected, for example (,) the client device selection Apple Inc. Push Service of iOS system, Android
Equipment selects Android Push Service.Task processing node can be periodically to task during message push task is handled
Distribution node feedback message pushes progress, after the subtask of distribution has been handled, sends processing to task allocation node and completes to lead to
Know.
The message feedback module 003, disappears for the refusal processing to task allocation node feedback to the subtask
Breath, so that the subtask is assigned to not feeding back to the refusal processing message of the subtask for task by the task allocation node
Handle node.
It is understood that after subtask is assigned to task processing node by task allocation node, if task is handled
The quantity of the currently processed subtask of node is not less than default amount threshold, and task processing node will be sent out to task allocation node
Send refusal processing message.After task allocation node receives refusal processing message, the son for distributing to task processing node is appointed
Business is distributed to not feed back handles node to the task of the refusal processing message of the subtask.In this way, on the one hand it ensure that task
The quantity for handling the currently processed subtask of node will not be too many, on the other hand by the sub-distribution again of subtask, also ensure that
The subtask can be performed in time.
A kind of task processing system provided in an embodiment of the present invention, realizes the subtask quantity of task processing node processing
Equilibrium, both avoided due to subtask excessively cause task processing node the speed of service reduce, turn avoid due to son appoint
It is engaged in the very few waste for causing resource.
On the basis of embodiment illustrated in fig. 7, as shown in figure 8, another kind task processing system provided in an embodiment of the present invention,
It can also include：Acceptance message feedback module 004, progress obtain module 005, progress sending module 006, speed determination module
007 and notice sending module 008,
The acceptance message feedback module 004, for determining that task processing node is worked as in the quantity determining module 002
When the quantity of the subtask of pre-treatment is less than default amount threshold, the agreement to the subtask is fed back to the task allocation node
Handle message；
The progress obtains module 005, for obtaining the processing progress information of task processing node processing task；
Wherein, processing progress information can be processed complete subtask quantity and subtask mark, untreated finish
Subtask quantity and subtask mark or the mark of the current subtask just handled.
The progress sending module 006, for the processing progress information to be sent to the task allocation node；
The speed determination module 007, for determining the speed of task processing node processing subtask whether less than pre-
If threshold speed, if it is, the triggering notice sending module 008；
The notice sending module 008, for sending the abnormal notice of processing to the task allocation node, so that described
Distribution node of being engaged in handles the processing progress information of node transmission according to the task after the abnormal notice of the processing is received, will
The untreated partly or entirely subtask of task processing node is assigned at other tasks in addition to the task handles node
Reason node is handled.
Specifically, task allocation node handles the untreated son of node redistributing transmission processing the notifying extremely of the task
After task, it can also be born according to redistributing the subtask distribution condition behind subtask and updating the data the task processing node in storehouse
Blame the record of the subtask of processing.
It is understood that since task processing node is numerous and is distributed on a different server, when some clothes
When the machine of delaying or network interruption or task processing node operation error occurs in business device, it will cause what is handled on corresponding task processing node
Whole subtask pauses are performed or can not performed, and then cause whole waiting task to perform slowly or even perform failure.
Embodiment illustrated in fig. 8 can be sent out when the speed for handling subtask is less than pre-set velocity threshold value to task allocation node
Send processing abnormal notice, task allocation node is assigned to the untreated partly or entirely subtask of task processing node and remove
Other tasks processing node beyond task processing node is handled.In this way, ensure that the task processing to go wrong
Node is responsible for the timely execution of the subtask of processing, and then also ensure that the timely execution of waiting task.
It should be noted that herein, relational terms such as first and second and the like are used merely to a reality
Body or operation are distinguished with another entity or operation, are deposited without necessarily requiring or implying between these entities or operation
In any this actual relation or order.Moreover, term " comprising ", "comprising" or its any other variant are intended to
Non-exclusive inclusion, so that process, method, article or equipment including a series of elements not only will including those
Element, but also including other elements that are not explicitly listed, or further include as this process, method, article or equipment
Intrinsic key element.In the absence of more restrictions, the key element limited by sentence "including a ...", it is not excluded that
Also there are other identical element in process, method, article or equipment including the key element.
Each embodiment in this specification is described using relevant mode, identical similar portion between each embodiment
Divide mutually referring to what each embodiment stressed is the difference with other embodiment.It is real especially for system
For applying example, since it is substantially similar to embodiment of the method, so description is fairly simple, related part is referring to embodiment of the method
Part explanation.
The foregoing is merely illustrative of the preferred embodiments of the present invention, is not intended to limit the scope of the present invention.It is all
Any modification, equivalent replacement, improvement and so within the spirit and principles in the present invention, are all contained in protection scope of the present invention
It is interior.
Claims (10)
- A kind of 1. task processing method, it is characterised in that applied to task allocation node, the task allocation node with multiple Business processing node is connected, the described method includes：Waiting task is obtained, the waiting task is split as multiple subtasks；Wherein, it is described by the waiting task Multiple subtasks are split as, including：According to the granularity threshold value of default subtask, the start bit of each subtask in the waiting task is calculated Put and the final position of each subtask；To each subtask：By the task identification of the waiting task, the initial position of the subtask, the subtask end Stop bit puts the subtask object that the subtask is encapsulated as with waiting task parameter information；The subtask is assigned to a task processing node, including：The subtask object of the subtask is assigned to one A task processing node；To each subtask, it is handled as follows：The subtask is assigned to a task processing node；Receive the notification message that the task processing node of the subtask is assigned for subtask feedback；If the notification message is to handle message to the refusal of the subtask, which is assigned to and was not fed back to this The task processing node of the refusal processing message of subtask, continues to execute the task processing for receiving and the subtask being assigned The step of notification message that node is fed back for the subtask, wherein, the refusal processing message is that task handles node true The quantity of its fixed currently processed subtask feeds back to the task allocation node when being not less than default amount threshold.
- 2. according to the method described in claim 1, it is characterized in that, further include：In the case where the notification message handles message for the agreement to the subtask, obtain the task processing node and send Processing progress information；After the processing notice extremely that task processing node is sent is received, according to sending the processing and notifying extremely for task The processing progress information of node is handled, the untreated partly or entirely subtask of task processing node is assigned to except the task Other tasks processing node beyond processing node is handled, wherein, the abnormal notice of processing is that task processing node exists Determine that it handles the speed of subtask and is less than what is sent during pre-set velocity threshold value.
- 3. method according to claim 1 or 2, it is characterised in that the task allocation node also with task interface module Connection, the multiple task processing node are located in multiple servers, and each task processing node is only located in a server, The acquisition waiting task, including：Obtain the waiting task that the task interface module receives.
- 4. a kind of task processing method, it is characterised in that handle node, the task processing node and task point applied to task It is connected with node, the described method includes：The subtask of the task allocation node distribution is obtained, wherein, which is treating place for the task allocation node What reason task obtained after being split；The quantity of the currently processed subtask of task processing node is determined whether not less than default amount threshold, if it is, Message is handled to the refusal of the subtask to task allocation node feedback, so that the task allocation node is by the subtask It is assigned to not feed back and node is handled to the task of the refusal processing message of the subtask；The method further includes：When the quantity for determining the currently processed subtask of task processing node is less than default amount threshold, to the task point Agreement with node feeding back to the subtask handles message；Obtain the processing progress information of task processing node processing task；The processing progress information is sent to the task allocation node, determines the speed of task processing node processing subtask Whether degree is less than pre-set velocity threshold value, if it is, the abnormal notice of processing is sent to the task allocation node, so that described Distribution node of being engaged in handles the processing progress information of node transmission according to the task after the abnormal notice of the processing is received, will The untreated partly or entirely subtask of task processing node is assigned at other tasks in addition to the task handles node Reason node is handled.
- 5. according to the method described in claim 4, it is characterized in that, the task allocation node also connects with task interface module Connect, multiple tasks processing node is located in multiple servers, and each task processing node is only located in a server.
- A kind of 6. task processing system, it is characterised in that applied to task allocation node, the task allocation node with multiple Business processing node is connected, the system comprises：Task split cells, first allocation unit, notification receiving unit and divide again With unit,The task split cells, for obtaining waiting task, multiple subtasks are split as by the waiting task；Its In, the task split cells, including：Task obtains subelement, position computation subunit and task encapsulation subelement；The task obtains subelement, for obtaining waiting task；The position computation subunit, for the granularity threshold value according to default subtask, is calculated described pending The initial position of each subtask in business and the final position of each subtask；The task encapsulates subelement, for each subtask：By the task identification of the waiting task, the subtask Initial position, the subtask final position and waiting task parameter information be encapsulated as the subtask object of the subtask；The allocation unit first, specifically for each subtask, the subtask object of the subtask is assigned to described in one Task handles node；The notification receiving unit, the task processing node of the subtask is assigned for receiving for subtask feedback Notification message, if the notification message is to handle the refusal of the subtask message, allocation unit again described in triggering；Its In, the refusal processing message is that task processing node is not less than default quantity in the quantity for determining its currently processed subtask The notification receiving unit of the task allocation node is fed back to during threshold value；The allocation unit again, did not fed back appointing to the refusal processing message of the subtask for the subtask to be assigned to Business processing node, triggers the notification receiving unit.
- 7. system according to claim 6, it is characterised in that further include：Progress obtaining unit and task buanch unit,The progress obtaining unit, in the case of handling message in the notification message for the agreement to the subtask, is obtained Obtain the processing progress information that the task processing node is sent；The task buanch unit, after being notified extremely in the processing for receiving the task processing node transmission, according to hair The task that the processing notifies extremely is given to handle the processing progress information of node, by the untreated part or complete of task processing node Other tasks processing node that portion subtask is assigned in addition to the task handles node is handled, wherein, the processing is different Normal open knows what task processing node was sent when the speed for determining its processing subtask is less than pre-set velocity threshold value.
- 8. the system according to claim 6 or 7, it is characterised in that the task allocation node also with task interface module Connection, the multiple task processing node are located in multiple servers, and each task processing node is only located in a server, The task split cells is specifically used for：The waiting task that the task interface module receives is obtained, by described pending Business is split as multiple subtasks.
- 9. a kind of task processing system, it is characterised in that handle node, the task processing node and task point applied to task It is connected with node, the system comprises：Subtask obtains module, quantity determining module and message feedback module,The subtask obtains module, for obtaining the subtask of the task allocation node distribution, wherein, which is institute State what task allocation node obtained after being split to waiting task；The quantity determining module, for determining the quantity of the currently processed subtask of task processing node whether not less than pre- If amount threshold, if it is, triggering the message feedback module；The message feedback module, for handling message to the refusal of the subtask to task allocation node feedback, so that The subtask is assigned to not feed back by the task allocation node handles section to the task of the refusal processing message of the subtask Point；The system also includes：Acceptance message feedback module, progress obtain module, progress sending module, speed determination module and Notify sending module,The acceptance message feedback module, for determining the currently processed son of task processing node in the quantity determining module When the quantity of task is less than default amount threshold, the agreement fed back to the task allocation node to the subtask handles message；The progress obtains module, for obtaining the processing progress information of task processing node processing task；The progress sending module, for the processing progress information to be sent to the task allocation node；Whether the speed determination module, the speed for determining task processing node processing subtask are less than pre-set velocity threshold Value, if it is, triggering the notice sending module；The notice sending module, for sending the abnormal notice of processing to the task allocation node, so that the task is distributed Node handles the processing progress information of node transmission according to the task, by the task after the abnormal notice of the processing is received Other tasks that the untreated partly or entirely subtask of processing node is assigned in addition to the task handles node handle node Handled.
- 10. system according to claim 9, it is characterised in that the task allocation node also connects with task interface module Connect, multiple tasks processing node is located in multiple servers, and each task processing node is only located in a server.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201510150111.5A CN104731663B (en) | 2015-03-31 | 2015-03-31 | Task processing method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201510150111.5A CN104731663B (en) | 2015-03-31 | 2015-03-31 | Task processing method and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN104731663A CN104731663A (en) | 2015-06-24 |
| CN104731663B true CN104731663B (en) | 2018-04-13 |
Family
ID=53455577
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201510150111.5A Active CN104731663B (en) | 2015-03-31 | 2015-03-31 | Task processing method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN104731663B (en) |
Families Citing this family (26)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP6532385B2 (en) * | 2015-11-02 | 2019-06-19 | キヤノン株式会社 | INFORMATION PROCESSING SYSTEM, CONTROL METHOD THEREOF, AND PROGRAM |
| CN105511975B (en) * | 2015-11-27 | 2019-06-04 | 北京奇虎科技有限公司 | A kind of abnormality eliminating method and device |
| CN105516259B (en) * | 2015-11-27 | 2019-06-04 | 北京奇虎科技有限公司 | A kind of method for sending information and device |
| CN107153573A (en) * | 2016-03-02 | 2017-09-12 | 阿里巴巴集团控股有限公司 | Distributed task scheduling treating method and apparatus |
| CN105912399B (en) * | 2016-04-05 | 2020-02-07 | 杭州嘉楠耘智信息科技有限公司 | Task processing method, device and system |
| CN106528292B (en) * | 2016-10-21 | 2022-04-22 | 上海嘉楠捷思信息技术有限公司 | Task processing method and device |
| CN108022028B (en) * | 2016-11-01 | 2021-02-26 | 南京途牛科技有限公司 | Resource processing method and device |
| CN106453420A (en) * | 2016-12-08 | 2017-02-22 | 郑州云海信息技术有限公司 | Request processing device and method and terminal |
| CN106682872A (en) * | 2016-12-19 | 2017-05-17 | 北京锐安科技有限公司 | Mission distribution method and device |
| CN108270837B (en) * | 2017-01-04 | 2021-04-30 | 北京京东尚科信息技术有限公司 | Distributed task scheduling method and system using idle resources |
| CN108692801B (en) | 2017-04-12 | 2022-01-28 | 梅特勒-托利多(常州)精密仪器有限公司 | Weighing and measuring system and metering system |
| CN108958922B (en) * | 2017-05-17 | 2022-01-07 | 北京京东尚科信息技术有限公司 | Method and device for executing task |
| CN109146212B (en) * | 2017-06-16 | 2022-03-25 | 佛山科学技术学院 | Large-scale isomorphic task allocation method in crowdsourcing system |
| CN109254833B (en) * | 2017-07-12 | 2020-10-09 | 杭州海康威视数字技术股份有限公司 | Picture analysis method, device and system and computer equipment |
| CN109753849B (en) * | 2017-11-03 | 2021-08-17 | 杭州海康威视数字技术股份有限公司 | Method and device for processing video analysis task |
| CN108037968B (en) * | 2017-12-01 | 2021-11-05 | 东软集团股份有限公司 | Execution progress display method and device, storage medium and electronic equipment |
| CN109214132B (en) * | 2018-10-30 | 2023-06-30 | 中国运载火箭技术研究院 | LVC simulation-oriented uncoupled streaming type large-flux asynchronous task processing system |
| CN109754189A (en) * | 2019-01-07 | 2019-05-14 | 金邦达有限公司 | A kind of distribution method of fabrication task, a kind of acquisition methods, computer installation and the computer readable storage medium of fabrication task |
| CN110532077B (en) * | 2019-08-22 | 2021-12-07 | 腾讯科技（深圳）有限公司 | Task processing method and device and storage medium |
| CN110942244A (en) * | 2019-11-22 | 2020-03-31 | 北京金山云网络技术有限公司 | Work order distribution method and device, electronic equipment and storage medium |
| CN111506400A (en) * | 2020-03-13 | 2020-08-07 | 平安国际智慧城市科技股份有限公司 | Computing resource allocation system, method, device and computer equipment |
| CN111367647B (en) * | 2020-03-31 | 2024-06-11 | 绿盟科技集团股份有限公司 | Task assignment method and device |
| CN111756833B (en) * | 2020-06-22 | 2023-04-28 | 抖音视界有限公司 | Node processing method, node processing device, electronic equipment and computer readable medium |
| CN113127207B (en) * | 2021-04-30 | 2024-04-02 | 平安国际融资租赁有限公司 | Crowd-sourced task resource allocation method and device, electronic equipment and storage medium |
| CN113835862B (en) * | 2021-09-26 | 2023-07-07 | 中国联合网络通信集团有限公司 | Task processing method and device |
| CN114708970B (en) * | 2022-04-11 | 2023-05-16 | 上海铂桐医疗科技有限公司 | Pain comprehensive evaluation data processing method and system suitable for big data |
Family Cites Families (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US6304866B1 (en) * | 1997-06-27 | 2001-10-16 | International Business Machines Corporation | Aggregate job performance in a multiprocessing system by incremental and on-demand task allocation among multiple concurrently operating threads |
| CN101753461B (en) * | 2010-01-14 | 2012-07-25 | 中国建设银行股份有限公司 | Method for realizing load balance, load balanced server and group system |
| CN102521051B (en) * | 2011-12-05 | 2014-05-07 | 中国联合网络通信集团有限公司 | Task scheduling method, device and system in Map Reduce system applied to nomography |
| CN102541645B (en) * | 2012-01-04 | 2013-09-11 | 北京航空航天大学 | Dynamic adjustment method for node task slot based on node state feedbacks |
| CN103677751B (en) * | 2012-09-06 | 2016-12-21 | 阿里巴巴集团控股有限公司 | Tasks in parallel treating method and apparatus |
| CN103699441B (en) * | 2013-12-05 | 2017-07-18 | 深圳先进技术研究院 | The MapReduce report task executing method of task based access control granularity |
| CN104331520B (en) * | 2014-11-28 | 2018-08-07 | 北京奇艺世纪科技有限公司 | Hadoop clustering performances optimization method and device and node state recognition methods and device |
| CN104461710A (en) * | 2014-12-12 | 2015-03-25 | 北京国双科技有限公司 | Method and device for processing tasks |
-
2015
- 2015-03-31 CN CN201510150111.5A patent/CN104731663B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN104731663A (en) | 2015-06-24 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN104731663B (en) | Task processing method and system | |
| US10425534B2 (en) | System and method for optimizing agent time | |
| US7848836B2 (en) | Scheduling system and work order scheduling protocol for such a system | |
| CN107861760A (en) | BIOS collocation method, terminal and server | |
| CN107291547A (en) | A kind of task scheduling processing method, apparatus and system | |
| CN101981897A (en) | Method and device for communicating according to the standard protocol OPC UA in a client/server system | |
| CN113051019A (en) | Flow task execution control method, device and equipment | |
| CN109961196B (en) | Method for servicing numerically controlled machine tools and corresponding device | |
| CN106789166B (en) | Method and device for network element batch configuration | |
| CN109040178A (en) | Configuration information transmitting method and device | |
| CN111507643A (en) | Work order distribution method and device, electronic equipment and storage medium | |
| CN111934956B (en) | Equipment configuration method and device, storage medium and electronic device | |
| CN101185070A (en) | Device management system and method for setting configuration-value therein | |
| CN109348434A (en) | A kind of sending method of scene information, sending device and terminal device | |
| CN113609047B (en) | Data adapter and data adaptation method | |
| CN109976883A (en) | Task processing method and system | |
| JP2006293743A (en) | Server type computer and transfer evaluation decision apparatus | |
| CN103914339B (en) | Server management system and server management method | |
| CN108696564A (en) | task processing method, device, terminal and storage medium | |
| CN107743246A (en) | Task processing method, system and data handling system | |
| EP0464352A2 (en) | Sub-entry point interface architecture for change management in a computer network | |
| CN107769947A (en) | A kind of method, apparatus and equipment for changing customization skin | |
| CN114172940B (en) | Control method and device of cooking equipment, storage medium and terminal | |
| CN110276212A (en) | Processing method and processing device, storage medium and the electronic device of data | |
| CN108153650A (en) | Obtain method, system, device and the storage medium of Cloud Server resource information |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |