RKNNManager.cpp 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. #include "RKNNManager.h"
  2. #include "PPYOLOE.hpp"
  3. #include "../DataManager/DataManager.h"
  4. #include "../DataManager/DataPackage.h"
  5. // Image test
  6. #include "../ImageTest/ImageTest.h"
  7. void RKNNManager::addRknnTask(std::string modelData)
  8. {
  9. m_threads.emplace_back(&RKNNManager::taskThread, this, modelData);
  10. m_threads.emplace_back(&RKNNManager::taskThread, this, modelData);
  11. m_threads.emplace_back(&RKNNManager::taskThread, this, modelData);
  12. }
  13. void RKNNManager::taskThread(std::string modelpath)
  14. {
  15. PPYOLOE infer;
  16. if (!infer.initialize(modelpath))
  17. {
  18. std::cerr << "initialize rknn infer failed" << std::endl;
  19. return;
  20. }
  21. m_threadSwitch = true;
  22. int index = infer.get_index();
  23. DataPackagePtr dataPackage;
  24. std::string pipeName = "rknn" + std::to_string(index);
  25. DataManager::getInstance().addDataPipe<DataPackage>(pipeName);
  26. //time test
  27. ImageTest::saveImageFromData
  28. while (m_threadSwitch)
  29. {
  30. if (DataManager::getInstance().popData("resized" + std::to_string(index), dataPackage))
  31. {
  32. infer.infer(index, (unsigned char *)dataPackage->pResizeData, dataPackage->nResizeWidth, dataPackage->nResizeHeight);
  33. continue;
  34. }
  35. std::this_thread::sleep_for(std::chrono::milliseconds(20));
  36. }
  37. }