Queuing for thread pools using number of bytes
AssigneeRed Hat, Inc.
InventorBela Ban
Life of this patent
Estimating the term…
Abstract
A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A building block layer is coupled to the application programming interface. A channel layer is coupled to the building block layer. A transport protocol stack is coupled to the channel layer for implementing properties specified by the channel layer. The transport protocol stack has a concurrent stack consisting of an out of band thread pool and a regular thread pool. The transport protocol layer is to process messages from each sender in parallel with the corresponding channel for each sender.
Claims31
A computer-implemented method for processing messages, the method comprising:
- receiving messages from a plurality of senders;
- queuing the messages from each sender based on a user-defined criteria;
- forming a channel for each sender;
- and
- processing the messages from each sender in parallel with the corresponding channel for each sender based on the user-defined criteria.
An article of manufacture comprising:
- a machine-accessible storage medium including data that, when accessed by a machine, cause the machine to perform a method comprising:
- receiving messages from a plurality of senders;
- queuing the messages from each sender based on a user-defined criteria;
- forming a channel for each sender;
- and
- processing the messages from each sender in parallel with the corresponding channel for each sender based on the user-defined criteria.
An apparatus for processing messages comprising:
- an application programming interface for receiving and sending messages;
- a building block layer coupled to the application programming interface;
- a channel layer coupled to the building block layer, the channel layer to form a channel for each sender;
- and
- a transport protocol stack coupled to the channel layer for implementing properties specified by the channel layer, the transport protocol stack comprising a concurrent stack consisting of an out of band thread pool and a regular thread pool, the transport protocol stack configured to receive messages from a plurality of senders, to queue the messages from each sender based on a user-defined criteria, and to process the messages from each sender in parallel with the corresponding channel for each sender based on the user-defined criteria.
Dependencies are inferred from the claim text.