Changeset 75965a6

Timestamp:

Jan 13, 2022, 9:49:46 PM (3 years ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum

Children:

86530e7

Parents:

5d1ebb9

Message:

replace thread_rand with prng, replace xorshift64 with xorshift_13_7_17

Files:

• benchmark/readyQ/churn.cfa (modified) (1 diff)
• benchmark/readyQ/locality.cfa (modified) (2 diffs)
• libcfa/src/concurrency/clib/cfathread.cfa (modified) (2 diffs)

benchmark/readyQ/churn.cfa ¶

@@ -21 +21 @@
         wait( sem );
         for() {
-                uint64_t r = thread_rand();
+                uint32_t r = prng();
                 bench_sem * next = __atomic_exchange_n(&spots[r % spot_cnt], &sem, __ATOMIC_SEQ_CST);
                 if(next) post( *next );

benchmark/readyQ/locality.cfa ¶

@@ -128 +128 @@
 __attribute__((noinline)) void work(MyData & data, size_t cnt_, uint64_t & state) {
         for (cnt_) {
-                access(data, __xorshift64(state));
+                access(data, xorshift_13_7_17(state));
         }
 }
 
 void main(MyThread & this) {
-        uint64_t state = thread_rand();
+        uint64_t state = prng();
 
         // Wait for start
@@ -144 +144 @@
 
                 // Wait on a random spot
-                uint64_t idx = __xorshift64(state) % this.spots.len;
+                uint64_t idx = xorshift_13_7_17(state) % this.spots.len;
                 bool closed = put(*this.spots.ptr[idx], this, this.data, this.share);
 

libcfa/src/concurrency/clib/cfathread.cfa ¶

@@ -22 +22 @@
 #include "thread.hfa"
 #include "time.hfa"
+#include "stdlib.hfa"
 
 #include "cfathread.h"
@@ -195 +196 @@
                                 eevent.data.u64 = (uint64_t)active_thread();
 
-                                int id = thread_rand() % poller_cnt;
+                                int id = prng() % poller_cnt;
                                 if(0 != epoll_ctl(poller_fds[id], EPOLL_CTL_ADD, fd, &eevent))
                                 {