File d'exécution pour accélérateur. Plus de détails...

#include </__w/arcaneframework.github.io/arcaneframework.github.io/framework/arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h>

Graphe de collaboration de Arcane::Accelerator::impl::RunQueueImpl:

Classes
class	Lock
	Verrou pour le pool de RunCommand en multi-thread. Plus de détails...

Fonctions membres publiques
	RunQueueImpl (const RunQueueImpl &)=delete

	RunQueueImpl (RunQueueImpl &&)=delete

RunQueueImpl &	operator= (const RunQueueImpl &)=delete

RunQueueImpl &	operator= (RunQueueImpl &&)=delete

eExecutionPolicy	executionPolicy () const

RunnerImpl *	runner () const

MemoryAllocationOptions	allocationOptions () const

bool	isAutoPrefetchCommand () const

void	copyMemory (const MemoryCopyArgs &args) const

void	prefetchMemory (const MemoryPrefetchArgs &args) const

void	recordEvent (RunQueueEvent &event)

void	waitEvent (RunQueueEvent &event)

void	setConcurrentCommandCreation (bool v)

bool	isConcurrentCommandCreation () const

void	dumpStats (std::ostream &ostr) const

bool	isAsync () const

void	_internalBarrier ()
	Bloque jusqu'à ce que toutes les commandes soient terminées.

IRunnerRuntime *	_internalRuntime () const

IRunQueueStream *	_internalStream () const

void	addRef ()

void	removeRef ()

Fonctions membres publiques statiques
static RunQueueImpl *	create (RunnerImpl *r, const RunQueueBuildInfo &bi)

static RunQueueImpl *	create (RunnerImpl *r)

Fonctions membres privées
	RunQueueImpl (RunnerImpl *runner_impl, Int32 id, const RunQueueBuildInfo &bi)

RunCommandImpl *	_internalCreateOrGetRunCommandImpl ()

void	_internalFreeRunningCommands ()
	Libère les commandes en cours d'exécution.

bool	_isInPool () const

void	_release ()

void	_setDefaultMemoryRessource ()

void	_addRunningCommand (RunCommandImpl *p)

void	_putInCommandPool (RunCommandImpl *p)

void	_freeCommandsInPool ()

void	_checkPutCommandInPoolNoLock (RunCommandImpl *p)
	Remet la commande dans le pool si possible.

Fonctions membres privées statiques
static RunQueueImpl *	_reset (RunQueueImpl *p)
	Réinitialise l'implémentation.

static void	_destroy (RunQueueImpl *q)

Attributs privés
RunnerImpl *	m_runner_impl = nullptr

eExecutionPolicy	m_execution_policy = eExecutionPolicy::None

IRunnerRuntime *	m_runtime = nullptr

IRunQueueStream *	m_queue_stream = nullptr

std::stack< RunCommandImpl * >	m_run_command_pool
	Pool de commandes.

UniqueArray< RunCommandImpl * >	m_active_run_command_list
	Liste des commandes en cours d'exécution.

Int32	m_id = 0
	Identifiant de la file.

bool	m_is_in_pool = false
	Indique si l'instance est dans un pool d'instance.

std::atomic< Int32 >	m_nb_ref = 0
	Nombre de références sur l'instance.

bool	m_is_async = false
	Indique si la file est asynchrone.

eMemoryResource	m_memory_ressource = eMemoryResource::Unknown
	Ressource mémoire par défaut.

std::unique_ptr< std::mutex >	m_pool_mutex

bool	m_use_pool_mutex = false

Amis
class	Arcane::Accelerator::Runner

class	Arcane::Accelerator::RunQueue

class	RunCommandImpl

class	RunQueueImplStack

class	RunnerImpl

Description détaillée

File d'exécution pour accélérateur.

Cette classe gère l'implémentation d'une RunQueue. La description des méthodes se trouve dans RunQueue.

Définition à la ligne 40 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

Documentation des constructeurs et destructeur

◆ RunQueueImpl()

Arcane::Accelerator::impl::RunQueueImpl::RunQueueImpl	(	RunnerImpl *	runner_impl,
		Int32	id,
		const RunQueueBuildInfo &	bi )

private

Définition à la ligne 71 du fichier RunQueueImpl.cc.

◆ ~RunQueueImpl()

Arcane::Accelerator::impl::RunQueueImpl::~RunQueueImpl ( )

