event_loop_test.cpp

   1
   2 #ifdef HAVE_CONFIG_H
   3 #include <config.h>
   4 #endif
   5
   6 #include <iostream>
   7 #include <beacon/event_loop.hpp>
   8 #include <boost/bind.hpp>
   9 #include <beacon/reference_countable.hpp>
  10
  11 using namespace std;
  12 using namespace beacon;
  13
  14 unsigned times_called = 0;
  15 class inv : public invokable {
  16     public:
  17
  18         inv() : invokable(0) {
  19         }
  20
  21         void invoke() {
  22             times_called++;
  23         }
  24
  25         bool operator==(invokable const & other) {
  26             return this == &other;
  27         }
  28 };
  29
  30 void function() {
  31     times_called++;
  32 }
  33
  34 int main(int argc, char * argv[]) {
  35
  36     event_loop el;
  37
  38     el.start();
  39
  40     inv in;
  41
  42     //fast
  43     boost::function<void()> fn = invoke_with_no_future<void()>(el, &function, (void const *)(&function));
  44
  45     //slow - approx. 5x slower
  46     //boost::function<beacon::future<void> *()> fn = invoke_with_future_pointer<void()>(el, &function, (void const *)(&function));
  47
  48     //slow as well - no leaks
  49     //boost::function<beacon::scoped_future<void> ()> fn = invoke_with_future_object<void()>(el, &function, (void const *)(&function));
  50
  51     boost::xtime start, end, now;
  52     boost::xtime_get(&start, boost::TIME_UTC);
  53
  54     for(int i = 0; i < 1000000; i++) {
  55         //el.enqueue(new inv);
  56         fn(); //this leaks when used with future pointer
  57         //beacon::scoped_future<void> res(fn()); //this wraps the future pointer so that it doesn't leak
  58     }
  59
  60     boost::xtime_get(&now, boost::TIME_UTC);
  61     now.nsec += 1000;
  62     boost::thread::sleep(now);
  63
  64     cout << "dequing ";
  65     cout << el.dequeue((void const *)(&function)) << " calls" << endl;
  66
  67     el.join();
  68
  69     boost::xtime_get(&end, boost::TIME_UTC);
  70
  71     double diff = end.sec - start.sec + (end.nsec - start.nsec) / 1e9;
  72
  73     cout << "time: " << diff << std::endl;
  74     cout << "times called: " << times_called << endl;
  75     return EXIT_SUCCESS;
  76 }