Navigation
API > API/Runtime > API/Runtime/Core > API/Runtime/Core/Containers
References
| Module | Core |
| Header | /Engine/Source/Runtime/Core/Public/Containers/ClosableMpscQueue.h |
| Include | #include "Containers/ClosableMpscQueue.h" |
Syntax
template<typename T>
class TClosableMpscQueue
Remarks
Multi-producer/single-consumer unbounded concurrent queue that can be consumed only once.
Constructors
| Type | Name | Description | |
|---|---|---|---|
TClosableMpscQueue
(
const TClosableMpscQueue& |
Destructors
| Type | Name | Description | |
|---|---|---|---|
Functions
| Type | Name | Description | |
|---|---|---|---|
| bool | Close
(
const F& Consumer |
Closes the queue and consumes all items. | |
| bool | Enqueue
(
ArgTypes&&... Args |
Returns false if the queue is closed | |
| bool | IsClosed () |
Operators
| Type | Name | Description | |
|---|---|---|---|
| TClosableMpscQueue & | operator=
(
const TClosableMpscQueue& |
||
| TClosableMpscQueue & | operator=
(
TClosableMpscQueue&& |