CN110413390A - Thread task processing method, device, server and storage medium - Google Patents

Abstract

Embodiments of the present invention disclose a thread task processing method, device, server, and storage medium. The method includes: acquiring a task queue, where the task queue includes a plurality of first tasks; and determining whether the first tasks are assigned corresponding If the first task is not assigned a corresponding thread pool, obtain the thread pool configuration parameters of the first task; configure a thread pool according to the configuration parameters, and the thread pool includes a plurality of first threads; The first thread is called to execute the first task, and the corresponding execution result is recorded. The embodiment of the present invention realizes the multi-thread uploading of files, records the execution result of the thread task in real time, and improves the stability of the multi-thread uploading system.

Description

Thread task processing method, device, server and storage medium

technical field

Embodiments of the present invention relate to the field of file transmission, and in particular, to a thread task processing method, device, server, and storage medium.

Background technique

Secure File Transfer Protocol (Secure File Transfer Protocol, SFTP) provides a secure network encryption method for transferring files. When the new funder is connected, the technical colleague on the access side and the funder confirm the limit of the number of SFTP connections and the required number of threads, and configure the funder's SFTP information in the management system. When multi-threading is required for execution during development, only the multi-threaded component is called to provide an interface, and the component completes the task.

Due to the rapid development of enterprise business, more and more partners, and high similarity of post-loan business, a large number of file interactions are uploaded to the SFTP server of the funder through a single thread. When the data surges, the file upload is not timely; Customized development is required, and every time a new funder accesses the program, the program needs to be rewritten to implement the new task, which greatly affects the business stability of the enterprise.

SUMMARY OF THE INVENTION

Embodiments of the present invention provide a thread task processing method, device, server and storage medium, so as to realize multi-thread uploading of files, query execution results of thread tasks in real time, and improve the stability of the multi-thread upload system.

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

obtaining a task queue, the task queue includes a plurality of first tasks;

judging whether the first task is assigned a corresponding thread pool;

If the first task is not assigned a corresponding thread pool, obtain the thread pool configuration parameters of the first task;

Configure a thread pool according to the configuration parameter, and the thread pool includes a plurality of first threads;

The first thread is called to execute the first task, and the corresponding execution result is recorded.

Optionally, the obtaining configuration parameters includes:

Calling the visual interface to obtain the configuration parameters input by the user, the configuration parameters include one or more of: channel ID, maximum number of supported threads, priority, scheduling frequency, maximum abnormal execution times, and result notification mode.

Optionally, the configuring the thread pool according to the configuration parameter includes:

The thread pool is initialized according to the channel ID and the maximum number of supported threads.

Optionally, the invoking the first thread to perform the first task includes:

Obtain the first thread according to the scheduling frequency and priority of the first task;

Putting the first task into the first thread for execution.

Optionally, the execution result corresponding to the record includes:

Determine whether the first task in the first thread is successfully executed;

If the execution of the first task in the first thread fails, determining the number of times the execution of the first task in the first thread fails;

If the number of failures is less than or equal to the maximum number of abnormal executions, the first task is re-added to the task queue for execution.

Optionally, after the determining the number of times of failures in the execution of the first task in the first thread, the method further includes:

If the number of failures is greater than the maximum number of abnormal executions, the execution result is fed back according to the result notification method.

Optionally, after the recording of the corresponding execution result, it further includes:

A query address capable of querying the execution result in real time is output.

In a second aspect, an embodiment of the present invention provides a thread task processing device, including:

a task queue acquisition module, configured to acquire a task queue, the task queue includes a plurality of first tasks;

a thread configuration judgment module for judging whether the first task is assigned a corresponding thread pool;

a configuration parameter obtaining module, configured to obtain the thread pool configuration parameters of the first task if the first task is not assigned a corresponding thread pool;

a thread pool configuration module, configured to configure a thread pool according to the configuration parameter, where the thread pool includes a plurality of first threads;

A task execution module, configured to call the first thread to execute the first task, and record the corresponding execution result.

In a third aspect, an embodiment of the present invention provides a server, including:

one or more processors;

storage means for storing one or more programs,

When the one or more programs are executed by the one or more processors, the one or more processors implement the thread task processing method provided by any embodiment of the present invention.

