Commit: be5c4a1b3527801f637c4b98fee6cb8ed5c6da4e - launch_thread_performance (hg)

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

Commit MetaInfo

• Revision: be5c4a1b3527801f637c4b98fee6cb8ed5c6da4e (tree)
• Zeit: 2017-09-01 03:07:52
• Autor: Eric Hopper <hopper@omni...>
• Commiter: Eric Hopper

Log Message

Make magnitude of numbers more easily compared by setting a width.

Ändern Zusammenfassung

• modified: test_thread.cpp

Diff

diff -r 409f9b966f30 -r be5c4a1b3527 test_thread.cpp
--- a/test_thread.cpp	Fri Jun 02 17:47:40 2017 -0700
+++ b/test_thread.cpp	Thu Aug 31 11:07:52 2017 -0700
@@ -5,6 +5,7 @@
 #include "readerwriterqueue.h"
 #include <stdexcept>
 #include <string>
+#include <iomanip>
 
 extern void do_something();
 
@@ -57,21 +58,22 @@
    using ::std::async;
    using ::std::thread;
    using ::std::launch;
+   using ::std::setw;
    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';
+           << setw(10) << calls_per_second([]() { }, 5) << '\n';
    }
    if (whichtests & 0x2) {
       cout << "        Empty calls per second: "
-           << calls_per_second([]() { do_something(); }, 5) << '\n';
+           << setw(10) << calls_per_second([]() { do_something(); }, 5) << '\n';
    }
    if (whichtests & 0x4) {
       cout << "   New thread calls per second: "
-           << calls_per_second(
+           << setw(10) << calls_per_second(
               []() {
                  thread t{ do_something };
                  t.join();
@@ -82,7 +84,7 @@
    }
    if (whichtests & 0x8) {
       cout << " Async launch calls per second: "
-           << calls_per_second(
+           << setw(10) << calls_per_second(
               []() {
                  auto fut = async(launch::async | launch::deferred, do_something);
                  fut.wait();
@@ -96,7 +98,7 @@
       ::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(
+           << setw(10) << calls_per_second(
               [&from_main, &to_main]() {
                  if (!from_main.enqueue(do_something)) {
                     throw ::std::runtime_error("Unable to send request to worker.");