private

Définition à la ligne 84 du fichier RunQueueImpl.cc.

Documentation des fonctions membres

◆ _addRunningCommand()

void Arcane::Accelerator::impl::RunQueueImpl::_addRunningCommand ( RunCommandImpl * p )

private

Définition à la ligne 326 du fichier RunQueueImpl.cc.

◆ _checkPutCommandInPoolNoLock()

void Arcane::Accelerator::impl::RunQueueImpl::_checkPutCommandInPoolNoLock ( RunCommandImpl * p )

private

Remet la commande dans le pool si possible.

On ne remet pas la commande dans le pool tant qu'il y a une RunCommand qui y fait référence. Dans ce cas la commande sera remise dans le pool lors de l'appel au destructeur de RunCommand. Cela est nécessaire pour gérer le cas où une RunCommand est créée mais n'est jamais utilisée car dans ce cas elle ne sera jamais dans m_active_run_command_list et ne sera pas traitée lors de l'appel à _internalFreeRunningCommands().

Définition à la ligne 314 du fichier RunQueueImpl.cc.

Références Arcane::Accelerator::impl::RunCommandImpl::m_has_living_run_command, Arcane::Accelerator::impl::RunCommandImpl::m_may_be_put_in_pool, et m_run_command_pool.

Référencé par _internalFreeRunningCommands().

Voici le graphe des appelants de cette fonction :

◆ _destroy()

void Arcane::Accelerator::impl::RunQueueImpl::_destroy ( RunQueueImpl * q )

staticprivate

Définition à la ligne 116 du fichier RunQueueImpl.cc.

◆ _freeCommandsInPool()

void Arcane::Accelerator::impl::RunQueueImpl::_freeCommandsInPool ( )

private

Définition à la ligne 96 du fichier RunQueueImpl.cc.

◆ _internalBarrier()

void Arcane::Accelerator::impl::RunQueueImpl::_internalBarrier ( )

Bloque jusqu'à ce que toutes les commandes soient terminées.

Définition à la ligne 348 du fichier RunQueueImpl.cc.

Références _internalFreeRunningCommands().

Voici le graphe d'appel pour cette fonction :

◆ _internalCreateOrGetRunCommandImpl()

RunCommandImpl * Arcane::Accelerator::impl::RunQueueImpl::_internalCreateOrGetRunCommandImpl ( )

private

Définition à la ligne 242 du fichier RunQueueImpl.cc.

◆ _internalFreeRunningCommands()

void Arcane::Accelerator::impl::RunQueueImpl::_internalFreeRunningCommands ( )

private

Libère les commandes en cours d'exécution.

Cette méthode est en général appelée après une barrière ce qui garantit que les commandes asynchrones sont terminées.

Définition à la ligne 269 du fichier RunQueueImpl.cc.

Références _checkPutCommandInPoolNoLock(), Arcane::Array< DataType >::add(), et m_active_run_command_list.

Référencé par _internalBarrier().

Voici le graphe d'appel pour cette fonction :

Voici le graphe des appelants de cette fonction :

◆ _internalRuntime()

IRunnerRuntime * Arcane::Accelerator::impl::RunQueueImpl::_internalRuntime ( ) const

inline

Définition à la ligne 91 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ _internalStream()

IRunQueueStream * Arcane::Accelerator::impl::RunQueueImpl::_internalStream ( ) const

inline

Définition à la ligne 92 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ _isInPool()

bool Arcane::Accelerator::impl::RunQueueImpl::_isInPool ( ) const

inlineprivate

Définition à la ligne 111 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ _putInCommandPool()

void Arcane::Accelerator::impl::RunQueueImpl::_putInCommandPool ( RunCommandImpl * p )

private

Définition à la ligne 336 du fichier RunQueueImpl.cc.

◆ _release()

void Arcane::Accelerator::impl::RunQueueImpl::_release ( )

private

Définition à la ligne 129 du fichier RunQueueImpl.cc.

◆ _reset()

RunQueueImpl * Arcane::Accelerator::impl::RunQueueImpl::_reset ( RunQueueImpl * p )

staticprivate

Réinitialise l'implémentation.

Cette méthode est appelée lorsqu'on va initialiser une RunQueue avec cette instance. Il faut dans ce cas réinitialiser les valeurs de l'instance qui dépendent de l'état actuel.

