Fabrique pour les tâches. Plus de détails...

#include <arcane/utils/ConcurrencyUtils.h>

Graphe de collaboration de Arcane::TaskFactory:

Fonctions membres publiques statiques
template<typename InstanceType >
static ITask *	createTask (InstanceType instance, void(InstanceType::function)(const TaskContext &tc))
	Créé une tâche. Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

template<typename InstanceType >
static ITask *	createTask (InstanceType instance, void(InstanceType::function)())
	Créé une tâche. Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

template<typename InstanceType >
static ITask *	createChildTask (ITask parent_task, InstanceType instance, void(InstanceType::*function)(const TaskContext &tc))
	Créé une tâche fille.

template<typename InstanceType >
static ITask *	createChildTask (ITask parent_task, InstanceType instance, void(InstanceType::*function)())
	Créé une tâche fille.

static void	executeParallelFor (Integer begin, Integer size, const ParallelLoopOptions &options, IRangeFunctor *f)
	Exécute le fonctor f en concurrence.

static void	executeParallelFor (Integer begin, Integer size, Integer block_size, IRangeFunctor *f)
	Exécute le fonctor f en concurrence.

static void	executeParallelFor (Integer begin, Integer size, IRangeFunctor *f)
	Exécute le fonctor f en concurrence.

static void	executeParallelFor (const ParallelFor1DLoopInfo &loop_info)
	Exécute la boucle loop_info en concurrence.

static void	executeParallelFor (const ComplexForLoopRanges< 1 > &loop_ranges, const ParallelLoopOptions &options, IMDRangeFunctor< 1 > *functor)
	Exécute une boucle simple.

static void	executeParallelFor (const ComplexForLoopRanges< 2 > &loop_ranges, const ParallelLoopOptions &options, IMDRangeFunctor< 2 > *functor)
	Exécute une boucle 2D.

static void	executeParallelFor (const ComplexForLoopRanges< 3 > &loop_ranges, const ParallelLoopOptions &options, IMDRangeFunctor< 3 > *functor)
	Exécute une boucle 3D.

static void	executeParallelFor (const ComplexForLoopRanges< 4 > &loop_ranges, const ParallelLoopOptions &options, IMDRangeFunctor< 4 > *functor)
	Exécute une boucle 4D.

static Int32	nbAllowedThread ()
	Nombre de threads utilisés au maximum pour gérer les tâches.

static Int32	currentTaskThreadIndex ()
	Indice (entre 0 et nbAllowedThread()-1) du thread exécutant la tâche actuelle.

static Int32	currentTaskIndex ()
	Indice (entre 0 et nbAllowedThread()-1) de la tâche actuelle.

static void	setDefaultParallelLoopOptions (const ParallelLoopOptions &v)
	Positionne les valeurs par défaut d'exécution d'une boucle parallèle.

static const ParallelLoopOptions &	defaultParallelLoopOptions ()
	Valeurs par défaut d'exécution d'une boucle parallèle.

static bool	isActive ()
	Indique si les tâches sont actives. Les tâches sont actives si une implémentation est disponible et si le nombre de threads demandé est strictement supérieur à 1.

static void	printInfos (std::ostream &o)
	Affiche les informations sur l'implémentation.

static IObservable *	createThreadObservable ()
	Observable appelé lors de la création d'un thread pour une tâche.

static IObservable *	destroyThreadObservable ()
	Observable appelé lors de la destruction d'un thread pour une tâche.

static void	terminate ()