In a fourth aspect, an embodiment of the present invention provides a computer-readable storage medium on which an assigned computer program is stored, and when the program is executed by a processor, implements the thread task processing method provided by any embodiment of the present invention.

In the embodiment of the present invention, when the first task in the task queue does not have a corresponding thread pool, the thread pool is configured according to the corresponding configuration parameters, so that the first task in the task queue is executed through multiple threads, and the execution result of the thread task is recorded, so as to realize Multi-threaded upload files, real-time query thread task execution results, improve the stability of the multi-threaded upload system.

Description of drawings

1 is a schematic flowchart of a thread task processing method according to Embodiment 1 of the present invention;

2 is a schematic flowchart of a thread task processing method according to Embodiment 2 of the present invention;

3 is a schematic structural diagram of a thread task processing apparatus according to Embodiment 3 of the present invention;

FIG. 4 is a schematic structural diagram of a server according to Embodiment 4 of the present invention.

Detailed ways

The present invention will be further described in detail below in conjunction with the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are only used to explain the present invention, but not to limit the present invention. In addition, it should be noted that, for the convenience of description, the drawings only show some but not all structures related to the present invention.

Before discussing the exemplary embodiments in greater detail, it should be mentioned that some exemplary embodiments are described as processes or methods depicted as flowcharts. Although the flowchart depicts the steps as a sequential process, many of the steps may be performed in parallel, concurrently, or concurrently. Furthermore, the order of the steps can be rearranged. The process may be terminated when its operation is complete, but may also have additional steps not included in the figures. A process may correspond to a method, function, procedure, subroutine, subroutine, or the like.

Furthermore, the terms "first," "second," etc. may be used herein to describe various directions, acts, steps or elements, etc., but are not limited by these terms. These terms are only used to distinguish a first direction, act, step or element from another direction, act, step or element. The terms "first", "second", etc. should not be understood as indicating or implying relative importance or implying the number of indicated technical features. Thus, a feature defined as "first" or "second" may expressly or implicitly include one or more of that feature. In the description of the present invention, "plurality" and "batch" mean at least two, such as two, three, etc., unless otherwise expressly and specifically defined.

Example 1

1 is a schematic flowchart of a thread task processing method provided in Embodiment 1 of the present invention, which is applicable to uploading files using multiple threads. way to achieve, and can be integrated in the server. As shown in Figure 1, the method includes:

S110. Acquire a task queue, where the task queue includes a plurality of first tasks.

Specifically, the task queue refers to a queue for storing tasks to be processed, that is, the task queue includes a plurality of first tasks to be processed. The first task may be any task type that needs to be executed, such as an interface API request, uploading a file, downloading a file, and the like.

S120. Determine whether the first task is allocated a corresponding thread pool.

Specifically, the thread pool is a form of multi-thread processing, and the thread pool includes multiple threads, and these threads are used to execute the first task in the task queue. If the current first task has been executed before, it means that a corresponding thread pool already exists, and it is only necessary to put the first task that needs to be executed currently into the thread in the existing thread pool for execution. If the current first task is a new task type and there is no existing thread pool to execute the first task, a new thread pool needs to be created so that the first task can be executed.

S130. If the first task is not allocated a corresponding thread pool, acquire the thread pool configuration parameters of the first task.

Specifically, the configuration parameters are some parameters used to create a new thread pool or execute the first task, including one or more of the channel ID, the maximum number of supported threads, the priority, the scheduling frequency, the maximum number of abnormal executions, and the result notification method. variety. These configuration parameters are entered by the user through a visual interface and can be changed at any time without rewriting the program.

In this embodiment, the channel ID is a channel address used to create a new thread pool. Maximum supported threads represents the maximum number of threads that can run concurrently. Priority is used to indicate the priority of the first task. Scheduling frequency refers to the frequency at which the first task is put from the queue into the thread of the thread pool. The maximum number of abnormal executions is the maximum number of times the first task is allowed to fail. The result notification method is the notification method when the thread task execution fails.

S140. Configure a thread pool according to the configuration parameter, where the thread pool includes a plurality of first threads.

Specifically, after the configuration parameters are acquired, the thread pool is configured, that is, a new thread pool is created to execute a new first task. The thread pool includes a plurality of first threads for executing new first tasks.

