Graphe d'héritage de Arcane::TBBTaskImplementation:

Graphe de collaboration de Arcane::TBBTaskImplementation:

Classes
class	MDParallelForExecute
class	TaskInfoLockGuard
	Classe pour positionner TaskThreadInfo::taskIndex(). Plus de détails...
class	Impl
class	ParallelForExecute

Fonctions membres publiques
class	ARCCORE_ALIGNAS_PACKED (64) TaskThreadInfo
void	build ()
void	initialize (Int32 nb_thread) override
void	terminate () override
ITask *	createRootTask (ITaskFunctor *f) override
	Créé une tâche racine. L'implémentation doit recopier la valeur de f qui est soit un TaskFunctor, soit un TaskFunctorWithContext.
void	executeParallelFor (Int32 begin, Int32 size, const ParallelLoopOptions &options, IRangeFunctor *f) final
	Exécute le fonctor f en concurrence.
void	executeParallelFor (Int32 begin, Int32 size, Integer grain_size, IRangeFunctor *f) final
	Exécute le fonctor f en concurrence.
void	executeParallelFor (Int32 begin, Int32 size, IRangeFunctor *f) final
	Exécute le fonctor f en concurrence.
void	executeParallelFor (const ParallelFor1DLoopInfo &loop_info) override
	Exécute la boucle loop_info en concurrence.
void	executeParallelFor (const ComplexForLoopRanges< 1 > &loop_ranges, const ForLoopRunInfo &run_info, IMDRangeFunctor< 1 > *functor) final
	Exécute une boucle 1D en concurrence.
void	executeParallelFor (const ComplexForLoopRanges< 2 > &loop_ranges, const ForLoopRunInfo &run_info, IMDRangeFunctor< 2 > *functor) final
	Exécute une boucle 2D en concurrence.
void	executeParallelFor (const ComplexForLoopRanges< 3 > &loop_ranges, const ForLoopRunInfo &run_info, IMDRangeFunctor< 3 > *functor) final
	Exécute une boucle 3D en concurrence.
void	executeParallelFor (const ComplexForLoopRanges< 4 > &loop_ranges, const ForLoopRunInfo &run_info, IMDRangeFunctor< 4 > *functor) final
	Exécute une boucle 4D en concurrence.
bool	isActive () const final
	Indique si l'implémentation est active.
Int32	currentTaskThreadIndex () const final
	Implémentation de TaskFactory::currentTaskThreadIndex().
Int32	currentTaskIndex () const final
	Implémentation de TaskFactory::currentTaskIndex().
void	printInfos (std::ostream &o) const final
	Affiche les informations sur le runtime utilisé
TaskThreadInfo *	currentTaskThreadInfo () const
	Instance de TaskThreadInfo associé au thread courant.
Fonctions membres publiques hérités de Arcane::ITaskImplementation
Int32	nbAllowedThread () const
	Nombre de threads utilisés au maximum pour gérer les tâches.

Fonctions membres privées
template<int RankValue>
void	_executeMDParallelFor (const ComplexForLoopRanges< RankValue > &loop_ranges, IMDRangeFunctor< RankValue > *functor, const ForLoopRunInfo &run_info)
	Exécution d'une boucle N-dimensions.
void	_executeParallelFor (const ParallelFor1DLoopInfo &loop_info)

Attributs privés
bool	m_is_active = false
Impl *	m_p = nullptr

Description détaillée

Définition à la ligne 344 du fichier TBBTaskImplementation.cc.

Documentation des constructeurs et destructeur

◆ ~TBBTaskImplementation()

Arcane::TBBTaskImplementation::~TBBTaskImplementation ( )

override

Définition à la ligne 1038 du fichier TBBTaskImplementation.cc.

Documentation des fonctions membres

◆ _executeMDParallelFor()

template<int RankValue>

void Arcane::TBBTaskImplementation::_executeMDParallelFor	(	const ComplexForLoopRanges< RankValue > &	loop_ranges,
		IMDRangeFunctor< RankValue > *	functor,
		const ForLoopRunInfo &	run_info )

private

Exécution d'une boucle N-dimensions.

Avertissement: L'implémentation actuelle ne tient pas compte de options pour les boucles autres que une dimension.

Définition à la ligne 1149 du fichier TBBTaskImplementation.cc.

Références Arcane::TaskFactory::defaultParallelLoopOptions(), Arcane::ParallelLoopOptions::grainSize(), Arcane::makeLoopRanges(), Arcane::ParallelLoopOptions::maxThread(), Arcane::ParallelLoopOptions::mergeUnsetValues(), et Arcane::TaskFactory::verboseLevel().

