Navigation
API > API/Runtime > API/Runtime/MassEntity
| Name | FProcessingQueue |
| Type | struct |
| Header File | /Engine/Source/Runtime/MassEntity/Public/MassProcessingQueue.h |
| Include Path | #include "MassProcessingQueue.h" |
Syntax
struct FProcessingQueue
Variables
Public
| Name | Type | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|---|
| bBlockMainThread | bool | Should Execute(...) await the completion of all processors before returning | MassProcessingQueue.h |
Protected
| Name | Type | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|---|
| ActiveChunkContentionTracker | FActiveChunkTracker | Only tracks possible contention of direct chunk access (i.e. contention that can only occur accessing the same chunk) | MassProcessingQueue.h | |
| ActiveChunkCount | std::atomic< int32 > | MassProcessingQueue.h | ||
| ActiveContentionTracker | FActiveContentionTracker | Tracks active global contention | MassProcessingQueue.h | |
| ActiveProcessorCount | std::atomic< int32 > | MassProcessingQueue.h | ||
| bProcessorListDirty | bool | MassProcessingQueue.h | ||
| ChunkContentionMatrix | FContentionMatrix | MassProcessingQueue.h | ||
| CommandBufferPool | TArray< TSharedPtr< FMassCommandBuffer > > | MassProcessingQueue.h | ||
| CommandBuffersLock | FRWLock | MassProcessingQueue.h | ||
| CompletedProcessorCount | std::atomic< int32 > | MassProcessingQueue.h | ||
| ContentionMatrix | FContentionMatrix | Tracks all global contention | MassProcessingQueue.h | |
| ExecutionChunkHWM | std::atomic< int32 > | MassProcessingQueue.h | ||
| ExecutionConcurrencyHWM | std::atomic< int32 > | MassProcessingQueue.h | ||
| FChunkWorker | friend | MassProcessingQueue.h | ||
| FProcessorWorker | friend | MassProcessingQueue.h | ||
| MainThreadProcessorCount | int32 | MassProcessingQueue.h | ||
| PendingMainThreadProcessorCount | std::atomic< int32 > | MassProcessingQueue.h | ||
| PendingProcessorCount | std::atomic< int32 > | MassProcessingQueue.h | ||
| ProcessorQueue | TArray< FQueuedProcessor > | MassProcessingQueue.h | ||
| Processors | FMassRuntimePipeline | MassProcessingQueue.h | ||
| QueueChangeTracker | std::atomic< uint32 > | MassProcessingQueue.h | ||
| RemainingMainThreadProcessorIndices | TArray< int32 > | Array of indices in ProcessorQueue that still need to execute on the main thread | MassProcessingQueue.h | |
| RemainingProcessorIndices | TArray< int32 > | Array of indices in ProcessorQueue that still need to execute | MassProcessingQueue.h |
Functions
Public
| Name | Remarks | Include Path | Unreal Specifiers |
|---|---|---|---|
void AddProcessor
(
TNotNull< UMassProcessor* > InProcessor |
Add a processor to the queue and resolve dependencies | MassProcessingQueue.h | |
void AddProcessors
(
FMassRuntimePipeline& InPipeline |
Add processors from a pipeline to the queue and resolve dependencies | MassProcessingQueue.h | |
void AddProcessors
(
TConstArrayView< UMassProcessor* > InProcessors |
Add processors to the queue and resolve dependencies | MassProcessingQueue.h | |
void Execute
(
FProcessingContext&& ProcessingContext, |
Immediately execute the processors in the queue | MassProcessingQueue.h | |
void InitQueue() |
Immediately execute the processors in the queue | MassProcessingQueue.h | |
void SetProcessors
(
TConstArrayView< UMassProcessor* > InProcessors |
Clear the processing queue and re-initialize with the provided array | MassProcessingQueue.h |