提交: 409f9b966f3094467094eb3685daee1018a3adbd - launch_thread_performance (hg)

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

Commit MetaInfo

• 修订版: 409f9b966f3094467094eb3685daee1018a3adbd (tree)
• 时间: 2017-06-03 09:47:40
• 作者: Eric Hopper <hopper@omni...>
• Commiter: Eric Hopper

Log Message

Add in system for selecting subset of tests.

更改概述

• modified: test_thread.cpp

差异

diff -r 76283aa87338 -r 409f9b966f30 test_thread.cpp
--- a/test_thread.cpp	Fri Jun 02 17:47:21 2017 -0700
+++ b/test_thread.cpp	Fri Jun 02 17:47:40 2017 -0700
@@ -4,6 +4,7 @@
 #include <iostream>
 #include "readerwriterqueue.h"
 #include <stdexcept>
+#include <string>
 
 extern void do_something();
 
@@ -50,35 +51,47 @@
    }
 }
 
-int main()
+int main(int argc, const char * const argv[])
 {
    using ::std::cout;
    using ::std::async;
    using ::std::thread;
    using ::std::launch;
-   cout << "   Do nothing calls per second: "
-        << calls_per_second([]() { }, 5) << '\n';
-   cout << "        Empty calls per second: "
-        << calls_per_second([]() { do_something(); }, 5) << '\n';
-   cout << "   New thread calls per second: "
-        << calls_per_second(
+   int whichtests = 31; // All of them, a bitmask.
+   if (argc > 1) {
+      whichtests = ::std::stoi(argv[1]);
+   }
+   if (whichtests & 0x1) {
+      cout << "   Do nothing calls per second: "
+           << calls_per_second([]() { }, 5) << '\n';
+   }
+   if (whichtests & 0x2) {
+      cout << "        Empty calls per second: "
+           << calls_per_second([]() { do_something(); }, 5) << '\n';
+   }
+   if (whichtests & 0x4) {
+      cout << "   New thread calls per second: "
+           << calls_per_second(
               []() {
                  thread t{ do_something };
                  t.join();
               },
               5
-           )
-        << '\n';
-   cout << " Async launch calls per second: "
-        << calls_per_second(
+              )
+           << '\n';
+   }
+   if (whichtests & 0x8) {
+      cout << " Async launch calls per second: "
+           << calls_per_second(
               []() {
                  auto fut = async(launch::async | launch::deferred, do_something);
                  fut.wait();
               },
               5
-           )
-        << '\n';
-   {
+              )
+           << '\n';
+   }
+   if (whichtests & 0x10) {
       ::moodycamel::BlockingReaderWriterQueue<the_call_t> from_main;
       ::moodycamel::BlockingReaderWriterQueue<bool> to_main;
       thread worker{ [&from_main, &to_main]() { worker_thread(from_main, to_main); } };