Shared runqueue implementation. More...
Public Member Functions | |
| impl (const location_id first, const size_type n) | |
| template<typename T > | |
| impl (location_range_wrapper< T > const &r) | |
| impl (impl const &other) | |
| size_type | size (void) const noexcept |
| void | enqueue (const location_id lid, message_ptr m) |
Enqueues a message for location lid. More... | |
| void | enqueue_any (message_ptr m) |
| Enqueues a message for any locally managed location. | |
| void | enqueue_all (const bool ordered, message_ptr m) |
| Enqueues a message for all the locally managed locations. | |
| template<typename Range > | |
| void | enqueue_range (Range const &r, const bool ordered, message_ptr m) |
Enqueues a message for the range r of locally managed locations. | |
| queue_type & | get_queue (const location_id lid) noexcept |
Returns the queue for location lid. | |
Public Types | |
| using | size_type = std::size_t |
| using | queue_type = request_queue |
Shared runqueue implementation.
It is a mailbox structure that keeps the messages that are for each locally managed location.
| void stapl::runtime::shared_runqueue::impl::enqueue | ( | const location_id | lid, |
| message_ptr | m | ||
| ) |
Enqueues a message for location lid.
1.8.13