Optionally, configuring the thread pool according to configuration parameters may be: initializing the thread pool according to the channel ID and the maximum number of supported threads.

Specifically, the channel ID is the channel address used to create a new thread pool, which is assigned by the user. The maximum number of supported threads indicates the maximum number of threads that can run at the same time, which is less than or equal to the maximum number of concurrent threads that the channel corresponding to the channel ID can support. For example, if the channel ID is 1112, the maximum number of threads supported by notification is 10, and the maximum number of supported threads can be 10 or 9, which means that a channel with channel ID of 1112 is created that can support up to 10 or 9 concurrent threads. Thread pool to do.

S150. Invoke the first thread to execute the first task, and record the corresponding execution result.

Specifically, after the thread pool is created, the first task is put into the first thread for execution, and the corresponding execution result is recorded. The corresponding execution results include execution success, execution failure, and the number of execution failures.

Optionally, a method for invoking the first thread to perform the first task may be:

Obtain the first thread according to the scheduling frequency and priority of the first task;

Putting the first task into the first thread for execution.

Specifically, the priority is used to indicate the priority of the first task, and the higher the priority of the first task, the more preferentially it will be executed. By default, multiple first tasks are executed in a "first-in, first-out" manner, that is, the tasks that enter the task queue first are prioritized into the first thread for execution. Under special circumstances, some first tasks are more urgent than others, the most urgent first task can be executed first, and then the less urgent first task can be executed by setting the priority. Optionally, a method for setting the priority is: setting the priority of the first task in the manner of 10, 8, 5, and 3, wherein when the priority of the first task is 10, its priority is the highest, and when the priority of the first task is 10, the priority is the highest. When a task has no priority set, the default priority is 5.

The scheduling frequency refers to the frequency of putting the first task from the queue into the thread of the thread pool, that is, the acquisition frequency of the first task, and the scheduling frequency can be estimated and adjusted according to the execution period of the first task. For example, the execution period of the first task is 0.5s, and the scheduling frequency can be set to 2 times/s.

In the thread task processing method provided in Embodiment 1 of the present invention, when the first task in the task queue does not have a corresponding thread pool, the thread pool is configured according to the corresponding configuration parameters, so that the first task in the task queue is executed by multiple threads, and Record the results of thread task execution, realize multi-thread uploading files, record the execution results of thread tasks in real time, and improve the stability of the multi-thread upload system.

Embodiment 2

FIG. 2 is a schematic flowchart of a thread task processing method according to Embodiment 2 of the present invention. This embodiment is a further refinement on the basis of the foregoing embodiment. As shown in Figure 2, the method includes:

S200. Acquire a task queue, where the task queue includes a plurality of first tasks.

Specifically, the task queue refers to a queue for storing tasks to be processed, that is, the task queue includes a plurality of first tasks to be processed. The first task may be any task type that needs to be executed, such as an interface API request, uploading a file, downloading a file, and the like.

S210. Determine whether the first task is allocated a corresponding thread pool.

Specifically, the thread pool is a form of multi-thread processing, and the thread pool includes multiple threads, and these threads are used to execute the first task in the task queue. If the current first task has been executed before, it means that a corresponding thread pool already exists, and it is only necessary to put the first task that needs to be executed currently into the thread in the existing thread pool for execution. If the current first task is a new task type and there is no existing thread pool to execute the first task, a new thread pool needs to be created so that the first task can be executed.

S220. If the first task is not allocated a corresponding thread pool, acquire the thread pool configuration parameters of the first task.

Specifically, the configuration parameters are some parameters used to create a new thread pool or execute the first task, including one or more of the channel ID, the maximum number of supported threads, the priority, the scheduling frequency, the maximum number of abnormal executions, and the result notification method. variety. These configuration parameters are entered by the user through a visual interface and can be changed at any time without rewriting the program.

In this embodiment, the channel ID is a channel address used to create a new thread pool. Maximum supported threads represents the maximum number of threads that can run concurrently. Priority is used to indicate the priority of the first task. Scheduling frequency refers to the frequency at which the first task is put from the queue into the thread of the thread pool. The maximum number of exception executions is the maximum number of times the thread task execution is allowed to fail. The result notification method is the notification method when the thread task execution fails.

