FProcessingQueue

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,
TFunction< void()> OnDoneNotification,
ENamedThreads::Type CurrentThread,
TFunction< void()> OnPreCommandFlushNotification
)

 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  

Ask questions and help your peers Developer Forums

Write your own tutorials or read those from others Learning Library

On this page