CONDITIONAL DEFERRED QUEUING

• US 20120159514A1
• Filed: 12/15/2010
• Published: 06/21/2012
• Est. Priority Date: 12/15/2010
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Boctor, Victor, De Graaf, Wilbert, Gourevitch, Greg, Wallace, Shaun, Sigalov, Fai
• Granted Patent: US 9,141,447 B2
• Time in Patent Office: Days
• US Class Current: 719/314
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

Conditional deferred queuing may be provided. Upon receiving a message, one or more throttle conditions associated with the message may be identified. A lock associated with the throttle condition may be created on the message until the throttle condition is satisfied. Then, the lock on the message may be removed and the message may be delivered.

Claims

1. A method for providing conditional deferred queuing, the method comprising:

receiving a message;

identifying a throttle condition associated with the message;

creating a lock on the message associated with the throttle condition;

determining whether the throttle condition is satisfied; and

in response to determining that the throttle condition is satisfied;

removing the lock on the message, and

delivering the message.

2. The method of claim 1, wherein the message comprises at least one of the following:

an e-mail message, an instant messaging service message, and a text message.

3. The method of claim 1, wherein identifying the throttle condition comprises identifying at least one of the following:

a resource availability condition, a message identifier condition, a concurrency limit condition, and a tenancy condition.

4. The method of claim 1, further comprising assigning the message to a conditional queue associated with the throttle condition.

5. The method of claim 4, further comprising, prior to removing the lock on the message:

determining whether the message is a first message of the conditional queue; and

in response to determining that the message is not the first message of the conditional queue, maintaining the lock on the message.

6. The method of claim 5, further comprising:

identifying a priority associated with the message; and

assigning the message to a priority queue associated with the identified priority.

7. The method of claim 6, wherein the conditional queue is associated with the priority queue.

8. The method of claim 7, wherein the priority queue further comprises a plurality of messages not associated with the throttle condition.

9. The method of claim 7, further comprising:

receiving a delivery request associated with the identified priority;

determining whether the lock is maintained on the message; and

in response to determining that the lock is maintained on the message associated with the throttle condition, delivering at least one of the plurality of messages not associated with the throttle condition.

10. The method of claim 1, wherein delivering the message comprises delivering the message to at least one recipient user.

11. The method of claim 1, wherein delivering the message comprises delivering the message to a message processing component.

12. A computer-readable medium which stores a set of instructions which when executed performs a method for providing conditional deferred queuing, the method executed by the set of instructions comprising:

receiving a message;

identifying a throttle condition associated with the message;

assigning the message to a locked queue associated with the throttle condition;

determining whether the throttle condition is satisfied; and

in response to determining that the throttle condition is satisfied;

determining whether the message is a first locked message in the locked queue, and

in response to determining that the message is the first locked message in the conditional queue, moving the message to an unlocked queue.

13. The computer-readable medium of claim 12, further comprising:

determining whether a dequeue request has been received;

in response to determining that the dequeue request has been received, determining whether the message is the first unlocked message in the unlocked queue; and

in response to determining that the message is the first unlocked message in the unlocked queue, delivering the message.

14. The computer-readable medium of claim 12, wherein the throttle condition comprises a concurrency limit condition.

15. The computer-readable medium of claim 13, wherein the concurrency limit condition is associated with at least one of the following:

a recipient of the message and a sender of the message.

16. The computer-readable medium of claim 12, wherein the throttle condition comprises a message identifier condition limiting processing of a plurality of copies of the message.

17. The computer-readable medium of claim 12, wherein the throttle condition comprises a resource availability condition.

18. The computer-readable medium of claim 17 wherein the resource availability condition comprises a threshold number of simultaneous messages that can be handled by a message processing component.

19. The computer-readable medium of claim 12, wherein the throttle condition comprises a tenancy condition associated with queuing a plurality of messages associated with a plurality of message processing tenants.

20. A system for providing a context-aware environment, the system comprising:

a memory storage; and

a processing unit coupled to the memory storage, wherein the processing unit is operative to;

receive a message,

determine whether the message is associated with at least one of a plurality of throttle conditions, wherein the at least one of the plurality of throttle conditions comprises at least one of the following;

a resource availability condition, a message identifier condition, a concurrency limit condition, and a tenancy condition,

in response to determining that the message is associated with the at least one of the plurality of throttle conditions;

lock the message according to the at least one of the plurality of throttle conditions;

determine whether the throttle condition has been satisfied, and

in response to determining that the message comprises the first message of the locked queue, unlock the message, and

in response to determining that the message is not associated with the at least one of the plurality of throttle conditions, deliver the message to at least one of the following;

the recipient of the message and the message processing component.