S230. Configure a thread pool according to the configuration parameter, where the thread pool includes a plurality of first threads.

Specifically, after the configuration parameters are acquired, the thread pool is configured, that is, a new thread pool is created to execute a new first task. The thread pool includes a plurality of first threads for executing new first tasks.

Optionally, a method for configuring a thread pool according to a configuration parameter may be: initializing the thread pool according to the channel ID and the maximum number of supported threads.

Specifically, the channel ID is the channel address used to create a new thread pool, which is assigned by the user. The maximum number of supported threads indicates the maximum number of threads that can run at the same time, which is less than or equal to the maximum number of concurrent threads that the channel corresponding to the channel ID can support. For example, if the channel ID is 1112, the maximum number of threads supported by notification is 10, and the maximum number of supported threads can be 10 or 9, which means that a channel with channel ID of 1112 is created that can support up to 10 or 9 concurrent threads. Thread pool to do.

S240. Invoke the first thread to execute the first task.

Specifically, after the thread pool is created, the first task is put into the first thread for execution.

Optionally, a method for invoking the first thread to perform the first task may be:

Obtain the first thread according to the scheduling frequency and priority of the first task;

Putting the first task into the first thread for execution.

Specifically, the priority is used to indicate the priority of the first task, and the higher the priority of the first task, the more preferentially it will be executed. By default, multiple first tasks are executed in a "first-in, first-out" manner, that is, the tasks that enter the task queue first are prioritized into the first thread for execution. Under special circumstances, some first tasks are more urgently processed than other first tasks, the most urgent first task can be executed first, and then the less urgent first task can be executed by setting the priority. Optionally, a method for setting the priority is: setting the priority of the first task in the manner of 10, 8, 5, and 3, wherein when the priority of the first task is 10, its priority is the highest, and when the priority of the first task is 10, the priority is the highest. When a task has no priority set, the default priority is 5.

The scheduling frequency refers to the frequency of putting the first task from the queue into the thread of the thread pool, that is, the acquisition frequency of the first task, and the scheduling frequency can be estimated and adjusted according to the execution period of the first task. For example, the execution period of the first task is 0.5s, and the scheduling frequency can be set to 2 times/s.

S250. Determine whether the first task in the first thread is successfully executed.

Specifically, the first task in the first thread may be called the first thread task. If the first thread task is successfully executed, it means that there is no abnormality or failure during the execution of the first thread task. If the execution fails, it may be There is some abnormal reason, such as network failure, etc.

S260. If the execution of the first task in the first thread fails, determine the number of times the execution of the first task in the first thread fails.

Specifically, if the execution of the first thread task fails, the number of failures should be counted, and step S270 or step S280 should be executed according to the number of failures.

S270. If the number of failures is less than or equal to the maximum number of abnormal executions, re-add the first task to the task queue for execution.

Specifically, the maximum number of abnormal executions is the maximum number of times the task of the first thread is allowed to fail in execution. If the number of failures of the first thread task execution is less than or equal to the maximum number of abnormal execution times, it means that the number of times the first thread task fails to execute is within the allowable range. If the first task is added to the task queue and executed again, it is possible to eliminate the abnormal cause execution. success. For example, if a momentary network failure occurs during the execution of the first thread task, which causes the first thread task to fail to execute, the first task can be successfully executed by adding the first task back to the task queue and executing it again, which improves the execution success rate of the first thread task. .

Optionally, when the first task in the first thread that fails to be executed is rejoined to the queue, the priority of the first task may be increased, so that the first task can be preferentially executed when the first task is executed again.

S280. If the number of failures is greater than the maximum number of abnormal executions, the execution result is fed back according to the result notification method.

Specifically, if the number of execution failures of the first thread task is greater than the maximum abnormal execution times, it means that some kind of abnormality that cannot be repaired by itself has occurred in the execution process of the first task, and manual debugging is required, and the first thread task is fed back according to the result notification method. The total number of execution failures. The result notification method is a method of feeding back abnormal results, such as notifying the set exception handler in the form of a message, or generating a fault report and saving it to the set target folder.

