RAII thread notifier (#24)

added thread notifier

benchmark/test_performance.hpp

@@ -16,9 +16,9 @@
 // #include <chrono>
 // #include <future>
 // #include <iostream>
-// #include <q/mpsc_receiver_round_robin.hpp>
+// #include <q/mpsc_fixed_receiver_round_robin.hpp>
 // #include <q/q_api.hpp>
-// #include <q/spmc_sender_round_robin.hpp>
+// #include <q/spmc_fixed_sender_round_robin.hpp>
 // #include <string>
 // #include <vector>
 // //#include "test_helper.hpp"

examples/examples.cmake

@@ -1,5 +1,7 @@
-# examples/examples.cmake
-set(MAIN_SRC ${Q_SOURCE_DIR}/examples/spsc_main.cpp)
-add_executable(example_spsc ${MAIN_SRC})
+set(SPSC_EXAMPLE_SRC ${Q_SOURCE_DIR}/examples/spsc_main.cpp)
+add_executable(example_spsc ${SPSC_EXAMPLE_SRC})
 target_link_libraries(example_spsc ${Q_LIBRARY})
 
+set(NOTIFY_EXAMPLE_SRC ${Q_SOURCE_DIR}/examples/thread_notify_main.cpp)
+add_executable(example_thread_notify ${NOTIFY_EXAMPLE_SRC})
+target_link_libraries(example_thread_notify ${Q_LIBRARY})

examples/thread_notify_main.cpp

@@ -0,0 +1,27 @@
+#include <chrono>
+#include <iostream>
+#include <thread>
+#include "q/thread_exit_notifier.hpp"
+
+void coutThreadExit(std::thread::id id) {
+   std::cout << "Thread " << id << " has exited." << std::endl;
+}
+
+void threadRun() {
+   thread_local ThreadExitNotifier notifier(coutThreadExit);
+   for (int i = 0; i < 5; ++i) {
+      std::cout << "Thread " << std::this_thread::get_id() << " is running iteration " << i << std::endl;
+      std::this_thread::sleep_for(std::chrono::milliseconds(500));
+   }
+}
+
+int main() {
+   {
+      std::thread thread1(threadRun);
+      std::thread thread2(threadRun);
+
+      thread1.join();
+      thread2.join();
+   }
+   return 0;
+}