Définition à la ligne 364 du fichier RunQueueImpl.cc.

Références m_is_async.

◆ _setDefaultMemoryRessource()

void Arcane::Accelerator::impl::RunQueueImpl::_setDefaultMemoryRessource ( )

private

Définition à la ligne 154 du fichier RunQueueImpl.cc.

◆ addRef()

void Arcane::Accelerator::impl::RunQueueImpl::addRef ( )

inline

Définition à la ligne 96 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ allocationOptions()

MemoryAllocationOptions Arcane::Accelerator::impl::RunQueueImpl::allocationOptions ( ) const

Définition à la ligne 165 du fichier RunQueueImpl.cc.

◆ copyMemory()

void Arcane::Accelerator::impl::RunQueueImpl::copyMemory ( const MemoryCopyArgs & args ) const

Définition à la ligne 186 du fichier RunQueueImpl.cc.

◆ create() [1/2]

RunQueueImpl * Arcane::Accelerator::impl::RunQueueImpl::create ( RunnerImpl * r )

static

Définition à la ligne 224 du fichier RunQueueImpl.cc.

◆ create() [2/2]

RunQueueImpl * Arcane::Accelerator::impl::RunQueueImpl::create	(	RunnerImpl *	r,
		const RunQueueBuildInfo &	bi )

static

Définition à la ligne 233 du fichier RunQueueImpl.cc.

◆ dumpStats()

void Arcane::Accelerator::impl::RunQueueImpl::dumpStats ( std::ostream & ostr ) const

Définition à la ligne 386 du fichier RunQueueImpl.cc.

◆ executionPolicy()

eExecutionPolicy Arcane::Accelerator::impl::RunQueueImpl::executionPolicy ( ) const

inline

Définition à la ligne 73 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ isAsync()

bool Arcane::Accelerator::impl::RunQueueImpl::isAsync ( ) const

inline

Définition à la ligne 88 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ isAutoPrefetchCommand()

bool Arcane::Accelerator::impl::RunQueueImpl::isAutoPrefetchCommand ( ) const

Définition à la ligne 177 du fichier RunQueueImpl.cc.

◆ isConcurrentCommandCreation()

bool Arcane::Accelerator::impl::RunQueueImpl::isConcurrentCommandCreation ( ) const

inline

Définition à la ligne 85 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ prefetchMemory()

void Arcane::Accelerator::impl::RunQueueImpl::prefetchMemory ( const MemoryPrefetchArgs & args ) const

Définition à la ligne 195 du fichier RunQueueImpl.cc.

◆ recordEvent()

void Arcane::Accelerator::impl::RunQueueImpl::recordEvent ( RunQueueEvent & event )

Définition à la ligne 204 du fichier RunQueueImpl.cc.

◆ removeRef()

void Arcane::Accelerator::impl::RunQueueImpl::removeRef ( )

inline

Définition à la ligne 100 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ runner()

RunnerImpl * Arcane::Accelerator::impl::RunQueueImpl::runner ( ) const

inline

Définition à la ligne 74 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ setConcurrentCommandCreation()

void Arcane::Accelerator::impl::RunQueueImpl::setConcurrentCommandCreation ( bool v )

Définition à la ligne 375 du fichier RunQueueImpl.cc.

◆ waitEvent()

void Arcane::Accelerator::impl::RunQueueImpl::waitEvent ( RunQueueEvent & event )

Définition à la ligne 214 du fichier RunQueueImpl.cc.

Documentation des fonctions amies et associées

◆ Arcane::Accelerator::Runner

friend class Arcane::Accelerator::Runner

friend

Définition à la ligne 42 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ Arcane::Accelerator::RunQueue

friend class Arcane::Accelerator::RunQueue

friend

Définition à la ligne 43 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ RunCommandImpl

friend class RunCommandImpl

friend

Définition à la ligne 44 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ RunnerImpl

friend class RunnerImpl

friend

Définition à la ligne 46 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ RunQueueImplStack

friend class RunQueueImplStack

friend

Définition à la ligne 45 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

Documentation des données membres

◆ m_active_run_command_list

UniqueArray<RunCommandImpl*> Arcane::Accelerator::impl::RunQueueImpl::m_active_run_command_list

private

Liste des commandes en cours d'exécution.

Définition à la ligne 130 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