static void	setVerboseLevel (Integer v)
	Positionne le niveau de verbosité (0 pour pas d'affichage qui est le défaut)

static Integer	verboseLevel ()
	Niveau de verbosité

static void	_internalSetImplementation (ITaskImplementation *task_impl)

Description détaillée

Fabrique pour les tâches.

Définition à la ligne 274 du fichier ConcurrencyUtils.h.

Documentation des fonctions membres

◆ _internalSetImplementation()

void Arcane::TaskFactory::_internalSetImplementation ( ITaskImplementation * task_impl )

static

Définition à la ligne 166 du fichier ConcurrencyUtils.cc.

◆ createChildTask() [1/2]

template<typename InstanceType >

static ITask * Arcane::TaskFactory::createChildTask	(	ITask *	parent_task,
		InstanceType *	instance,
		void(InstanceType::*)()	function
	)

inlinestatic

Créé une tâche fille.

Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

Définition à la ligne 326 du fichier ConcurrencyUtils.h.

Références ARCANE_CHECK_POINTER.

◆ createChildTask() [2/2]

template<typename InstanceType >

static ITask * Arcane::TaskFactory::createChildTask	(	ITask *	parent_task,
		InstanceType *	instance,
		void(InstanceType::*)(const TaskContext &tc)	function
	)

inlinestatic

Créé une tâche fille.

Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

Définition à la ligne 312 du fichier ConcurrencyUtils.h.

Références ARCANE_CHECK_POINTER.

◆ createTask() [1/2]

template<typename InstanceType >

static ITask * Arcane::TaskFactory::createTask	(	InstanceType *	instance,
		void(InstanceType::*)()	function
	)

inlinestatic

Créé une tâche. Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

Définition à la ligne 299 du fichier ConcurrencyUtils.h.

◆ createTask() [2/2]

template<typename InstanceType >

static ITask * Arcane::TaskFactory::createTask	(	InstanceType *	instance,
		void(InstanceType::*)(const TaskContext &tc)	function
	)

inlinestatic

Créé une tâche. Lors de l'exécution, la tâche appellera la méthode function via l'instance instance.

Définition à la ligne 287 du fichier ConcurrencyUtils.h.

◆ createThreadObservable()

IObservable * Arcane::TaskFactory::createThreadObservable ( )

static

Observable appelé lors de la création d'un thread pour une tâche.

Avertissement: L'instance de l'observable est créée lors du premier appel à cette méthode. Elle n'est donc pas thread-safe. De même, la modification de l'observable (ajout/suppression d'observateur) n'est pas thread-safe.

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

◆ currentTaskIndex()

static Int32 Arcane::TaskFactory::currentTaskIndex ( )

inlinestatic

Indice (entre 0 et nbAllowedThread()-1) de la tâche actuelle.

Cet indice est le même que currentTaskThreadIndex() sauf dans le cas où on se trouve dans un executeParallelFor() avec un partitionnement déterministe (ParallelLoopOptions::Partitioner::Deterministic). Dans ce dernier cas, le numéro de la tâche est assigné de manière déterministe qui ne dépend que du nombre de threads alloués pour la tâche et de ParallelLoopOptions::grainSize().

Si le thread courant n'exécute pas une tâche associé à cette implémentation, retourne (-1).

Définition à la ligne 420 du fichier ConcurrencyUtils.h.

◆ currentTaskThreadIndex()

static Int32 Arcane::TaskFactory::currentTaskThreadIndex ( )

inlinestatic

Indice (entre 0 et nbAllowedThread()-1) du thread exécutant la tâche actuelle.

Pour des raisons de performance, il est préférable d'appeler cette méthode le moins possible. L'idéal est de ne le faire qu'au début de l'exécution de la tâche et ensuite d'utiliser la valeur retournée.

Définition à la ligne 402 du fichier ConcurrencyUtils.h.

◆ defaultParallelLoopOptions()

static const ParallelLoopOptions & Arcane::TaskFactory::defaultParallelLoopOptions ( )

inlinestatic

Valeurs par défaut d'exécution d'une boucle parallèle.

Définition à la ligne 434 du fichier ConcurrencyUtils.h.

Référencé par Arcane::arcaneParallelForeach(), et Arcane::arcaneParallelForeach().

◆ destroyThreadObservable()

IObservable * Arcane::TaskFactory::destroyThreadObservable ( )

static

Observable appelé lors de la destruction d'un thread pour une tâche.

Avertissement: L'instance de l'observable est créée lors du premier appel à cette méthode. Elle n'est donc pas thread-safe. De même, la modification de l'observable (ajout/suppression d'observateur) n'est pas thread-safe.

Définition à la ligne 188 du fichier ConcurrencyUtils.cc.

◆ executeParallelFor() [1/8]

static void Arcane::TaskFactory::executeParallelFor	(	const ComplexForLoopRanges< 1 > &	loop_ranges,
		const ParallelLoopOptions &	options,
		IMDRangeFunctor< 1 > *	functor
	)

inlinestatic

Exécute une boucle simple.

Définition à la ligne 358 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [2/8]

static void Arcane::TaskFactory::executeParallelFor	(	const ComplexForLoopRanges< 2 > &	loop_ranges,
		const ParallelLoopOptions &	options,
		IMDRangeFunctor< 2 > *	functor
	)

inlinestatic

Exécute une boucle 2D.

Définition à la ligne 366 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [3/8]

static void Arcane::TaskFactory::executeParallelFor	(	const ComplexForLoopRanges< 3 > &	loop_ranges,
		const ParallelLoopOptions &	options,
		IMDRangeFunctor< 3 > *	functor
	)

inlinestatic

Exécute une boucle 3D.

Définition à la ligne 374 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [4/8]

static void Arcane::TaskFactory::executeParallelFor	(	const ComplexForLoopRanges< 4 > &	loop_ranges,
		const ParallelLoopOptions &	options,
		IMDRangeFunctor< 4 > *	functor
	)

inlinestatic

Exécute une boucle 4D.

Définition à la ligne 382 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [5/8]

static void Arcane::TaskFactory::executeParallelFor ( const ParallelFor1DLoopInfo & loop_info )

inlinestatic

Exécute la boucle loop_info en concurrence.

Définition à la ligne 352 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [6/8]

static void Arcane::TaskFactory::executeParallelFor	(	Integer	begin,
		Integer	size,
		const ParallelLoopOptions &	options,
		IRangeFunctor *	f
	)

inlinestatic

Exécute le fonctor f en concurrence.

Définition à la ligne 334 du fichier ConcurrencyUtils.h.

Référencé par Arcane::arcaneParallelFor(), Arcane::arcaneParallelFor(), Arcane::arcaneParallelFor(), Arcane::arcaneParallelFor(), Arcane::arcaneParallelForeach(), Arcane::arcaneParallelForeach(), Arcane::arcaneParallelForVa(), Arcane::Parallel::For(), Arcane::Parallel::For(), Arcane::Parallel::For(), Arcane::Parallel::For(), Arcane::Parallel::For(), Arcane::Parallel::For(), Arcane::Parallel::Foreach(), Arcane::Parallel::Foreach(), Arcane::Parallel::Foreach(), et Arcane::Parallel::Foreach().

◆ executeParallelFor() [7/8]

static void Arcane::TaskFactory::executeParallelFor	(	Integer	begin,
		Integer	size,
		Integer	block_size,
		IRangeFunctor *	f
	)

inlinestatic

Exécute le fonctor f en concurrence.

Définition à la ligne 340 du fichier ConcurrencyUtils.h.

◆ executeParallelFor() [8/8]

static void Arcane::TaskFactory::executeParallelFor	(	Integer	begin,
		Integer	size,
		IRangeFunctor *	f
	)

inlinestatic

Exécute le fonctor f en concurrence.

Définition à la ligne 346 du fichier ConcurrencyUtils.h.

◆ isActive()

static bool Arcane::TaskFactory::isActive ( )

inlinestatic

Indique si les tâches sont actives. Les tâches sont actives si une implémentation est disponible et si le nombre de threads demandé est strictement supérieur à 1.

Définition à la ligne 446 du fichier ConcurrencyUtils.h.

Référencé par Arcane::Accelerator::AcceleratorRuntimeInitialisationInfo::executionPolicy().

◆ nbAllowedThread()

static Int32 Arcane::TaskFactory::nbAllowedThread ( )

inlinestatic

Nombre de threads utilisés au maximum pour gérer les tâches.

Définition à la ligne 390 du fichier ConcurrencyUtils.h.

◆ printInfos()

static void Arcane::TaskFactory::printInfos ( std::ostream & o )

inlinestatic

Affiche les informations sur l'implémentation.

Les informations sont par exemple le numéro de version ou le nom de l'implémentation.

Définition à la ligne 457 du fichier ConcurrencyUtils.h.

◆ setDefaultParallelLoopOptions()

static void Arcane::TaskFactory::setDefaultParallelLoopOptions ( const ParallelLoopOptions & v )

inlinestatic

Positionne les valeurs par défaut d'exécution d'une boucle parallèle.

Définition à la ligne 428 du fichier ConcurrencyUtils.h.

Référencé par Arcane::ArcaneLauncher::init().

◆ setVerboseLevel()

static void Arcane::TaskFactory::setVerboseLevel ( Integer v )

inlinestatic

Positionne le niveau de verbosité (0 pour pas d'affichage qui est le défaut)

Définition à la ligne 492 du fichier ConcurrencyUtils.h.

◆ terminate()

void Arcane::TaskFactory::terminate ( )

static

Définition à la ligne 199 du fichier ConcurrencyUtils.cc.

◆ verboseLevel()

static Integer Arcane::TaskFactory::verboseLevel ( )

inlinestatic

Niveau de verbosité

Définition à la ligne 495 du fichier ConcurrencyUtils.h.

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

Fonctions membres publiques statiques

Description détaillée

Documentation des fonctions membres

◆ _internalSetImplementation()

◆ createChildTask() [1/2]

◆ createChildTask() [2/2]

◆ createTask() [1/2]

◆ createTask() [2/2]

◆ createThreadObservable()

◆ currentTaskIndex()

◆ currentTaskThreadIndex()

◆ defaultParallelLoopOptions()

◆ destroyThreadObservable()

◆ executeParallelFor() [1/8]

◆ executeParallelFor() [2/8]

◆ executeParallelFor() [3/8]

◆ executeParallelFor() [4/8]

◆ executeParallelFor() [5/8]

◆ executeParallelFor() [6/8]

◆ executeParallelFor() [7/8]

◆ executeParallelFor() [8/8]

◆ isActive()

◆ nbAllowedThread()

◆ printInfos()

◆ setDefaultParallelLoopOptions()

◆ setVerboseLevel()

◆ terminate()

◆ verboseLevel()