Changeset 34798

Timestamp:

08/06/09 16:53:32 (4 years ago)

Author:

saturday06

Message:

bencher

Files:

• lang/objective-cplusplus/i3/trunk/src/mil/src/Test11.cpp (modified) (3 diffs)

lang/objective-cplusplus/i3/trunk/src/mil/src/Test11.cpp

@@ -14 +14 @@
 namespace Test11 {
 
-int global = 0;
+atomic<int> global = 0;
 atomic<int> spin_status;
 
@@ -37 +37 @@
 
 // bench class
-struct BenchReceiver : mil::Module<BenchReceiver> {
+const unsigned int POST_MAX = 50000;
+
+struct Bencher : mil::Module<Bencher> {
+    static Bencher benchers[20];
+    int index;
     int begin;
+    int posted;
+    void setIndex(int index_) {
+        posted = 0;
+        index = index_;
+    }
+    void a() {
+        posted++;
+        if (posted == POST_MAX) {
+            AllPosted e;
+            benchers[index].post(e, *this);
+        }
+    }
+    void execute(TinyEvent& e) {
+        global.fetch_and_add(1);
+        benchers[index].post(e, *this);
+        a();
+    }
+    void execute(SmallEvent& e) {
+        global.fetch_and_add(e.data * 2);
+        benchers[index].post(e, *this);
+        a();
+    }
+    void execute(MiddleEvent& e) {
+        global.fetch_and_add(e.data * 2);
+        benchers[index].post(e, *this);
+        a();
+    }
+    void execute(BigEvent& e) {
+        global.fetch_and_add(e.data * 2);
+        benchers[index].post(e, *this);
+        a();
+    }
+    void execute(AllPosted& e) {
+        printf("AllPosted Received : %lf, global = %d, index = %d\n",
+               (double)(clock() - begin) / CLOCKS_PER_SEC, global.load(), index);
+        spin_status.fetch_and_add(1);
+    }
     void run() {
         while (spin_status.load()) {}
         begin = clock();
+        for (int i = 0; i < 5; i++) {
+            TinyEvent t;
+            benchers[index].post(t, *this);
+            SmallEvent s;
+            s.data = 8;
+            benchers[index].post(s, *this);
+            //MiddleEvent m;
+            //m.data = 16;
+            //r.post(m, *this);
+            //BigEvent b;
+            //b.data = 32;
+            //r.post(b, *this);
+        }
         this->loop();
-    }
-    void execute(TinyEvent& e) {
-        global += 2;
-    }
-    void execute(SmallEvent& e) {
-        global += e.data * 2;
-    }
-    void execute(MiddleEvent& e) {
-        global += e.data * 2;
-    }
-    void execute(BigEvent& e) {
-        global += e.data * 2;
-    }
-    void execute(AllPosted& e) {
-        printf("AllPosted Received : %lf, global = %d\n",
-               (double)(clock() - begin) / CLOCKS_PER_SEC, global);
-        spin_status.store(2);
     }
 };
 
-struct BenchSender : mil::Module<BenchSender> {
-    int begin;
-    BenchReceiver& r;
-    BenchSender(BenchReceiver& r) : r(r) {}
-    void run() {
-        while (spin_status.load()) {}
-        begin = clock();
-        for (int i = 0; i < 5000000; i++) {
-            TinyEvent t;
-            r.post(t, *this);
-            SmallEvent s;
-            s.data = 8;
-            r.post(s, *this);
-            MiddleEvent m;
-            m.data = 16;
-            //r.post(m, *this);
-            BigEvent b;
-            b.data = 32;
-            //r.post(b, *this);
-        }
-        AllPosted a;
-        r.post(a, *this);
-
-        while (spin_status.load() != 2) {
-            while (this->execute_front()) {
-            }
-        }
-        printf("run end : %lf, global = %d\n",
-               (double)(clock() - begin) / CLOCKS_PER_SEC, global);
-        spin_status.store(3);
-    }
-};
+Bencher Bencher::benchers[20];
 
 }
@@ -101 +107 @@
 
 QT_TEST(test_iaodfioasdfadfaadfasdfadfiiiii) {
-    BenchReceiver r;
-    BenchSender s(r);
     spin_status.store(1);
-    r.start();
-    s.start();
-    sleep(1);
+
+    for (size_t i = 0; i < _countof(Bencher::benchers); i++) {
+        Bencher::benchers[i].setIndex((i + 1) % _countof(Bencher::benchers));
+        Bencher::benchers[i].start();
+    }
+
     spin_status.store(0);
 
-    while (spin_status.load() != 3) {}
-
+    while (spin_status.load() != _countof(Bencher::benchers)) {
+        Sleep(10);
+    }
 }