Method Do

libs/base/base_tests/threaded_list_test.cpp:24–37

  {}

  virtual void Do()
  {
    while (!m_p.IsCancelled())
    {
      int res = m_p.Front(true /* doPop */);
      {
        std::lock_guard<std::mutex> resGuard(m_resMutex);
        m_res.push_back(res);
      }
      LOG(LINFO, (m_id, " thread got ", res));
      threads::Sleep(10);
    }
    LOG(LINFO, (m_id, " thread is cancelled"));
  }
};

UNIT_TEST(ThreadedList)