Thread manager with OpenMP. More...

#include <threadManager_OpenMP.h>

Static Public Member Functions
static void	init (int Nthread)
	setup: called in main only once. More...

static void	finalize ()
	finalization. More...

static int	get_num_threads_available ()
	returns number of threads (works outside of parallel region). More...

static int	get_num_threads ()
	returns available number of threads. More...

static int	get_thread_id ()
	returns thread id. More...

static void	wait ()
	barrier among threads inside a node. More...

static void	barrier (const int Nthread)
	barrier among threads inside a node. More...

static void	sync_barrier_all ()
	barrier among all the threads and nodes. More...

static void	reduce_sum_global (dcomplex &value, const int i_thread, const int Nthread)
	global reduction with summation: dcomplex values are assumed thread local. More...

static void	reduce_sum_global (dcomplex *value, const int num, const int i_thread, const int Nthread)
	global reduction with summation for an array: dcomplex values are assumed thread local. More...

static void	reduce_sum_global (double &value, const int i_thread, const int Nthread)
	global reduction with summation: double values are assumed thread local. More...

static void	reduce_sum_global (double *value, const int num, const int i_thread, const int Nthread)
	global reduction with summation for an array: double values are assumed thread local. More...

static void	reduce_sum_global (float &value, const int i_thread, const int Nthread)
	global reduction with summation: float values are assumed thread local. More...

static void	reduce_sum_global (float *value, const int num, const int i_thread, const int Nthread)
	global reduction with summation for an array: float values are assumed thread local. More...

static void	assert_single_thread (const std::string &class_name)
	assert currently running on single thread. More...

Static Public Attributes
static const std::string	class_name = "ThreadManager_OpenMP"

Private Member Functions
	ThreadManager_OpenMP (const ThreadManager_OpenMP &)

ThreadManager_OpenMP &	operator= (const ThreadManager_OpenMP &)

Static Private Attributes
static int	m_Nthread = 0
	number of threads. More...

static Bridge::VerboseLevel	m_vl = Bridge::CRUCIAL
	verbose level. More...

static std::vector< dcomplex >	m_darray_reductionDC

static std::vector< double >	m_darray_reduction

static std::vector< float >	m_darray_reductionF

static const int	each_buf_sizeDC = 16
	reduction buffer size for each thread (dcomplex) More...

static const int	each_buf_size = 8
	reduction buffer size for each thread (double) More...

static const int	each_buf_sizeF = 2 * each_buf_size
	reduction buffer size for each thread (float) More...

Detailed Description

Thread manager with OpenMP.

This class wraps OpenMP API functions. The number of available threads is specified as an argument of init() function, which is to be called at the begining of main, soon after Communicator and CommonParameter are initialized. If the specified number of threads (nthread) is not the same as that of OMP_NUM_THREADS environment variable, the number of threads is set to the specified one. If Nthread = 0 is specified, the number of threads is set to OMP_NUM_THREADS or maximum number of platform. [29 Aug 2013 H.Matsufuru]

Added reduce_sum_global for array [30 Sep 2019 I.Kanamori] Add complex args [08 Aug 2020 Y.Namekawa]

Definition at line 42 of file threadManager_OpenMP.h.

Constructor & Destructor Documentation

ThreadManager_OpenMP::ThreadManager_OpenMP ( const ThreadManager_OpenMP & )

private

Member Function Documentation

void ThreadManager_OpenMP::assert_single_thread ( const std::string & class_name )

static

assert currently running on single thread.

Definition at line 270 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::barrier ( const int Nthread )

static

barrier among threads inside a node.

Definition at line 188 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::finalize ( )

static

finalization.

Definition at line 158 of file threadManager_OpenMP.cpp.

int ThreadManager_OpenMP::get_num_threads ( )

static

returns available number of threads.

Definition at line 165 of file threadManager_OpenMP.cpp.

static int ThreadManager_OpenMP::get_num_threads_available ( )

inlinestatic

returns number of threads (works outside of parallel region).

Definition at line 84 of file threadManager_OpenMP.h.

int ThreadManager_OpenMP::get_thread_id ( )

static

returns thread id.

Definition at line 172 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::init ( int Nthread )

static

setup: called in main only once.

Definition at line 121 of file threadManager_OpenMP.cpp.

ThreadManager_OpenMP& ThreadManager_OpenMP::operator= ( const ThreadManager_OpenMP & )

private

void ThreadManager_OpenMP::reduce_sum_global	(	dcomplex &	value,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation: dcomplex values are assumed thread local.

Definition at line 207 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::reduce_sum_global	(	dcomplex *	value,
		const int	num,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation for an array: dcomplex values are assumed thread local.

Definition at line 217 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::reduce_sum_global	(	double &	value,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation: double values are assumed thread local.

Definition at line 228 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::reduce_sum_global	(	double *	value,
		const int	num,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation for an array: double values are assumed thread local.

Definition at line 238 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::reduce_sum_global	(	float &	value,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation: float values are assumed thread local.

Definition at line 249 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::reduce_sum_global	(	float *	value,
		const int	num,
		const int	i_thread,
		const int	Nthread
	)

static

global reduction with summation for an array: float values are assumed thread local.

Definition at line 259 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::sync_barrier_all ( )

static

barrier among all the threads and nodes.

Definition at line 195 of file threadManager_OpenMP.cpp.

void ThreadManager_OpenMP::wait ( )

static

barrier among threads inside a node.

Definition at line 179 of file threadManager_OpenMP.cpp.

Member Data Documentation

const std::string ThreadManager_OpenMP::class_name = "ThreadManager_OpenMP"

static

Definition at line 75 of file threadManager_OpenMP.h.

const int ThreadManager_OpenMP::each_buf_size = 8

staticprivate

reduction buffer size for each thread (double)

Definition at line 60 of file threadManager_OpenMP.h.

const int ThreadManager_OpenMP::each_buf_sizeDC = 16

staticprivate

reduction buffer size for each thread (dcomplex)

Definition at line 54 of file threadManager_OpenMP.h.

const int ThreadManager_OpenMP::each_buf_sizeF = 2 * each_buf_size

staticprivate

reduction buffer size for each thread (float)

Definition at line 66 of file threadManager_OpenMP.h.

std::vector< double > ThreadManager_OpenMP::m_darray_reduction

staticprivate

Definition at line 47 of file threadManager_OpenMP.h.

std::vector< dcomplex > ThreadManager_OpenMP::m_darray_reductionDC

staticprivate

Definition at line 46 of file threadManager_OpenMP.h.

std::vector< float > ThreadManager_OpenMP::m_darray_reductionF

staticprivate

Definition at line 48 of file threadManager_OpenMP.h.

int ThreadManager_OpenMP::m_Nthread = 0

staticprivate

number of threads.

Definition at line 44 of file threadManager_OpenMP.h.

Bridge::VerboseLevel ThreadManager_OpenMP::m_vl = Bridge::CRUCIAL

staticprivate

verbose level.

Definition at line 45 of file threadManager_OpenMP.h.

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

src/lib/ResourceManager/threadManager_OpenMP.h
src/lib/ResourceManager/OpenMP/threadManager_OpenMP.cpp

Static Public Member Functions

Static Public Attributes

Private Member Functions

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation