#include <macrotaskq.h>

Inheritance diagram for madness::MacroTaskQ:

[legend]

Collaboration diagram for madness::MacroTaskQ:

[legend]

Public Member Functions
	MacroTaskQ (const MacroTaskQFactory factory)
	create an empty taskq and initialize the subworlds

	~MacroTaskQ ()

void	add_tasks (MacroTaskBase::taskqT &vtask)

nlohmann::json	get_cloud_statistics () const

long	get_nsubworld () const

MacroTaskInfo	get_policy () const

World &	get_subworld ()

nlohmann::json	get_taskq_statistics () const

void	print_taskq () const

void	run_all ()
	run all tasks

void	set_printlevel (const long p)

Public Member Functions inherited from madness::WorldObject< MacroTaskQ >
	WorldObject (const WorldObject &other)

	WorldObject (World &world)
	Constructor that associates an object (via the derived class) with a globally unique ID.

virtual	~WorldObject ()

World &	get_world () const
	Returns a reference to the `world`.

const uniqueidT &	id () const
	Returns the globally unique object ID.

WorldObject &	operator= (const WorldObject &)=delete

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7, const a8T &a8) const

detail::task_result_type< memfnT >::futureT	send (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7, const a8T &a8, const a9T &a9) const

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7, const a8T &a8, const a9T &a9, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4,a5,a6,a7,a8,a9)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7, const a8T &a8, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4,a5,a6,a7,a8)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const a7T &a7, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4,a5,a6,a7)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const a6T &a6, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4,a5,a6)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const a5T &a5, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4,a5)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const a4T &a4, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3,a4)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const a3T &a3, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2,a3)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const a2T &a2, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1,a2)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const a1T &a1, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)(a1)`.

detail::task_result_type< memfnT >::futureT	task (ProcessID dest, memfnT memfn, const TaskAttributes &attr=TaskAttributes()) const
	Sends task to derived class method `returnT (this->*memfn)()`.

Public Member Functions inherited from madness::WorldObjectBase
virtual	~WorldObjectBase ()=default

Static Public Member Functions
static std::shared_ptr< World >	create_worlds (World &universe, const std::size_t nsubworld)

static void	set_pmap (World &world)

Public Attributes
madness::Cloud	cloud

Private Member Functions
void	add_replicated_task (const std::shared_ptr< MacroTaskBase > &task)

long	get_scheduled_task_number (World &subworld)
	scheduler is located on universe.rank==0

long	get_scheduled_task_number_local ()

bool	printdebug () const

bool	printprogress () const

bool	printtimings () const

bool	printtimings_detail () const

void	set_complete (const long task_number) const
	scheduler is located on rank==0

void	set_complete_local (const long task_number) const
	scheduler is located on rank==0

std::size_t	size () const

Private Attributes
nlohmann::json	cloud_statistics
	save cloud statistics after run_all()

long	nsubworld =1

std::shared_ptr< WorldDCPmapInterface< Key< 1 > > >	pmap1
	set the process map for the subworld

std::shared_ptr< WorldDCPmapInterface< Key< 2 > > >	pmap2

std::shared_ptr< WorldDCPmapInterface< Key< 3 > > >	pmap3

std::shared_ptr< WorldDCPmapInterface< Key< 4 > > >	pmap4

std::shared_ptr< WorldDCPmapInterface< Key< 5 > > >	pmap5

std::shared_ptr< WorldDCPmapInterface< Key< 6 > > >	pmap6

const MacroTaskInfo	policy
	storage and distribution policy

long	printlevel =0

std::shared_ptr< World >	subworld_ptr

MacroTaskBase::taskqT	taskq

std::mutex	taskq_mutex

nlohmann::json	taskq_statistics
	save taskq statistics after run_all()

World &	universe

Additional Inherited Members
Public Types inherited from madness::WorldObject< MacroTaskQ >
typedef WorldObject< MacroTaskQ >	objT

Protected Member Functions inherited from madness::WorldObject< MacroTaskQ >
void	process_pending ()
	To be called from derived constructor to process pending messages.

Constructor & Destructor Documentation

◆ MacroTaskQ()

madness::MacroTaskQ::MacroTaskQ ( const MacroTaskQFactory factory )

inlineexplicit

create an empty taskq and initialize the subworlds

References madness::MacroTaskInfo::check_consistency(), cloud, madness::MacroTaskInfo::cloud_distribution_policy, create_worlds(), MADNESS_CHECK_THROW, nsubworld, policy, madness::print(), printdebug(), madness::WorldObject< MacroTaskQ >::process_pending(), madness::Cloud::set_replication_policy(), madness::Cloud::set_storing_policy(), madness::MacroTaskInfo::storage_policy, subworld_ptr, madness::MacroTaskInfo::to_cloud_storage_policy(), and universe.

◆ ~MacroTaskQ()

madness::MacroTaskQ::~MacroTaskQ ( )

inline

Member Function Documentation

◆ add_replicated_task()

void madness::MacroTaskQ::add_replicated_task ( const std::shared_ptr< MacroTaskBase > & task )

inlineprivate

References madness::WorldObject< MacroTaskQ >::task(), and taskq.

Referenced by add_tasks().

◆ add_tasks()

void madness::MacroTaskQ::add_tasks ( MacroTaskBase::taskqT & vtask )

inline

References add_replicated_task(), madness::World::rank(), and universe.

◆ create_worlds()

static std::shared_ptr< World > madness::MacroTaskQ::create_worlds	(	World &	universe,
		const std::size_t	nsubworld
	)

inlinestatic

for each process create a world using a communicator shared with other processes by round-robin copy-paste from test_world.cc

References madness::WorldMpiInterface::comm(), madness::WorldGopInterface::fence(), madness::World::gop, madness::World::mpi, nsubworld, madness::World::rank(), SafeMPI::Intracomm::Split(), and universe.

Referenced by MacroTaskQ(), main(), simple_example(), test_copy_function_from_other_world(), test_copy_function_from_other_world_through_cloud(), and test_replication_policy().

◆ get_cloud_statistics()

nlohmann::json madness::MacroTaskQ::get_cloud_statistics ( ) const

inline

References cloud_statistics.

◆ get_nsubworld()

long madness::MacroTaskQ::get_nsubworld ( ) const

inline

References nsubworld.

◆ get_policy()

MacroTaskInfo madness::MacroTaskQ::get_policy ( ) const

inline

References policy.

◆ get_scheduled_task_number()

long madness::MacroTaskQ::get_scheduled_task_number ( World & subworld )

inlineprivate

scheduler is located on universe.rank==0

References madness::WorldGopInterface::broadcast_serializable(), madness::WorldGopInterface::fence(), madness::Future< T >::get(), get_scheduled_task_number_local(), madness::World::gop, madness::World::rank(), and madness::WorldObject< MacroTaskQ >::send().

Referenced by run_all().

◆ get_scheduled_task_number_local()

long madness::MacroTaskQ::get_scheduled_task_number_local ( )

inlineprivate

References MADNESS_ASSERT, madness::World::rank(), taskq, taskq_mutex, and universe.

Referenced by get_scheduled_task_number().

◆ get_subworld()

World & madness::MacroTaskQ::get_subworld ( )

inline

References subworld_ptr.

Referenced by run_all().

◆ get_taskq_statistics()

nlohmann::json madness::MacroTaskQ::get_taskq_statistics ( ) const

inline

References taskq_statistics.

◆ print_taskq()

void madness::MacroTaskQ::print_taskq ( ) const

inline

References madness::WorldGopInterface::fence(), madness::World::gop, madness::print(), madness::World::rank(), taskq, and universe.

Referenced by run_all().

◆ printdebug()

bool madness::MacroTaskQ::printdebug ( ) const

inlineprivate

References printlevel.

Referenced by MacroTaskQ(), printprogress(), and run_all().

◆ printprogress()

bool madness::MacroTaskQ::printprogress ( ) const

inlineprivate

References printdebug(), and printlevel.

Referenced by run_all().

◆ printtimings()

bool madness::MacroTaskQ::printtimings ( ) const

inlineprivate

References printlevel, madness::World::rank(), and universe.

◆ printtimings_detail()

bool madness::MacroTaskQ::printtimings_detail ( ) const

inlineprivate

References printlevel, madness::World::rank(), and universe.

Referenced by run_all().

◆ run_all()

void madness::MacroTaskQ::run_all ( )

inline

run all tasks

References madness::Cloud::clear(), madness::Cloud::clear_cache(), cloud, cloud_statistics, madness::cpu_time(), madness::Cloud::distribute_targets(), madness::Distributed, madness::WorldGopInterface::fence(), madness::Cloud::gather_timings(), madness::FunctionDefaults< NDIM >::get_pmap(), madness::Cloud::get_replication_policy(), get_scheduled_task_number(), madness::Cloud::get_statistics(), get_subworld(), madness::World::gop, madness::World::id(), madness::MemoryMeasurer::measure_and_print(), madness::NodeReplicated, pmap1, pmap2, pmap3, pmap4, pmap5, pmap6, policy, madness::print(), madness::Cloud::print_memory_statistics(), madness::Cloud::print_size(), print_taskq(), madness::Cloud::print_timings(), printdebug(), printlevel, printprogress(), printtimings_detail(), madness::MacroTaskInfo::ptr_target_distribution_policy, madness::World::rank(), madness::RankReplicated, madness::Cloud::replicate(), madness::Cloud::replicate_per_node(), set_complete(), madness::WorldGopInterface::set_forbid_fence(), madness::FunctionDefaults< NDIM >::set_pmap(), set_pmap(), madness::World::size(), madness::MacroTaskInfo::storage_policy, madness::MacroTaskInfo::StoreFunction, madness::WorldGopInterface::sum(), madness::Cloud::target_replication_time, madness::WorldObject< MacroTaskQ >::task(), taskq, taskq_statistics, universe, madness::wall_time(), and madness::Cloud::world_object_base_list.

◆ set_complete()

void madness::MacroTaskQ::set_complete ( const long task_number ) const

inlineprivate

scheduler is located on rank==0

References set_complete_local(), and madness::WorldObject< MacroTaskQ >::task().

Referenced by run_all().

◆ set_complete_local()

void madness::MacroTaskQ::set_complete_local ( const long task_number ) const

inlineprivate

scheduler is located on rank==0

References MADNESS_ASSERT, madness::World::rank(), taskq, and universe.

Referenced by set_complete().

◆ set_pmap()

static void madness::MacroTaskQ::set_pmap ( World & world )

inlinestatic

References madness::FunctionDefaults< NDIM >::set_default_pmap(), and madness::WorldObject< MacroTaskQ >::world.

Referenced by main(), run_all(), simple_example(), test_copy_function_from_other_world(), test_copy_function_from_other_world_through_cloud(), test_custom_worldobject(), test_pointer_to_funcimpl(), test_replication_policy(), and test_tuple().

◆ set_printlevel()

void madness::MacroTaskQ::set_printlevel ( const long p )

inline

References p(), and printlevel.

◆ size()

std::size_t madness::MacroTaskQ::size ( ) const

inlineprivate

References taskq.

Member Data Documentation

◆ cloud

madness::Cloud madness::MacroTaskQ::cloud

Referenced by MacroTaskQ(), and run_all().

◆ cloud_statistics

nlohmann::json madness::MacroTaskQ::cloud_statistics

private

save cloud statistics after run_all()

Referenced by get_cloud_statistics(), and run_all().

◆ nsubworld

long madness::MacroTaskQ::nsubworld =1

private

Referenced by MacroTaskQ(), create_worlds(), and get_nsubworld().

◆ pmap1

std::shared_ptr< WorldDCPmapInterface< Key<1> > > madness::MacroTaskQ::pmap1

private

set the process map for the subworld

Referenced by run_all().

◆ pmap2

std::shared_ptr< WorldDCPmapInterface< Key<2> > > madness::MacroTaskQ::pmap2

private

Referenced by run_all().

◆ pmap3

std::shared_ptr< WorldDCPmapInterface< Key<3> > > madness::MacroTaskQ::pmap3

private

Referenced by run_all().

◆ pmap4

std::shared_ptr< WorldDCPmapInterface< Key<4> > > madness::MacroTaskQ::pmap4

private

Referenced by run_all().

◆ pmap5

std::shared_ptr< WorldDCPmapInterface< Key<5> > > madness::MacroTaskQ::pmap5

private

Referenced by run_all().

◆ pmap6

std::shared_ptr< WorldDCPmapInterface< Key<6> > > madness::MacroTaskQ::pmap6

private

Referenced by run_all().

◆ policy

const MacroTaskInfo madness::MacroTaskQ::policy

private

storage and distribution policy

Referenced by MacroTaskQ(), get_policy(), and run_all().

◆ printlevel

long madness::MacroTaskQ::printlevel =0

private

Referenced by printdebug(), printprogress(), printtimings(), printtimings_detail(), run_all(), and set_printlevel().

◆ subworld_ptr

std::shared_ptr<World> madness::MacroTaskQ::subworld_ptr

private

Referenced by MacroTaskQ(), and get_subworld().

◆ taskq

MacroTaskBase::taskqT madness::MacroTaskQ::taskq

private

Referenced by add_replicated_task(), get_scheduled_task_number_local(), print_taskq(), run_all(), set_complete_local(), and size().

◆ taskq_mutex

std::mutex madness::MacroTaskQ::taskq_mutex

private

Referenced by get_scheduled_task_number_local().

◆ taskq_statistics

nlohmann::json madness::MacroTaskQ::taskq_statistics

private

save taskq statistics after run_all()

Referenced by get_taskq_statistics(), and run_all().

◆ universe

World& madness::MacroTaskQ::universe

private

Referenced by MacroTaskQ(), add_tasks(), create_worlds(), get_scheduled_task_number_local(), print_taskq(), printtimings(), printtimings_detail(), run_all(), and set_complete_local().

The documentation for this class was generated from the following file:

macrotaskq.h

Public Member Functions

Static Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ MacroTaskQ()

◆ ~MacroTaskQ()

Member Function Documentation

◆ add_replicated_task()

◆ add_tasks()

◆ create_worlds()

◆ get_cloud_statistics()

◆ get_nsubworld()

◆ get_policy()

◆ get_scheduled_task_number()

◆ get_scheduled_task_number_local()

◆ get_subworld()

◆ get_taskq_statistics()

◆ print_taskq()

◆ printdebug()

◆ printprogress()

◆ printtimings()

◆ printtimings_detail()

◆ run_all()

◆ set_complete()

◆ set_complete_local()

◆ set_pmap()

◆ set_printlevel()

◆ size()

Member Data Documentation

◆ cloud

◆ cloud_statistics

◆ nsubworld

◆ pmap1

◆ pmap2

◆ pmap3

◆ pmap4

◆ pmap5

◆ pmap6

◆ policy

◆ printlevel

◆ subworld_ptr

◆ taskq

◆ taskq_mutex

◆ taskq_statistics

◆ universe