Changeset b232745 for doc/theses/thierry_delisle_PhD/code/relaxed_list.cpp

Timestamp:

Jun 22, 2020, 4:29:05 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:

13c5e19

Parents:

0f89d4f

Message:

Several changes to relaxed list prototype and added workstealing for comparison

File:

• doc/theses/thierry_delisle_PhD/code/relaxed_list.cpp (modified) (13 diffs)

doc/theses/thierry_delisle_PhD/code/relaxed_list.cpp

@@ -1 @@
-#include "relaxed_list.hpp"
+#if !defined(LIST_VARIANT_HPP)
+#define LIST_VARIANT_HPP "relaxed_list.hpp"
+#endif
+
+#include LIST_VARIANT_HPP
+#if !defined(LIST_VARIANT)
+#error not variant selected
+#endif
 
 #include <array>
@@ -35 +42 @@
 
 template<>
-thread_local relaxed_list<Node>::TLS relaxed_list<Node>::tls = {};
+thread_local LIST_VARIANT<Node>::TLS LIST_VARIANT<Node>::tls = {};
 
 template<>
-relaxed_list<Node> * relaxed_list<Node>::head = nullptr;
+std::atomic_uint32_t LIST_VARIANT<Node>::ticket = { 0 };
 
 #ifndef NO_STATS
 template<>
-relaxed_list<Node>::GlobalStats relaxed_list<Node>::global_stats = {};
+LIST_VARIANT<Node>::GlobalStats LIST_VARIANT<Node>::global_stats = {};
 #endif
 
@@ -120 +127 @@
         atomic_min(global.valmin, local.valmin);
 
-        relaxed_list<Node>::stats_tls_tally();
+        LIST_VARIANT<Node>::stats_tls_tally();
 }
 
@@ -199 +206 @@
         std::cout << "Total ops     : " << ops << "(" << global.in << "i, " << global.out << "o, " << global.empty << "e)\n";
         #ifndef NO_STATS
-                relaxed_list<Node>::stats_print(std::cout);
+                LIST_VARIANT<Node>::stats_print(std::cout);
         #endif
 }
@@ -216 +223 @@
         unsigned nslots,
         local_stat_t & local,
-        relaxed_list<Node> & list
+        LIST_VARIANT<Node> & list
 ) {
         while(__builtin_expect(!done.load(std::memory_order_relaxed), true)) {
@@ -254 +261 @@
         std::cout << "Initializing ";
         size_t npushed = 0;
-        relaxed_list<Node> list = { nthread * nqueues };
+        LIST_VARIANT<Node> list = { nthread, nqueues };
         {
                 Node** all_nodes[nthread];
@@ -340 +347 @@
         unsigned nnodes,
         local_stat_t & local,
-        relaxed_list<Node> & list
+        LIST_VARIANT<Node> & list
 ) {
         Node * nodes[nnodes];
@@ -384 +391 @@
         std::cout << "Initializing ";
         // List being tested
-        relaxed_list<Node> list = { nthread * nqueues };
+        LIST_VARIANT<Node> list = { nthread, nqueues };
         {
                 enable_stats = true;
@@ -441 +448 @@
         int nslots,
         local_stat_t & local,
-        relaxed_list<Node> & list
+        LIST_VARIANT<Node> & list
 ) {
         while(__builtin_expect(!done.load(std::memory_order_relaxed), true)) {
@@ -518 +525 @@
 
         // List being tested
-        relaxed_list<Node> list = { nthread * nqueues };
+        LIST_VARIANT<Node> list = { nthread, nqueues };
         {
                 Random rand(rdtscl());
@@ -593 +600 @@
         unsigned nnodes,
         local_stat_t & local,
-        relaxed_list<Node> & list
+        LIST_VARIANT<Node> & list
 ) {
         Node * nodes[nnodes];
@@ -653 +660 @@
 
         // List being tested
-        relaxed_list<Node> list = { nthread * nqueues };
+        LIST_VARIANT<Node> list = { nthread, nqueues };
         {
                 enable_stats = true;
@@ -921 +928 @@
 
         std::cout << "Running " << nthreads << " threads (" << (nthreads * nqueues) << " queues) for " << duration << " seconds" << std::endl;
-        std::cout << "Relaxed list variant: " << relaxed_list<Node>::name() << std::endl;
+        std::cout << "Relaxed list variant: " << LIST_VARIANT<Node>::name() << std::endl;
         switch(benchmark) {
                 case Churn: