Function UNIT_TEST

libs/base/base_tests/thread_pool_computational_tests.cpp:16–36

}  // namespace

UNIT_TEST(ThreadPoolComputational_SomeThreads)
{
  for (size_t t = 0; t < kTimes; ++t)
  {
    size_t const threadCount = 4;
    std::atomic<size_t> counter{0};
    {
      base::ComputationalThreadPool threadPool(threadCount);
      for (size_t i = 0; i < threadCount; ++i)
      {
        threadPool.Submit([&]()
        {
          threads::Sleep(1);
          ++counter;
        });
      }
    }

    TEST_EQUAL(threadCount, counter, ());
  }
}

UNIT_TEST(ThreadPoolComputational_OneThread)
{