Changeset d72c074

Timestamp:

Jun 24, 2020, 4:36:20 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

564148f

Parents:

29cb302

Message:

Added option to bias threads to queues, instead of processors to queues

Location:

libcfa/src/concurrency

Files:

• invoke.h (modified) (1 diff)
• ready_queue.cfa (modified) (4 diffs)
• thread.cfa (modified) (1 diff)

libcfa/src/concurrency/invoke.h

@@ -168 +168 @@
                 struct $thread * prev;
                 volatile unsigned long long ts;
+                int preferred;
         };
 

libcfa/src/concurrency/ready_queue.cfa

@@ -37 +37 @@
 #endif
 
-#define BIAS 8
+#define BIAS 64
 
 // returns the maximum number of processors the RWLock support
@@ -221 +221 @@
         #if defined(BIAS) && !defined(__CFA_NO_STATISTICS__)
                 bool local = false;
+                int preferred =
+                        //*
+                        kernelTLS.this_processor ? kernelTLS.this_processor->id * 4 : -1;
+                        /*/
+                        thrd->link.preferred * 4;
+                        //*/
+
+
         #endif
 
@@ -231 +239 @@
                         unsigned rlow  = r % BIAS;
                         unsigned rhigh = r / BIAS;
-                        if((0 != rlow) && kernelTLS.this_processor) {
+                        if((0 != rlow) && preferred >= 0) {
                                 // (BIAS - 1) out of BIAS chances
                                 // Use perferred queues
-                                unsigned pid = kernelTLS.this_processor->id * 4;
-                                i = pid + (rhigh % 4);
+                                i = preferred + (rhigh % 4);
 
                                 #if !defined(__CFA_NO_STATISTICS__)
@@ -411 +418 @@
         #endif
 
+        // Update the thread bias
+        thrd->link.preferred = w / 4;
+
         // return the popped thread
         return thrd;

libcfa/src/concurrency/thread.cfa

@@ -38 +38 @@
         link.next = 0p;
         link.prev = 0p;
+        link.preferred = -1;
 
         node.next = 0p;