S290. Output a query address capable of querying the execution result in real time.

Specifically, the query address is an interface address that can display the execution result, such as the interface address of a display. By querying the address, the execution of the task of the first thread can be monitored in real time, so that corresponding measures can be taken in time when the execution of the first task of the first thread fails to improve the stability of the system operation.

In the second embodiment of the present invention, by recording the execution results, when the number of execution failures of the first task in the first thread is within the range of the maximum abnormal execution times, the first task is put back into the task queue for execution again. When the number of execution failures of the first task exceeds the maximum number of abnormal executions, the execution result is fed back through the result notification method, and a query address that can query the execution result in real time is output, which realizes real-time monitoring of the execution result of the first task. When the execution fails, corresponding measures can be taken in time to improve the execution success rate of the first task and the stability of the system operation.

Embodiment 3

FIG. 3 is a schematic structural diagram of a thread task processing apparatus according to Embodiment 3 of the present invention. This embodiment is applicable to uploading files using multiple threads. The device can be implemented in software and/or hardware, and can be integrated on a server. The thread task processing apparatus provided by the embodiment of the present invention can execute the thread task processing method provided by any embodiment of the present invention, and has functional modules and beneficial effects corresponding to the execution method. For the content not described in detail in Embodiment 3 of the present invention, reference may be made to the description in any method embodiment of the present invention.

As shown in FIG. 3 , the thread task processing apparatus 300 provided in Embodiment 3 of the present invention includes:

A task queue acquiring module 310, configured to acquire a task queue, where the task queue includes a plurality of first tasks;

a thread configuration judging module 320, configured to judge whether the first task is assigned a corresponding thread pool;

A configuration parameter obtaining module 330, configured to obtain a thread pool configuration parameter of the first task if the first task is not assigned a corresponding thread pool;

a thread pool configuration module 340, configured to configure a thread pool according to the configuration parameter, where the thread pool includes a plurality of first threads;

The task execution module 350 is configured to call the first thread to execute the first task, and record the corresponding execution result.

Further, the configuration parameter obtaining module 330 is further configured to call the visual interface to obtain the configuration parameters input by the user, the configuration parameters include: channel ID, maximum number of supported threads, priority, scheduling frequency, maximum abnormal execution times and result notification one or more of the ways.

Further, the thread pool configuration module 340 includes:

A thread pool initialization unit, configured to initialize the thread pool according to the channel ID and the maximum number of supported threads.

Further, the task execution module 350 includes:

a first thread acquiring unit, configured to acquire the first thread according to the scheduling frequency and priority of the first task;

A first task execution unit, configured to put the first task into the first thread for execution.

Further, the task execution module 350 also includes:

a first task execution result judgment unit, configured to judge whether the first task in the first thread is successfully executed;

a first task execution failure times judgment unit, configured to determine the failure times of the first task execution in the first thread if the first task execution in the first thread fails;

A first task rebuilding unit, configured to re-add the first task to the task queue for execution if the number of failures is less than or equal to the maximum number of abnormal executions.

Further, the task execution module 350 also includes:

An execution result feedback unit, configured to feed back an execution result according to the result notification method if the number of failures is greater than the maximum number of abnormal executions.

Further, the thread task processing apparatus 300 further includes:

The query address output module is used for outputting the query address that can query the execution result in real time.

In the third embodiment of the present invention, when the first task in the task queue does not have a corresponding thread pool, the thread pool is configured according to the corresponding configuration parameters, so that the first task in the task queue is executed through multiple threads, and the execution result of the thread task is recorded , to achieve multi-threaded uploading of files, real-time query of the execution results of thread tasks, and improve the business stability of multi-threaded uploading.

Embodiment 4

FIG. 4 is a schematic structural diagram of a server according to Embodiment 4 of the present invention. Figure 4 shows a block diagram of an exemplary server 412 suitable for use in implementing embodiments of the present invention. The server 412 shown in FIG. 4 is only an example, and should not impose any limitation on the functions and scope of use of the embodiments of the present invention.

As shown in FIG. 4, server 412 takes the form of a general server. Components of server 412 may include, but are not limited to, one or more processors 416, storage 428, and a bus 418 connecting various system components including storage 428 and processor 416.

