serialize.hpp

Go to the documentation of this file.

#ifndef TATAMI_HDF5_SERIALIZE_HPP
#define TATAMI_HDF5_SERIALIZE_HPP
 
#ifndef TATAMI_HDF5_PARALLEL_LOCK
#include "subpar/subpar.hpp"
#ifndef SUBPAR_USES_OPENMP_RANGE
#include <mutex>
#include <thread>
 
namespace tatami_hdf5 {
// We put this in a separate function instead of a static function variable
// inside serialize(), as we would get a different mutex for each instance 
// of serialize() created with a different Function_.
inline auto& get_default_hdf5_lock() {
    static std::mutex hdf5_lock;
    return hdf5_lock;
}
}
#endif
#endif
 
namespace tatami_hdf5 {
 
template<class Function_>
void serialize(Function_ f) {
#ifdef TATAMI_HDF5_PARALLEL_LOCK
    TATAMI_HDF5_PARALLEL_LOCK(f);
#else
#ifdef SUBPAR_USES_OPENMP_RANGE
    #pragma omp critical(hdf5)
    {
        f();
    }
#else
    auto& h5lock = get_default_hdf5_lock();
    std::lock_guard<std::mutex> thing(h5lock);
    f();
#endif
#endif
}
 
}
 
#endif