threadManager_OpenMP.h

Go to the documentation of this file.

#ifndef THREADMANAGER_OPENMP_INCLUDED
#define THREADMANAGER_OPENMP_INCLUDED

#include <string>

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



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

  // buffer size for global reduction
#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(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