Référencé par executeParallelFor(), executeParallelFor(), executeParallelFor(), et executeParallelFor().

Voici le graphe d'appel pour cette fonction :

Voici le graphe des appelants de cette fonction :

◆ _executeParallelFor()

void Arcane::TBBTaskImplementation::_executeParallelFor ( const ParallelFor1DLoopInfo & loop_info )

private

Définition à la ligne 1086 du fichier TBBTaskImplementation.cc.

◆ ARCCORE_ALIGNAS_PACKED()

class Arcane::TBBTaskImplementation::ARCCORE_ALIGNAS_PACKED ( 64 )

inline

Définition à la ligne 332 du fichier TBBTaskImplementation.cc.

◆ build()

void Arcane::TBBTaskImplementation::build ( )

inline

Définition à la ligne 413 du fichier TBBTaskImplementation.cc.

◆ createRootTask()

ITask * Arcane::TBBTaskImplementation::createRootTask ( ITaskFunctor * f )

inlineoverridevirtual

Créé une tâche racine. L'implémentation doit recopier la valeur de f qui est soit un TaskFunctor, soit un TaskFunctorWithContext.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 417 du fichier TBBTaskImplementation.cc.

◆ currentTaskIndex()

Int32 Arcane::TBBTaskImplementation::currentTaskIndex ( ) const

finalvirtual

Implémentation de TaskFactory::currentTaskIndex().

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1246 du fichier TBBTaskImplementation.cc.

Références currentTaskThreadIndex(), et currentTaskThreadInfo().

Voici le graphe d'appel pour cette fonction :

◆ currentTaskThreadIndex()

Int32 Arcane::TBBTaskImplementation::currentTaskThreadIndex ( ) const

inlinefinalvirtual

Implémentation de TaskFactory::currentTaskThreadIndex().

Implémente Arcane::ITaskImplementation.

Définition à la ligne 461 du fichier TBBTaskImplementation.cc.

Références Arcane::ITaskImplementation::nbAllowedThread().

Référencé par currentTaskIndex(), et currentTaskThreadInfo().

Voici le graphe d'appel pour cette fonction :

Voici le graphe des appelants de cette fonction :

◆ currentTaskThreadInfo()

TBBTaskImplementation::TaskThreadInfo * Arcane::TBBTaskImplementation::currentTaskThreadInfo ( ) const

Instance de TaskThreadInfo associé au thread courant.

Peut-être nul si le thread courant n'est pas associé à un thread TBB ou si en dehors d'une exécution d'une tâche ou d'une boucle parallèle.

Définition à la ligne 1234 du fichier TBBTaskImplementation.cc.

Références currentTaskThreadIndex().

Référencé par currentTaskIndex().

Voici le graphe d'appel pour cette fonction :

Voici le graphe des appelants de cette fonction :

◆ executeParallelFor() [1/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	const ComplexForLoopRanges< 1 > &	loop_ranges,
		const ForLoopRunInfo &	run_info,
		IMDRangeFunctor< 1 > *	functor )

inlinefinalvirtual

Exécute une boucle 1D en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 431 du fichier TBBTaskImplementation.cc.

Références _executeMDParallelFor().

Voici le graphe d'appel pour cette fonction :

◆ executeParallelFor() [2/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	const ComplexForLoopRanges< 2 > &	loop_ranges,
		const ForLoopRunInfo &	run_info,
		IMDRangeFunctor< 2 > *	functor )

inlinefinalvirtual

Exécute une boucle 2D en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 437 du fichier TBBTaskImplementation.cc.

Références _executeMDParallelFor().

Voici le graphe d'appel pour cette fonction :

◆ executeParallelFor() [3/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	const ComplexForLoopRanges< 3 > &	loop_ranges,
		const ForLoopRunInfo &	run_info,
		IMDRangeFunctor< 3 > *	functor )

inlinefinalvirtual

Exécute une boucle 3D en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 443 du fichier TBBTaskImplementation.cc.

Références _executeMDParallelFor().

Voici le graphe d'appel pour cette fonction :

◆ executeParallelFor() [4/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	const ComplexForLoopRanges< 4 > &	loop_ranges,
		const ForLoopRunInfo &	run_info,
		IMDRangeFunctor< 4 > *	functor )

inlinefinalvirtual

Exécute une boucle 4D en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 449 du fichier TBBTaskImplementation.cc.

Références _executeMDParallelFor().

Voici le graphe d'appel pour cette fonction :

◆ executeParallelFor() [5/8]

