提交: 86b23c6decb1fd0261cd67ffe6d3e9771fefb7fc - launch_thread_performance (hg)

Comparing performance of a task queued to an existing thread vs. new thread for each task.

Commit MetaInfo

• 修订版: 86b23c6decb1fd0261cd67ffe6d3e9771fefb7fc (tree)
• 时间: 2017-03-24 06:14:49
• 作者: Eric Hopper <hopper@omni...>
• Commiter: Eric Hopper

Log Message

Use Moody Camel's lock free queue implementation.

更改概述

• modified: test_thread.cpp

差异

diff -r 450c4661537c -r 86b23c6decb1 test_thread.cpp
--- a/test_thread.cpp	Thu Mar 23 10:27:44 2017 -0700
+++ b/test_thread.cpp	Thu Mar 23 14:14:49 2017 -0700
@@ -2,6 +2,8 @@
 #include <thread>
 #include <future>
 #include <iostream>
+#include "readerwriterqueue.h"
+#include <stdexcept>
 
 extern void do_something();
 
@@ -27,17 +29,38 @@
    return count / interval;
 }
 
+
+static bool end_thread_flag = false;
+
+void end_thread()
+{
+   end_thread_flag = true;
+}
+
+void worker_thread(::moodycamel::BlockingReaderWriterQueue<the_call_t> &to_me,
+                   ::moodycamel::BlockingReaderWriterQueue<bool> &from_me)
+{
+   while (!end_thread_flag) {
+      the_call_t a_call;
+      to_me.wait_dequeue(a_call);
+      a_call();
+      if (!from_me.enqueue(true)) {
+         throw ::std::runtime_error("Unable to queue notification!");
+      }
+   }
+}
+
 int main()
 {
    using ::std::cout;
    using ::std::async;
    using ::std::thread;
    using ::std::launch;
-   cout << "  Do nothing calls per second: "
+   cout << "   Do nothing calls per second: "
         << calls_per_second([]() { }, 5) << '\n';
-   cout << "       Empty calls per second: "
+   cout << "        Empty calls per second: "
         << calls_per_second([]() { do_something(); }, 5) << '\n';
-   cout << "  New thread calls per second: "
+   cout << "   New thread calls per second: "
         << calls_per_second(
               []() {
                  thread t{ do_something };
@@ -46,7 +69,7 @@
               5
            )
         << '\n';
-   cout << "Async launch calls per second: "
+   cout << " Async launch calls per second: "
         << calls_per_second(
               []() {
                  auto fut = async(launch::async | launch::deferred, do_something);
@@ -55,5 +78,28 @@
               5
            )
         << '\n';
+   {
+      ::moodycamel::BlockingReaderWriterQueue<the_call_t> from_main;
+      ::moodycamel::BlockingReaderWriterQueue<bool> to_main;
+      thread worker{ [&from_main, &to_main]() { worker_thread(from_main, to_main); } };
+      cout << "Worker thread calls per second: "
+           << calls_per_second(
+              [&from_main, &to_main]() {
+                 if (!from_main.enqueue(do_something)) {
+                    throw ::std::runtime_error("Unable to send request to worker.");
+                 }
+                 bool dummy = false;
+                 to_main.wait_dequeue(dummy);
+              },
+              5
+           )
+        << '\n';
+      from_main.enqueue(end_thread);
+      {
+         bool dummy;
+         to_main.wait_dequeue(dummy);
+      }
+      worker.join();
+   }
    return 0;
 }