Make the tracked queuelengths atomic to stabilize them.

sandialabs · Jan 14, 2025 · 0af59c4 · 0af59c4
1 parent 61e1a3d
commit 0af59c4
Show file tree

Hide file tree

Showing 3 changed files with 138 additions and 71 deletions.
diff --git a/include/qt_spawncache.h b/include/qt_spawncache.h
@@ -10,8 +10,8 @@ typedef struct _qt_threadqueue_node qt_threadqueue_node_t;
 typedef struct _qt_threadqueue_private {
   qt_threadqueue_node_t *head, *tail;
   qt_threadqueue_node_t *on_deck;
-  long qlength;
-  long qlength_stealable;
+  _Atomic long qlength_a;
+  _Atomic long qlength_stealable_a;
   struct _qt_threadqueue_private *next;
 } qt_threadqueue_private_t;