testsuite/thread_pool_test.cpp

   1 #define BOOST_TEST_MAIN
   2 #include <boost/test/included/unit_test.hpp>
   3
   4 #include <atomic>
   5
   6 #include "thread_pool.hpp"
   7
   8 BOOST_AUTO_TEST_CASE( int_test )
   9 {
  10     std::atomic_int count(0);
  11
  12     {
  13         nova::thread_pool pool(4);
  14
  15         for (int i = 0; i != 100; ++i) {
  16             pool.schedule([&]() {
  17                 count += 1;
  18             });
  19         }
  20     }
  21
  22     BOOST_REQUIRE_EQUAL( count, 100 );
  23 }
  24
  25 BOOST_AUTO_TEST_CASE( future_test )
  26 {
  27     std::future<int> answer;
  28
  29     {
  30         nova::thread_pool pool(4);
  31
  32         answer = pool.schedule([]() {
  33             return 42;
  34         });
  35     }
  36
  37     BOOST_REQUIRE_EQUAL( answer.get(), 42 );
  38 }