Changeset 3948 for trunk/test/queue.cc

Timestamp:

Jul 20, 2020, 9:12:46 AM (3 years ago)

Author:

Peter

Message:

replace boost::thread with std::thread in Scheduler. refs #953

File:

• trunk/test/queue.cc (modified) (3 diffs)

trunk/test/queue.cc

@@ -26 +26 @@
 #include "yat/utility/Queue.h"
 
-#include <boost/thread.hpp>
-
 #include <iostream>
+#include <thread>
+#include <vector>
 
 using namespace theplu::yat;
@@ -50 +50 @@
       }
       sleep(1);
-      // Make sure we can be interrupted
-      boost::this_thread::interruption_point();
     }
   }
@@ -65 +63 @@
   queue.push("Peter");
 
-  boost::thread_group workers;
-  workers.create_thread(Worker(queue));
-  workers.create_thread(Worker(queue));
-  workers.create_thread(Worker(queue));
-  workers.create_thread(Worker(queue));
+  std::vector<std::thread> threads;
+  threads.push_back(std::thread(Worker(queue)));
+  threads.push_back(std::thread(Worker(queue)));
+  threads.push_back(std::thread(Worker(queue)));
+  threads.push_back(std::thread(Worker(queue)));
 
-  workers.join_all();
+  for (size_t i=0; i<threads.size(); ++i)
+    threads[i].join();
 
   Queue<std::string> queue2(queue);