Changeset 320ec6fc for libcfa/src/concurrency/ready_queue.cfa

Timestamp:

Jul 24, 2020, 1:11:39 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:

39fc03e

Parents:

f4ec4a90

Message:

Changed ready_queue_(grow/shrink) to take a target instead of going incrementing

File:

• libcfa/src/concurrency/ready_queue.cfa (modified) (5 diffs)

libcfa/src/concurrency/ready_queue.cfa

@@ -37 +37 @@
 #endif
 
-#define BIAS 64
+#define BIAS 16
 
 // returns the maximum number of processors the RWLock support
@@ -500 +500 @@
 
 // Grow the ready queue
-void ready_queue_grow  (struct cluster * cltr) {
+void ready_queue_grow  (struct cluster * cltr, int target) {
         /* paranoid */ verify( ready_mutate_islocked() );
         __cfadbg_print_safe(ready_queue, "Kernel : Growing ready queue\n");
@@ -515 +515 @@
                 // increase count
                 ncount += 4;
+                /* paranoid */ verify( ncount == target * 4 || target < 2 );
 
                 // Allocate new array (uses realloc and memcpies the data)
@@ -550 +551 @@
 
 // Shrink the ready queue
-void ready_queue_shrink(struct cluster * cltr) {
+void ready_queue_shrink(struct cluster * cltr, int target) {
         /* paranoid */ verify( ready_mutate_islocked() );
         __cfadbg_print_safe(ready_queue, "Kernel : Shrinking ready queue\n");
@@ -566 +567 @@
                 // reduce the actual count so push doesn't use the old queues
                 lanes.count -= 4;
-                verify(ocount > lanes.count);
+                /* paranoid */ verify( ocount > lanes.count );
+                /* paranoid */ verify( lanes.count == target * 4 || target < 2 );
 
                 // for printing count the number of displaced threads