updated workstealing

tsung-wei-huang · tsung-wei-huang · commit 6ec3d03cf3b1 · 2018-11-29T23:34:06.000-06:00
diff --git a/example/taskflow.cpp b/example/taskflow.cpp
@@ -26,6 +26,10 @@
                                                                         \
   std::cout << "Taskflow [speculative executor]: "                      \
             << F<tf::BasicTaskflow<tf::SpeculativeThreadpool>>()        \
+            << " ms\n";                                                 \
+                                                                        \
+  std::cout << "Taskflow [privatized executor]: "                       \
+            << F<tf::BasicTaskflow<tf::PrivatizedThreadpool>>()         \
             << " ms\n";                                                 \
 
 // ============================================================================
diff --git a/taskflow/threadpool/privatized_threadpool.hpp b/taskflow/threadpool/privatized_threadpool.hpp
@@ -535,19 +535,19 @@ void PrivatizedThreadpool<Closure>::emplace(ArgsT&&... args){
 // Privatized queue of worker. The lock-free queue is inspired by 
 // http://www.1024cores.net/home/lock-free-algorithms/queues/bounded-mpmc-queue
 template<typename T, size_t C>
-class PrivatizedClosureQueue {
+class PrivatizedWorkQueue {
 
   public:
 
-  PrivatizedClosureQueue() : _buffer_mask(C - 1) {
+  PrivatizedWorkQueue() : _buffer_mask(C - 1) {
     for (size_t i = 0; i < C; i ++){
       _buffer[i].sequence_.store(i, std::memory_order_relaxed);
     }
     _front.store(0, std::memory_order_relaxed);
     _back.store(0, std::memory_order_relaxed);
   }
 
-  ~PrivatizedClosureQueue(){}
+  ~PrivatizedWorkQueue(){}
 
   bool enqueue(T& data){
     size_t pos = _front.load(std::memory_order_relaxed);
@@ -617,7 +617,7 @@ class PrivatizedThreadpool {
 
   struct Worker{
     std::condition_variable cv;
-    PrivatizedClosureQueue<Closure, 1024> queue;
+    PrivatizedWorkQueue<Closure, 1024> queue;
     std::optional<Closure> cache;
     bool exit {false};
 
