System and method for supporting cooperative notification offloading in a distributed data grid

A system for supporting cooperative notification offloading, the system comprising:

• a computer system having a memory and a processor, wherein the processor has a plurality of cores and is capable of multi-threaded operation;
• a multi-threaded messaging system operating on said computer system and having a service thread and a plurality of waiting threads;
• a pending notifier collection stored in said memory and comprising a plurality of pending notifiers associated with said plurality of waiting threads;
• wherein said signaling thread is configured to signal a notifier of the plurality of pending notifiers in the pending notifier collection and wake an awoken thread associated with said notifier;
• wherein the awoken thread is configured to signal additional pending notifiers of the plurality of pending notifiers in the pending notifier collection and wake additional awoken threads associated with said additional pending notifiers;
• and
• wherein each additional awoken thread is configured to signal more additional pending notifiers of the plurality of pending notifiers in the collection of pending notifiers and wake more additional awoken threads associated with said more additional pending notifiers until all of the plurality of pending notifiers in the collection of pending notifiers have been signaled and all of plurality of waiting threads have been awoken.

A non-transitory computer-readable media comprising instructions stored thereon for supporting cooperative notification offloading in a multi-threaded messaging system having a service thread and a plurality of waiting threads, which instructions, when executed, cause a computer system to perform steps comprising:

• maintaining a pending notifier collection comprising a plurality of pending notifiers associated with said plurality of waiting threads;
• signaling with said service thread, a notifier of the plurality of pending notifiers in the pending notifier collection and waking an awoken thread associated with said notifier;
• signaling with the awoken thread additional pending notifiers of the plurality of pending notifiers in the pending notifier collection and waking additional awoken threads associated with said additional pending notifiers;
• and
• wherein each additional awoken thread signals more additional pending notifiers of the plurality of pending notifiers in the pending notifier collection and wakes more additional awoken threads associated with said more additional pending notifiers until all of the plurality of pending notifiers in the pending notifier collection have been signaled and all of plurality of waiting threads have been awoken.