Bus 418 represents one or more of several types of bus structures, including a storage device bus or storage device controller, a peripheral bus, a graphics acceleration port, a processor, or a local bus using any of a variety of bus structures. For example, these architectures include, but are not limited to, Industry Subversive Alliance (ISA) bus, Micro Channel Architecture (MAC) bus, enhanced ISA bus, Video Electronics Standards Association (Video Electronics Standards Association) , VESA) local bus and peripheral component interconnect (Peripheral Component Interconnect, PCI) bus.

Server 412 typically includes a variety of computer system readable media. These media can be any available media that can be accessed by server 412, including volatile and non-volatile media, removable and non-removable media.

Storage 428 may include computer system readable media in the form of volatile memory, such as random access memory (RAM) 430 and/or cache memory 432 . Server 412 may further include other removable/non-removable, volatile/non-volatile computer system storage media. For example only, storage system 434 may be used to read and write to non-removable, non-volatile magnetic media (not shown in FIG. 4, commonly referred to as a "hard drive"). Although not shown in Figure 4, a magnetic disk drive may be provided for reading and writing to removable non-volatile magnetic disks (eg "floppy disks"), as well as removable non-volatile optical disks such as Compact Disc Read -Only Memory, CD-ROM), digital video disc (Digital Video Disc-Read Only Memory, DVD-ROM) or other optical media) CD-ROM drive for reading and writing. In these cases, each drive may be connected to bus 418 through one or more data media interfaces. Storage 428 may include at least one program product having a set (eg, at least one) of program modules configured to perform the functions of various embodiments of the present invention.

A program/utility 440 having a set (at least one) of program modules 442, which may be stored, for example, in storage device 428, such program modules 442 including, but not limited to, an operating system, one or more application programs, other program modules, and programs Data, each or some combination of these examples may include an implementation of a network environment. Program modules 442 generally perform the functions and/or methods of the described embodiments of the present invention.

The server 412 may also communicate with one or more external devices 414 (eg, keyboards, pointing servers, display 424, etc.), with one or more servers that enable a user to interact with the server 412, and/or with the Server 412 can communicate with any server (eg, network card, modem, etc.) that communicates with one or more other computing servers. Such communication may take place through input/output (I/O) interface 422 . Also, the server 412 may communicate with one or more networks (eg, Local Area Network (LAN), Wide Area Network (WAN), and/or public networks such as the Internet) through a network adapter 420 . As shown in FIG. 4 , network adapter 420 communicates with other modules of server 412 via bus 418 . It should be understood that, although not shown, other hardware and/or software modules may be used in conjunction with server 412, including but not limited to: microcode, server drivers, redundant processors, external disk drive arrays, Redundant Arrays of disks Independent Disks, RAID) systems, tape drives and data backup storage systems.

The processor 416 executes various functional applications and data processing by running the programs stored in the storage device 428, for example, to implement the thread task processing method provided by any embodiment of the present invention, and the method may include:

obtaining a task queue, the task queue includes a plurality of first tasks;

judging whether the first task is assigned a corresponding thread pool;

If the first task is not assigned a corresponding thread pool, obtain the thread pool configuration parameters of the first task;

Configure a thread pool according to the configuration parameter, and the thread pool includes a plurality of first threads;

The first thread is called to execute the first task, and the corresponding execution result is recorded.

Embodiment 5

Embodiment 5 of the present invention also provides a computer-readable storage medium, on which a computer program is stored, and when the program is executed by a processor, implements the thread task processing method provided by any embodiment of the present invention, and the method may include:

obtaining a task queue, the task queue includes a plurality of first tasks;

judging whether the first task is assigned a corresponding thread pool;

If the first task is not assigned a corresponding thread pool, obtain the thread pool configuration parameters of the first task;

Configure a thread pool according to the configuration parameter, and the thread pool includes a plurality of first threads;

The first thread is called to execute the first task, and the corresponding execution result is recorded.

