Reply queue management
View Patent ↗A method, system, and medium are provided for optimizing assignment of threads to queues within a messaging-middleware environment. Embodiments of the present invention evaluate the number of threads assigned to each individual queue and then assign a new thread to an appropriate queue based on current thread assignments. Different rules may be used to assign threads depending on the number of threads assigned to each queue. For example, initially any queue with less than a low threshold amount of active threads may be assigned threads until the low threshold is met. A different assignment methodology may be used once the low threshold is met. For example, once the low threshold is met, active queues having more than the low threshold, but less than a high threshold, may be assigned threads in a round robin fashion.
1. One or more non-transitory computer-readable media having computer-executable instructions embodied thereon for performing a method of optimizing an allocation of threads to messaging-middleware queues, the method comprising:
receiving a request to assign an input thread to a queue, wherein the input thread helps communicate a message from an application to the queue;
retrieving a list of active queues that are designated to receive messages from the application;
determining an active thread number for each active queue on the list;
executing an assignment rule to select a specific queue from all of the active queues, the assignment rule being based on the active thread number for each active queue, wherein the assignment rule requires that all queues with below a low threshold of active threads be filled before threads are assigned to a queue having more than the low threshold of active threads; and
assigning the input thread to the specific queue.
2. The media of claim 1 , wherein the assignment rule requires:
when one or more low queues have the active thread number below the low threshold of active threads, selecting the specific queue according to a selection rule from among the one or more low queues,
when no queues have the active thread number below the low threshold of active threads, determining whether any of the active queues have the active thread number below a high threshold of active threads and,
when one or more high queues have the active thread number below the high threshold of active threads, then selecting the specific queue according to the selection rule from among the one or more high queues, and
when none of the queues have below the high threshold of active threads then communicating an instruction to create a new queue, then selecting the specific queue being the new queue.
3. The media of claim 1 , wherein the selection rule is selecting the specific queue randomly from queues that satisfy the assignment rule.
4. The media of claim 1 , wherein the selection rule is selecting the specific queue from queues that satisfy the assignment rule using an order created using names of the queues that satisfy the assignment rule.
5. The media of claim 1 , wherein the selection rule is selecting the specific queue from queues that satisfy the assignment rule.
6. The media of claim 1 , wherein the selection rule is selecting the specific queue in round robin fashion from queues that satisfy the assignment rule.