Custom thread names

Wiebe Cazemier
1 parent 163d14e8
Showing 3 changed files with 15 additions and 1 deletions
mainapp.cpp
threaddata.cpp
threaddata.h
@@ -130,7 +130,7 @@ void MainApp::start()
     {
         std::shared_ptr<ThreadData> t(new ThreadData(i, subscriptionStore));
         std::thread thread(do_thread_work, t.get());
-        t->thread = std::move(thread);
+        t->moveThreadHere(std::move(thread));
         threads.push_back(t);
     }
  
 #include "threaddata.h"
+#include <string>
+#include <sstream>
  
 ThreadData::ThreadData(int threadnr, std::shared_ptr<SubscriptionStore> &subscriptionStore) :
     subscriptionStore(subscriptionStore),
@@ -14,6 +16,17 @@ ThreadData::ThreadData(int threadnr, std::shared_ptr&lt;SubscriptionStore&gt; &amp;subscri
     check<std::runtime_error>(epoll_ctl(epollfd, EPOLL_CTL_ADD, event_fd, &ev));
 }
  
+void ThreadData::moveThreadHere(std::thread &&thread)
+{
+    this->thread = std::move(thread);
+
+    pthread_t native = this->thread.native_handle();
+    std::ostringstream threadName;
+    threadName << "FlashMQ T " << threadnr;
+    threadName.flush();
+    pthread_setname_np(native, threadName.str().c_str());
+}
+
 void ThreadData::quit()
 {
     running = false;
@@ -36,6 +36,7 @@ public:
  
     ThreadData(int threadnr, std::shared_ptr<SubscriptionStore> &subscriptionStore);
  
+    void moveThreadHere(std::thread &&thread);
     void quit();
     void giveClient(Client_p client);
     Client_p getClient(int fd);