The computer storage medium in the embodiments of the present invention may adopt any combination of one or more computer-readable mediums. The computer-readable medium may be a computer-readable signal medium or a computer-readable storage medium. The computer-readable storage medium can be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus or device, or a combination of any of the above. More specific examples (a non-exhaustive list) of computer readable storage media include: electrical connections having one or more wires, portable computer disks, hard disks, random access memory (RAM), read only memory (ROM), Erasable programmable read only memory (EPROM or flash memory), optical fiber, portable compact disk read only memory (CD-ROM), optical storage devices, magnetic storage devices, or any suitable combination of the foregoing. In this document, a computer-readable storage medium can be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device.

A computer-readable signal medium may include a propagated data signal in baseband or as part of a carrier wave, with computer-readable program code embodied thereon. Such propagated data signals may take a variety of forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A computer-readable signal medium can also be any computer-readable medium other than a computer-readable storage medium that can transmit, propagate, or transport the program for use by or in connection with the instruction execution system, apparatus, or device .

Program code embodied on a computer readable medium may be transmitted using any suitable medium, including - but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.

Computer program code for carrying out operations of the present invention may be written in one or more programming languages, including object-oriented programming languages—such as Java, Smalltalk, C++, but also conventional Procedural programming language - such as the "C" language or similar programming language. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer, or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computer (eg, using an Internet service provider through Internet connection).

Note that the above are only preferred embodiments of the present invention and applied technical principles. Those skilled in the art will understand that the present invention is not limited to the specific embodiments described herein, and various obvious changes, readjustments and substitutions can be made by those skilled in the art without departing from the protection scope of the present invention. Therefore, although the present invention has been described in detail through the above embodiments, the present invention is not limited to the above embodiments, and can also include more other equivalent embodiments without departing from the concept of the present invention. The scope is determined by the scope of the appended claims.

Claims (10)

1. a thread task processing method, is characterized in that, comprises: obtaining a task queue, the task queue includes a plurality of first tasks; judging whether the first task is assigned a corresponding thread pool; If the first task is not assigned a corresponding thread pool, obtain the thread pool configuration parameters of the first task; Configure a thread pool according to the configuration parameter, and the thread pool includes a plurality of first threads; The first thread is called to execute the first task, and the corresponding execution result is recorded. 2. The method of claim 1, wherein the obtaining configuration parameters comprises: Calling the visual interface to obtain the configuration parameters input by the user, the configuration parameters include one or more of: channel ID, maximum number of supported threads, priority, scheduling frequency, maximum abnormal execution times, and result notification mode. 3. The method of claim 2, wherein the configuring the thread pool according to the configuration parameter comprises: The thread pool is initialized according to the channel ID and the maximum number of supported threads. 4. The method of claim 2, wherein the invoking the first thread to execute the first task comprises: Obtain the first thread according to the scheduling frequency and priority of the first task; Putting the first task into the first thread for execution. 5. The method according to claim 4, wherein the execution result corresponding to the record comprises: Determine whether the first task in the first thread is successfully executed; If the execution of the first task in the first thread fails, determining the number of times the execution of the first task in the first thread fails; If the number of failures is less than or equal to the maximum number of abnormal executions, the first task is re-added to the task queue for execution. 6. The method according to claim 5, wherein after determining the number of failures in the execution of the first task in the first thread, the method further comprises: If the number of failures is greater than the maximum number of abnormal executions, the execution result is fed back according to the result notification method. 7. The method according to claim 1, characterized in that, after the recording corresponding execution result, further comprising: A query address capable of querying the execution result in real time is output. 8. A thread task processing device, comprising: a task queue acquisition module, configured to acquire a task queue, the task queue includes a plurality of first tasks; a thread configuration judgment module for judging whether the first task is assigned a corresponding thread pool; a configuration parameter obtaining module, configured to obtain the thread pool configuration parameters of the first task if the first task is not assigned a corresponding thread pool; a thread pool configuration module, configured to configure a thread pool according to the configuration parameter, where the thread pool includes a plurality of first threads; A task execution module, configured to call the first thread to execute the first task, and record the corresponding execution result. 9. A server, characterized in that, comprising: one or more processors; storage means for storing one or more programs, When the one or more programs are executed by the one or more processors, the one or more processors implement the thread task processing method according to any one of claims 1-7. 10. A computer-readable storage medium on which an assigned computer program is stored, characterized in that, when the program is executed by a processor, the thread task processing method according to any one of claims 1-7 is implemented.