AtomThread.cpp ファイル

#include "Atom/AtomThread.h"
#include "Async/Async.h"
#include "Containers/SpscQueue.h"
#include "Containers/Ticker.h"
#include "Engine/Engine.h"
#include "Engine/World.h"
#include "ProfilingDebugging/CsvProfiler.h"
#include "Tasks/Pipe.h"
#include "CriWareLLM.h"
#include "CriWareCore.h"
#include "Atom/Atom.h"

クラス
struct	FAtomAsyncBatcher
struct	FAtomThreadInteractor

関数
static FAutoConsoleCommand	AtomThreadPriorityConsoleCommand (TEXT("AtomThread.TaskPriority"), TEXT("Takes a single parameter of value `High`, `Normal`, `BackgroundHigh`, `BackgroundNormal` or `BackgroundLow`."), FConsoleCommandWithArgsDelegate::CreateStatic(&SetAtomTaskPriority))
FAutoConsoleVariableRef	CVarAboveNormalAtomThreadPri (TEXT("AtomThread.AboveNormalPriority"), GCVarAboveNormalAtomThreadPri, TEXT("0=Normal, 1=AboveNormal"), ECVF_Default)
FAutoConsoleVariableRef	CVarAtomCommandFenceWaitTimeMs (TEXT("AtomCommand.FenceWaitTimeMs"), GAtomCommandFenceWaitTimeMs, TEXT("Sets number of ms for fence wait"), ECVF_Default)
static FAutoConsoleVariableRef	CVarBatchAtomAsyncBatchSize (TEXT("AtomThread.BatchAsyncBatchSize"), GBatchAtomAsyncBatchSize,)
FAutoConsoleVariableRef	CVarEnableAtomBatchProcessing (TEXT("AtomThread.EnableBatchProcessing"), GCVarEnableAtomBatchProcessing, TEXT("0: Not Enabled, 1: Enabled"), ECVF_Default)
FAutoConsoleVariableRef	CVarEnableAtomCommandLogging (TEXT("AtomThread.EnableAtomCommandLogging"), GCVarEnableAtomCommandLogging, TEXT("0=Disabled, 1=Enabled"), ECVF_Default)
FAutoConsoleVariableRef	CVarSuspendAtomThread (TEXT("AtomThread.SuspendAtomThread"), GCVarSuspendAtomThread, TEXT("0=Resume, 1=Suspend"), ECVF_Cheat)
static FAutoConsoleVariableSink	CVarUseAtomThreadSink (FConsoleCommandDelegate::CreateStatic(&FAtomThreadInteractor::UseAtomThreadCVarSinkFunction))
static void	SetAtomTaskPriority (const TArray< FString > &Args)

変数
static FAtomAsyncBatcher	GAtomAsyncBatcher
static int32	GAtomCommandFenceWaitTimeMs = 35
CRIWARECORE_API UE::Tasks::FPipe	GAtomPipe
UE::Tasks::ETaskPriority	GAtomTaskPriority = UE::Tasks::ETaskPriority::Normal
static int32	GBatchAtomAsyncBatchSize = 128
static int32	GCVarAboveNormalAtomThreadPri = 0
static int32	GCVarEnableAtomBatchProcessing = 1
static int32	GCVarEnableAtomCommandLogging = 0
static int32	GCVarSuspendAtomThread = 0
CRIWARECORE_API std::atomic< bool >	GIsAtomThreadRunning
CRIWARECORE_API std::atomic< bool >	GIsAtomThreadSuspended

関数詳解

AtomThreadPriorityConsoleCommand()

FAutoConsoleCommand AtomThreadPriorityConsoleCommand ( TEXT("AtomThread.TaskPriority") , TEXT("Takes a single parameter of value `High`, `Normal`, `BackgroundHigh`, `BackgroundNormal` or `BackgroundLow`.") , FConsoleCommandWithArgsDelegate::CreateStatic & SetAtomTaskPriority )

static

CVarAboveNormalAtomThreadPri()

FAutoConsoleVariableRef CVarAboveNormalAtomThreadPri	(	TEXT("AtomThread.AboveNormalPriority")	,
		GCVarAboveNormalAtomThreadPri	,
		TEXT("0=Normal, 1=AboveNormal")	,
		ECVF_Default	)

CVarAtomCommandFenceWaitTimeMs()

FAutoConsoleVariableRef CVarAtomCommandFenceWaitTimeMs	(	TEXT("AtomCommand.FenceWaitTimeMs")	,
		GAtomCommandFenceWaitTimeMs	,
		TEXT("Sets number of ms for fence wait")	,
		ECVF_Default	)

CVarBatchAtomAsyncBatchSize()

FAutoConsoleVariableRef CVarBatchAtomAsyncBatchSize ( TEXT("AtomThread.BatchAsyncBatchSize") , GBatchAtomAsyncBatchSize  )

static

CVarEnableAtomBatchProcessing()

FAutoConsoleVariableRef CVarEnableAtomBatchProcessing	(	TEXT("AtomThread.EnableBatchProcessing")	,
		GCVarEnableAtomBatchProcessing	,
		TEXT("0: Not Enabled, 1: Enabled")	,
		ECVF_Default	)

CVarEnableAtomCommandLogging()

FAutoConsoleVariableRef CVarEnableAtomCommandLogging	(	TEXT("AtomThread.EnableAtomCommandLogging")	,
		GCVarEnableAtomCommandLogging	,
		TEXT("0=Disabled, 1=Enabled")	,
		ECVF_Default	)

CVarSuspendAtomThread()

FAutoConsoleVariableRef CVarSuspendAtomThread	(	TEXT("AtomThread.SuspendAtomThread")	,
		GCVarSuspendAtomThread	,
		TEXT("0=Resume, 1=Suspend")	,
		ECVF_Cheat	)

CVarUseAtomThreadSink()

FAutoConsoleVariableSink CVarUseAtomThreadSink ( FConsoleCommandDelegate::CreateStatic &::UseAtomThreadCVarSinkFunction )

static

SetAtomTaskPriority()

void SetAtomTaskPriority ( const TArray< FString > & Args )

static

変数詳解

GAtomAsyncBatcher

FAtomAsyncBatcher GAtomAsyncBatcher

static

GAtomCommandFenceWaitTimeMs

int32 GAtomCommandFenceWaitTimeMs = 35

static

GAtomPipe

CRIWARECORE_API UE::Tasks::FPipe GAtomPipe

extern

GAtomTaskPriority

UE::Tasks::ETaskPriority GAtomTaskPriority = UE::Tasks::ETaskPriority::Normal

GBatchAtomAsyncBatchSize

int32 GBatchAtomAsyncBatchSize = 128

static

GCVarAboveNormalAtomThreadPri

int32 GCVarAboveNormalAtomThreadPri = 0

static

GCVarEnableAtomBatchProcessing

int32 GCVarEnableAtomBatchProcessing = 1

static

GCVarEnableAtomCommandLogging

int32 GCVarEnableAtomCommandLogging = 0

static

GCVarSuspendAtomThread

int32 GCVarSuspendAtomThread = 0

static

GIsAtomThreadRunning

CRIWARECORE_API std::atomic<bool> GIsAtomThreadRunning

extern

GIsAtomThreadSuspended

CRIWARECORE_API std::atomic<bool> GIsAtomThreadSuspended

extern