Navigation
API > API/Runtime > API/Runtime/Core
Multi-producer/single-consumer unbounded concurrent queue that can be consumed only once.
| Name | TClosableMpscQueue |
| Type | class |
| Header File | /Engine/Source/Runtime/Core/Public/Containers/ClosableMpscQueue.h |
| Include Path | #include "Containers/ClosableMpscQueue.h" |
Syntax
template<typename T>
class TClosableMpscQueue
Constructors
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
| Containers/ClosableMpscQueue.h | |||
| Containers/ClosableMpscQueue.h | |||
TClosableMpscQueue
(
const TClosableMpscQueue& |
Containers/ClosableMpscQueue.h |
Destructors
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
~TClosableMpscQueue() |
Containers/ClosableMpscQueue.h |
Structs
| Name | Remarks |
|---|---|
| FNode |
Variables
Protected
| Name | Type | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|---|
| Head | std::atomic< FNode * > | Containers/ClosableMpscQueue.h | ||
| Sentinel | FNode | Containers/ClosableMpscQueue.h |
Functions
Public
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
bool Close
(
const F& Consumer |
Closes the queue and consumes all items. | Containers/ClosableMpscQueue.h | |
bool Enqueue
(
ArgTypes&&... Args |
Returns false if the queue is closed | Containers/ClosableMpscQueue.h | |
bool IsClosed() |
Containers/ClosableMpscQueue.h |
Static
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
static void Close_NonMember
(
FNode* Head, |
Containers/ClosableMpscQueue.h |
Operators
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
TClosableMpscQueue & operator=
(
const TClosableMpscQueue& |
Containers/ClosableMpscQueue.h | ||
| Containers/ClosableMpscQueue.h |