When oneDNN is built with the threadpool CPU runtime (see Build Options), oneDNN requires a user to implement a threadpool interface to enable the library to perform computations using multiple threads.
The threadpool interface is defined in include/dnnl_threadpool_iface.hpp
. Below is a sample implementation based on Eigen threadpool that is also used for testing (see tests/testing_threadpool.hpp
).
#include "dnnl_threadpool_iface.hpp"
private:
std::unique_ptr<Eigen::ThreadPool> tp_;
public:
explicit threadpool(int num_threads = 0) {
if (num_threads <= 0)
num_threads = (int)std::thread::hardware_concurrency();
tp_.reset(new Eigen::ThreadPool(num_threads));
}
return tp_->CurrentThreadId() != -1;
}
int n, const std::function<void(int, int)> &fn) override {
for (int i = 0; i < n; i++)
tp_->Schedule([i, n, fn]() { fn(i, n); });
}
};