lasp_thread.cpp

Go to the documentation of this file.

/* #define DEBUGTRACE_ENABLED */
#include "lasp_thread.h"
#include "BS_thread_pool.hpp"
#include "debugtrace.hpp"
#include <memory>
 
std::weak_ptr<BS::thread_pool> _global_weak_pool;
 
std::mutex _mtx;
 
using Lck = std::scoped_lock<std::mutex>;
using rte = std::runtime_error;
 
GlobalThreadPool::GlobalThreadPool() {
  DEBUGTRACE_ENTER;
  Lck lck(_mtx);
  _pool = _global_weak_pool.lock();
  if (!_pool) {
    _pool = std::make_shared<BS::thread_pool>();
    if (!_pool) {
      throw rte("Fatal: could not allocate thread pool!");
    }
    // Update global weak pointer
    _global_weak_pool = _pool;
  }
}