Class MpscStorage<T, SendAwaiter, RecvAwaiter>

#include <ChannelBase.hpp>
template<typename T,typename SendAwaiter,typename RecvAwaiter>classMpscStorage{ ... }
No description provided
Examples0
Public static methods0
Public member functions6
boolhasCapacity()const
No description provided
voidclear()
No description provided
voidregisterSendWaiter(
SendAwaiter*waiter
)
No description provided
voidregisterRecvWaiter(
RecvAwaiter*waiter
)
No description provided
std::optional<T>pop()

Pops and returns a value from the queue if one is present. Unblocks a waiting sender if applicable.

boolpush(
T&value
,
boolback
)

Attempts to push a value directly into the receiver’s slot if one is present, otherwise attempts to push into the queue. If everything fails, returns false.

Fields4
std::deque<T>queue
;
No description provided
std::deque<SendAwaiter*>sendWaiters
;
No description provided
RecvAwaiter*recvWaiter
;
No description provided
std::optional<size_t>capacity
;
No description provided
Protected member functions0
Protected fields0
Derived classes0