threadManager_OpenMP.h

Go to the documentation of this file.

#ifndef THREADMANAGER_OPENMP_INCLUDED
#define THREADMANAGER_OPENMP_INCLUDED

#include <string>

#include "Parameters/commonParameters.h"
#include "IO/bridgeIO.h"



class ThreadManager_OpenMP {
 private:
  static int m_Nthread;              
  static Bridge::VerboseLevel m_vl;  
  static std::vector<dcomplex> m_darray_reductionDC;
  static std::vector<double> m_darray_reduction;
  static std::vector<float> m_darray_reductionF;

  // buffer size for global reduction
#ifdef REDUCTION_EACH_BUF_SIZE_DC
  static const int each_buf_size = REDUCTION_EACH_BUF_SIZE_DC; 
#else
  static const int each_buf_sizeDC = 16;                       
#endif

#ifdef REDUCTION_EACH_BUF_SIZE
  static const int each_buf_size = REDUCTION_EACH_BUF_SIZE; 
#else
  static const int each_buf_size = 8;                       
#endif

#ifdef REDUCTION_EACH_BUF_SIZE_F
  static const int each_buf_sizeF = REDUCTION_EACH_BUF_SIZE_F; 
#else
  static const int each_buf_sizeF = 2 * each_buf_size;         
#endif

 private:
  // non-copyable
  ThreadManager_OpenMP(const ThreadManager_OpenMP&);
  ThreadManager_OpenMP& operator=(const ThreadManager_OpenMP&);

 public:
  static const std::string class_name;

  static void init(int Nthread);

  static void finalize();

  static int get_num_threads_available() { return m_Nthread; }

  static int get_num_threads();

  static int get_thread_id();

  static void wait();

  static void barrier(const int Nthread);

  static void sync_barrier_all();

  static void reduce_sum_global(dcomplex& value,
                                const int i_thread, const int Nthread);

  static void reduce_sum_global(dcomplex *value, const int num,
                                const int i_thread, const int Nthread);

  static void reduce_sum_global(double& value,
                                const int i_thread, const int Nthread);

  static void reduce_sum_global(double *value, const int num,
                                const int i_thread, const int Nthread);

  static void reduce_sum_global(float& value,
                                const int i_thread, const int Nthread);

  static void reduce_sum_global(float *value, const int num,
                                const int i_thread, const int Nthread);

  static void assert_single_thread(const std::string& class_name);
};
#endif //THREADMANAGER_OPENMP_INCLUDED