testsuite/supernova/callback_interpreter_system.cpp

   1 #include <boost/test/unit_test.hpp>
   2
   3 #include <boost/thread.hpp>
   4 #include <boost/bind.hpp>
   5
   6 #include "utilities/callback_system.hpp"
   7 #include "utilities/callback_interpreter.hpp"
   8 #include "nova-tt/thread_priority.hpp"
   9
  10 using namespace nova;
  11
  12 namespace
  13 {
  14
  15 int i = 0;
  16
  17 struct dummy
  18 {
  19     void run(void)
  20     {
  21         ++i;
  22     }
  23 };
  24
  25 }
  26
  27 BOOST_AUTO_TEST_CASE( callback_system_test )
  28 {
  29     callback_system<dummy> cbs;
  30
  31     cbs.add_callback(new dummy());
  32     cbs.run_callbacks();
  33     BOOST_REQUIRE_EQUAL(i, 1);
  34 }
  35
  36 BOOST_AUTO_TEST_CASE( threaded_callback_interpreter_test )
  37 {
  38     threaded_callback_interpreter<dummy> cbi;
  39
  40     cbi.start_thread();
  41
  42     for (int j = 0; j != 20; ++j)
  43         cbi.add_callback(new dummy());
  44
  45     cbi.join_thread();
  46     BOOST_REQUIRE_EQUAL(i, 21);
  47 }
  48
  49 BOOST_AUTO_TEST_CASE( callback_interpreter_threadpool_test )
  50 {
  51     {
  52         callback_interpreter_threadpool<dummy> cbi(4, true, thread_priority_interval().first);
  53
  54         for (int j = 0; j != 20; ++j)
  55             cbi.add_callback(new dummy());
  56     }
  57     BOOST_REQUIRE_EQUAL(i, 41);
  58 }