TClosableMpscQueue

Multi-producer/single-consumer unbounded concurrent queue that can be consumed only once.

Choose your operating system:

Windows

macOS

Linux

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

Destructors

Name Description

Public function

~TClosableMpscQueue()

Functions

Name Description

Public function

bool

 

Close

(
    const F& Consumer
)

Closes the queue and consumes all items.

Public function

bool

 

Enqueue

(
    ArgTypes&&... Args
)

Returns false if the queue is closed

Public function Const

bool

 

IsClosed()

Operators

Name Description

Public function

TClosableMps...

 

operator=

(
    const TClosableMpscQueue&
)

Public function

TClosableMps...

 

operator=

(
    TClosableMpscQueue&&
)