Référencé par _internalFreeRunningCommands().

◆ m_execution_policy

eExecutionPolicy Arcane::Accelerator::impl::RunQueueImpl::m_execution_policy = eExecutionPolicy::None

private

Définition à la ligne 124 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_id

Int32 Arcane::Accelerator::impl::RunQueueImpl::m_id = 0

private

Identifiant de la file.

Définition à la ligne 132 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_is_async

bool Arcane::Accelerator::impl::RunQueueImpl::m_is_async = false

private

Indique si la file est asynchrone.

Définition à la ligne 138 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

Référencé par _reset().

◆ m_is_in_pool

bool Arcane::Accelerator::impl::RunQueueImpl::m_is_in_pool = false

private

Indique si l'instance est dans un pool d'instance.

Définition à la ligne 134 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_memory_ressource

eMemoryResource Arcane::Accelerator::impl::RunQueueImpl::m_memory_ressource = eMemoryResource::Unknown

private

Ressource mémoire par défaut.

Définition à la ligne 140 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_nb_ref

std::atomic<Int32> Arcane::Accelerator::impl::RunQueueImpl::m_nb_ref = 0

private

Nombre de références sur l'instance.

Définition à la ligne 136 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_pool_mutex

std::unique_ptr<std::mutex> Arcane::Accelerator::impl::RunQueueImpl::m_pool_mutex

private

Définition à la ligne 143 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_queue_stream

IRunQueueStream* Arcane::Accelerator::impl::RunQueueImpl::m_queue_stream = nullptr

private

Définition à la ligne 126 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_run_command_pool

std::stack<RunCommandImpl*> Arcane::Accelerator::impl::RunQueueImpl::m_run_command_pool

private

Pool de commandes.

Définition à la ligne 128 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

Référencé par _checkPutCommandInPoolNoLock().

◆ m_runner_impl

RunnerImpl* Arcane::Accelerator::impl::RunQueueImpl::m_runner_impl = nullptr

private

Définition à la ligne 123 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_runtime

IRunnerRuntime* Arcane::Accelerator::impl::RunQueueImpl::m_runtime = nullptr

private

Définition à la ligne 125 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

◆ m_use_pool_mutex

bool Arcane::Accelerator::impl::RunQueueImpl::m_use_pool_mutex = false

private

Définition à la ligne 144 du fichier arccore/src/common/arccore/common/accelerator/internal/RunQueueImpl.h.

La documentation de cette classe a été générée à partir des fichiers suivants :

Classes

Fonctions membres publiques

Fonctions membres publiques statiques

Fonctions membres privées

Fonctions membres privées statiques

Attributs privés

Amis

Description détaillée

Documentation des constructeurs et destructeur

◆ RunQueueImpl()

◆ ~RunQueueImpl()

Documentation des fonctions membres

◆ _addRunningCommand()

◆ _checkPutCommandInPoolNoLock()

◆ _destroy()

◆ _freeCommandsInPool()

◆ _internalBarrier()

◆ _internalCreateOrGetRunCommandImpl()

◆ _internalFreeRunningCommands()

◆ _internalRuntime()

◆ _internalStream()

◆ _isInPool()

◆ _putInCommandPool()

◆ _release()

◆ _reset()

◆ _setDefaultMemoryRessource()

◆ addRef()

◆ allocationOptions()

◆ copyMemory()

◆ create() [1/2]

◆ create() [2/2]

◆ dumpStats()

◆ executionPolicy()

◆ isAsync()

◆ isAutoPrefetchCommand()

◆ isConcurrentCommandCreation()

◆ prefetchMemory()

◆ recordEvent()

◆ removeRef()

◆ runner()

◆ setConcurrentCommandCreation()

◆ waitEvent()

Documentation des fonctions amies et associées

◆ Arcane::Accelerator::Runner

◆ Arcane::Accelerator::RunQueue

◆ RunCommandImpl

◆ RunnerImpl

◆ RunQueueImplStack

Documentation des données membres

◆ m_active_run_command_list

◆ m_execution_policy

◆ m_id

◆ m_is_async

◆ m_is_in_pool

◆ m_memory_ressource

◆ m_nb_ref

◆ m_pool_mutex

◆ m_queue_stream

◆ m_run_command_pool

◆ m_runner_impl

◆ m_runtime

◆ m_use_pool_mutex