1 #ifndef OPENPOSE_PRODUCER_W_DATUM_PRODUCER_HPP
2 #define OPENPOSE_PRODUCER_W_DATUM_PRODUCER_HPP
12 template<
typename TDatums,
typename TDatumsNoPtr>
23 std::shared_ptr<DatumProducer<TDatumsNoPtr>> spDatumProducer;
24 std::queue<TDatums> mQueuedElements;
38 template<
typename TDatums,
typename TDatumsNoPtr>
40 spDatumProducer{datumProducer}
44 template<
typename TDatums,
typename TDatumsNoPtr>
49 template<
typename TDatums,
typename TDatumsNoPtr>
59 std::shared_ptr<TDatumsNoPtr> tDatums;
61 if (mQueuedElements.empty())
64 std::tie(isRunning, tDatums) = spDatumProducer->checkIfRunningAndGetDatum();
76 if (tDatums !=
nullptr && tDatums->size() > 1)
79 for (
auto i = 0u ; i < tDatums->size() ; i++)
81 auto& tDatum = (*tDatums)[i];
83 tDatum.subIdMax = tDatums->size()-1;
84 mQueuedElements.emplace(
85 std::make_shared<TDatumsNoPtr>(TDatumsNoPtr{tDatum}));
89 if (!mQueuedElements.empty())
91 tDatums = mQueuedElements.front();
92 mQueuedElements.pop();
97 catch (
const std::exception& e)
100 error(e.what(), __LINE__, __FUNCTION__, __FILE__);
108 #endif // OPENPOSE_PRODUCER_W_DATUM_PRODUCER_HPP
void initializationOnThread()
Definition: wDatumProducer.hpp:45
static const std::string timerInit(const int line, const std::string &function, const std::string &file)
OP_API void error(const std::string &message, const int line=-1, const std::string &function="", const std::string &file="")
WDatumProducer(const std::shared_ptr< DatumProducer< TDatumsNoPtr >> &datumProducer)
Definition: wDatumProducer.hpp:39
Definition: workerProducer.hpp:10
void dLog(const T &message, const Priority priority=Priority::Max, const int line=-1, const std::string &function="", const std::string &file="")
Definition: errorAndLog.hpp:53
Definition: datumProducer.hpp:14
static void printAveragedTimeMsOnIterationX(const std::string &key, const int line, const std::string &function, const std::string &file, const unsigned long long x=DEFAULT_X)
static void timerEnd(const std::string &key)
Definition: wDatumProducer.hpp:13
TDatums workProducer()
Definition: wDatumProducer.hpp:50