replace std::jthread with std::thread

VS2019 では std::jthread::native_handle() が実装されていない。
microsoft/STL#1966
そのため、std::threadで代替する。

Author: hidez8891

example/reader.cpp

@@ -13,16 +13,22 @@ int main()
     using std::this_thread::sleep_for;
     using namespace std::literals::chrono_literals;
 
-    //::SetPriorityClass(::GetCurrentProcess(), REALTIME_PRIORITY_CLASS);
-    //::SetThreadPriority(hMonitorThread, THREAD_PRIORITY_TIME_CRITICAL);
-
     debugio::Monitor monitor;
-
     monitor.start([](debugio::Buffer* buf) -> int {
         fprintf(stderr, "[READ] pid=%d msg=%s\n", buf->processID, buf->data);
         return 0;
     });
 
+#ifdef _MSC_VER
+    SetPriorityClass(::GetCurrentProcess(), REALTIME_PRIORITY_CLASS);
+    SetThreadPriority(monitor.native_handle(), THREAD_PRIORITY_TIME_CRITICAL);
+#else
+    struct sched_param param = {
+        .sched_priority = 99,
+    };
+    pthread_setschedparam(monitor.native_handle(), SCHED_FIFO, &param);
+#endif
+
     sleep_for(2000ms);
     monitor.stop();
 

example/writer.cpp

@@ -31,7 +31,7 @@ int main()
         debugio::write_string(msg.c_str());
         fprintf(stderr, "[WRITE] %s\n", msg.c_str());
 
-        sleep_for(100ms);
+        sleep_for(50ms);
     }
 
     sleep_for(100ms);

include/debugio.h

@@ -1,6 +1,7 @@
 #ifndef DEBUGIO_H_
 #define DEBUGIO_H_
 
+#include <atomic>
 #include <functional>
 #include <thread>
 
@@ -44,6 +45,7 @@ namespace debugio {
         shared_memory<Buffer> buffer;
         event buffer_ready;
         event data_ready;
+        std::atomic<bool> stop_required;
 
         int open();
         int close();
@@ -57,6 +59,7 @@ namespace debugio {
         : buffer(DATA_BUFFER_ID)
         , buffer_ready(EVENTS_BUFFER_READY_ID)
         , data_ready(EVENTS_DATA_READY_ID)
+        , stop_required(false)
     {
     }
 
@@ -103,14 +106,16 @@ namespace debugio {
     */
     class Monitor : DebugIoBase {
     private:
-        std::jthread monitor;
+        std::thread monitor;
 
     public:
         Monitor();
         virtual ~Monitor();
 
         int start(std::function<int(Buffer*)> callback);
         int stop();
+
+        std::thread::native_handle_type native_handle();
     };
 
     inline Monitor::Monitor()
@@ -134,9 +139,10 @@ namespace debugio {
             return -1;
         }
 
-        monitor = std::jthread([this, callback](std::stop_token st) mutable {
+        stop_required.store(false);
+        monitor = std::thread([this, callback]() mutable {
             this->buffer_ready.notify();
-            while (!st.stop_requested()) {
+            while (!this->stop_required.load()) {
                 if (this->data_ready.wait(100) == 0) {
                     callback(&buffer);
                     this->buffer_ready.notify();
@@ -152,12 +158,17 @@ namespace debugio {
             return 0;
         }
 
-        monitor.request_stop();
+        stop_required.store(true);
         monitor.join();
 
         return close();
     }
 
+    inline std::thread::native_handle_type Monitor::native_handle()
+    {
+        return monitor.native_handle();
+    }
+
     /***************************************************************************
      * DebugIO Buffer Writer
     */