parallelize.hpp

Go to the documentation of this file.

#ifndef TATAMI_PARALLELIZE_HPP
#define TATAMI_PARALLELIZE_HPP
 
#include <vector>
#include <cmath>
 
#ifndef TATAMI_CUSTOM_PARALLEL
#include "subpar/subpar.hpp"
#endif
 
namespace tatami {
 
template<bool parallel_ = true, class Function_, typename Index_>
int parallelize(Function_ fun, const Index_ tasks, const int workers) {
    if constexpr(parallel_) {
#ifdef TATAMI_CUSTOM_PARALLEL
        return TATAMI_CUSTOM_PARALLEL(fun, tasks, workers);
#else
        return subpar::parallelize_range(workers, tasks, std::move(fun));
#endif
    } else {
        fun(0, 0, tasks);
        return 1;
    }
}
 
}
 
#endif