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
.