threadManager.h

Go to the documentation of this file.

 
#ifndef THREADMANAGER_INCLUDED
#define THREADMANAGER_INCLUDED
 
#include <string>
 
#include "Parameters/commonParameters.h"
#include "IO/bridgeIO.h"
 
 
 
class ThreadManager {
 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(const ThreadManager&);
  ThreadManager& operator=(const ThreadManager&);
 
 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 reduce_max_global(double *value, const int num,
                                const int i_thread, const int Nthread);
 
  static void reduce_max_global(double& value,
                                const int i_thread, const int Nthread);
 
  static void assert_single_thread(const std::string& class_name);
};
 
 
//typedef ThreadManager_OpenMP ThreadManager;
typedef ThreadManager ThreadManager_OpenMP;
 
 
#endif //THREADMANAGER_INCLUDED