Changeset 111a2ab3 for benchmark

Timestamp:

Apr 29, 2022, 3:10:16 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master, pthread-emulation, qualifiedEnum

Children:

4cb1a24

Parents:

b029e31

Message:

Changed churn.cfa to use the same approach as rust

File:

• benchmark/readyQ/churn.cfa (modified) (7 diffs)

benchmark/readyQ/churn.cfa

@@ -1 +1 @@
 #include "rq_bench.hfa"
 
+#include <locks.hfa>
+
 unsigned spot_cnt = 2;
-bench_sem * volatile * spots;
+semaphore * spots;
 
 thread BThrd {
         unsigned long long count;
         unsigned long long blocks;
-        bench_sem sem;
+        bool skip;
 };
 
@@ -14 +16 @@
         this.count  = 0;
         this.blocks = 0;
+        this.skip = false;
 }
 
@@ -19 +22 @@
 
 void main( BThrd & this ) with( this ) {
-        wait( sem );
+        park();
         for() {
-                uint32_t r = prng();
-                bench_sem * next = __atomic_exchange_n(&spots[r % spot_cnt], &sem, __ATOMIC_SEQ_CST);
-                if(next) post( *next );
-                blocks += wait( sem );
+                uint32_t r = prng(this);
+                semaphore & sem = spots[r % spot_cnt];
+                if(!skip) V( sem );
+                blocks += P( sem );
+                skip = false;
+
                 count ++;
                 if( clock_mode && stop) break;
@@ -49 +54 @@
                         spots = aalloc(spot_cnt);
                         for(i; spot_cnt) {
-                                spots[i] = 0p;
+                                (spots[i]){ 0 };
                         }
 
@@ -55 +60 @@
                         BThrd * threads[nthreads];
                         for(i; nthreads ) {
-                                threads[i] = malloc();
-                                (*threads[i]){};
+                                BThrd & t = *(threads[i] = malloc());
+                                (t){};
+                                t.skip = i < spot_cnt;
                         }
                         printf("Starting\n");
@@ -64 +70 @@
 
                         for(i; nthreads) {
-                                post( threads[i]->sem );
+                                unpark( *threads[i] );
                         }
                         wait(start, is_tty);
@@ -72 +78 @@
                         printf("\nDone\n");
 
+                        for(i; spot_cnt) {
+                                for(10000) V( spots[i] );
+                        }
+
                         for(i; nthreads) {
-                                post( threads[i]->sem );
                                 BThrd & thrd = join( *threads[i] );
                                 global_counter += thrd.count;