void Arcane::TBBTaskImplementation::executeParallelFor ( const ParallelFor1DLoopInfo & loop_info )

overridevirtual

Exécute la boucle loop_info en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1134 du fichier TBBTaskImplementation.cc.

◆ executeParallelFor() [6/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	Int32	begin,
		Int32	size,
		const ParallelLoopOptions &	options,
		IRangeFunctor *	f )

finalvirtual

Exécute le fonctor f en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1225 du fichier TBBTaskImplementation.cc.

Références executeParallelFor().

Référencé par executeParallelFor(), executeParallelFor(), et executeParallelFor().

Voici le graphe d'appel pour cette fonction :

Voici le graphe des appelants de cette fonction :

◆ executeParallelFor() [7/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	Int32	begin,
		Int32	size,
		Integer	block_size,
		IRangeFunctor *	f )

finalvirtual

Exécute le fonctor f en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1213 du fichier TBBTaskImplementation.cc.

Références Arcane::TaskFactory::defaultParallelLoopOptions(), executeParallelFor(), et Arcane::ParallelLoopOptions::setGrainSize().

Voici le graphe d'appel pour cette fonction :

◆ executeParallelFor() [8/8]

void Arcane::TBBTaskImplementation::executeParallelFor	(	Int32	begin,
		Int32	size,
		IRangeFunctor *	f )

inlinefinalvirtual

Exécute le fonctor f en concurrence.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 425 du fichier TBBTaskImplementation.cc.

Références Arcane::TaskFactory::defaultParallelLoopOptions(), et executeParallelFor().

Voici le graphe d'appel pour cette fonction :

◆ initialize()

void Arcane::TBBTaskImplementation::initialize ( Int32 nb_thread )

overridevirtual

. Initialise l'implémentation avec au maximum nb_thread. Si nb_thread vaut 0, l'implémentation peut choisir le nombre de thread automatiquement. Cette méthode est interne à Arcane et ne doit être appelée que lors de l'initialisation de l'exécution.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1047 du fichier TBBTaskImplementation.cc.

Références Arcane::TaskFactory::defaultParallelLoopOptions(), Arcane::ITaskImplementation::nbAllowedThread(), Arcane::TaskFactory::setDefaultParallelLoopOptions(), et Arcane::ParallelLoopOptions::setMaxThread().

Voici le graphe d'appel pour cette fonction :

◆ isActive()

bool Arcane::TBBTaskImplementation::isActive ( ) const

inlinefinalvirtual

Indique si l'implémentation est active.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 456 du fichier TBBTaskImplementation.cc.

◆ printInfos()

void Arcane::TBBTaskImplementation::printInfos ( std::ostream & o ) const

finalvirtual

Affiche les informations sur le runtime utilisé

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1074 du fichier TBBTaskImplementation.cc.

◆ terminate()

void Arcane::TBBTaskImplementation::terminate ( )

overridevirtual

. Termine l'utilisation de l'implémentation. Cette méthode doit être appelée en fin de calcul uniquement.

Implémente Arcane::ITaskImplementation.

Définition à la ligne 1065 du fichier TBBTaskImplementation.cc.

Documentation des données membres

◆ m_is_active

bool Arcane::TBBTaskImplementation::m_is_active = false

private

Définition à la ligne 482 du fichier TBBTaskImplementation.cc.

◆ m_p

Impl* Arcane::TBBTaskImplementation::m_p = nullptr

private

Définition à la ligne 483 du fichier TBBTaskImplementation.cc.

La documentation de cette classe a été générée à partir du fichier suivant :

TBBTaskImplementation.cc

Classes

Fonctions membres publiques

Fonctions membres privées

Attributs privés

Description détaillée

Documentation des constructeurs et destructeur

◆ ~TBBTaskImplementation()

Documentation des fonctions membres

◆ _executeMDParallelFor()

◆ _executeParallelFor()

◆ ARCCORE_ALIGNAS_PACKED()

◆ build()

◆ createRootTask()

◆ currentTaskIndex()

◆ currentTaskThreadIndex()

◆ currentTaskThreadInfo()

◆ executeParallelFor() [1/8]

◆ executeParallelFor() [2/8]

◆ executeParallelFor() [3/8]

◆ executeParallelFor() [4/8]

◆ executeParallelFor() [5/8]

◆ executeParallelFor() [6/8]

◆ executeParallelFor() [7/8]

◆ executeParallelFor() [8/8]

◆ initialize()

◆ isActive()

◆ printInfos()

◆ terminate()

Documentation des données membres

◆ m_is_active

◆ m_p