From 676b95bacde4770091f3bc913d580524654ed766 Mon Sep 17 00:00:00 2001
From: Yinsidi <yinsidij@gmail.com>
Date: Fri, 13 Aug 2021 00:48:01 -0700
Subject: [PATCH] another example

---
 examples/{sample.cpp => sample0.cpp} |   0
 examples/sample1.cpp                 | 122 +++++++++++++++++++++++++++
 meson.build                          |   9 +-
 3 files changed, 129 insertions(+), 2 deletions(-)
 rename examples/{sample.cpp => sample0.cpp} (100%)
 create mode 100644 examples/sample1.cpp

diff --git a/examples/sample.cpp b/examples/sample0.cpp
similarity index 100%
rename from examples/sample.cpp
rename to examples/sample0.cpp
diff --git a/examples/sample1.cpp b/examples/sample1.cpp
new file mode 100644
index 0000000..6212315
--- /dev/null
+++ b/examples/sample1.cpp
@@ -0,0 +1,122 @@
+#include <assert.h>
+#include <atomic>
+#include <chrono>
+#include <iostream>
+#include <random>
+#include <signal.h>
+#include <thread>
+
+// NB: On Windows, you must include Winbase.h/Synchapi.h/Windows.h before pevents.h
+#ifdef _WIN32
+#include <Windows.h>
+#endif
+#include "pevents.h"
+
+#ifdef _WIN32
+#define __unused__  [[maybe_unused]]
+#else
+#define __unused__ __attribute__((unused))
+#endif
+
+using namespace neosmart;
+using namespace std;
+
+neosmart_event_t events_completed[2];  // events completed for letters, numbers;
+neosmart_event_t events_letters[26];   // letter events
+neosmart_event_t events_numbers[10];   // number events
+
+void worker_letter(char ch)
+{
+    int i = ch-'A';
+    std::random_device rd;
+    std::mt19937 gen(rd());
+    std::uniform_int_distribution<int> dis(0, 3000);
+    std::this_thread::sleep_for(std::chrono::milliseconds(dis(gen)));
+    assert(0<=i && i<26);
+    SetEvent(events_letters[i]);
+    cout << ch << endl;
+}
+
+void letters() {
+
+    printf("letters(): Starting 26 letter threads\n");
+
+    for (char letter='A';letter<='Z';letter++)
+    {
+	    std::thread (worker_letter,letter).detach();
+    }
+
+    WaitForMultipleEvents(events_letters,26,true /*waitAll*/,WAIT_INFINITE);
+    SetEvent(events_completed[0]);
+    cout << "letters() completed" << endl;
+}
+
+
+void worker_number(int num)
+{
+    std::random_device rd;
+    std::mt19937 gen(rd());
+    std::uniform_int_distribution<int> dis(0, 5000);
+    std::this_thread::sleep_for(std::chrono::milliseconds(dis(gen)));
+    SetEvent(events_numbers[num]);
+    cout << num << endl;
+}
+
+void numbers() {
+
+    printf("numbers(): Starting 10 number threads\n");
+
+    for (int num=0;num<10;num++)
+    {
+	    std::thread (worker_number,num).detach();
+    }
+
+    WaitForMultipleEvents(events_numbers,10,true /*waitAll*/,WAIT_INFINITE);
+    SetEvent(events_completed[1]);
+    cout << "numbers(): completed" << endl;
+}
+
+int main() {
+
+    // create a list of manual-reset events;
+    for (int i=0;i<2;i++)   events_completed[i] = CreateEvent(true, false); // manual-reset events;
+    for (int i=0;i<26;i++)  events_letters[i] = CreateEvent(true, false);   // manual-reset events;
+    for (int i=0;i<10;i++)  events_numbers[i] = CreateEvent(true, false);   // manual-reset events;
+
+
+    vector<std::thread> threads;
+    threads.emplace_back(letters);
+    threads.emplace_back(numbers);
+    int result;
+    
+    result = WaitForMultipleEvents(events_completed,2,false/*waitAll*/, 3000);
+    if (result == WAIT_TIMEOUT)
+    {
+        cout << "Timeout! It's fine that none completed" << endl;
+    } else if (result == 0) {
+        cout << "Letters completed" << endl;
+    } else if (result == 1) {
+        cout << "Numbers completed" << endl;
+    } else {
+        cout << "ERROR! Unexpected index: " << result << endl;
+        exit(-1);
+    }
+
+    result = WaitForMultipleEvents(events_completed,2,true /*waitAll*/, WAIT_INFINITE);
+    if (result == WAIT_TIMEOUT) {
+        cout << "Timeout!" << endl;
+        assert(false);
+    } else if (result == 0) {
+        cout << "Letters and Numbers completed" << endl;
+    } else {
+        cout << "ERROR! Unexpected index: " << result << endl;
+	exit(-1);
+    }
+
+    for (auto& thread : threads)
+        thread.join();
+
+    for (int i=0;i<2;i++)   DestroyEvent(events_completed[i]);
+    for (int i=0;i<26;i++)  DestroyEvent(events_letters[i]);
+    for (int i=0;i<10;i++)  DestroyEvent(events_numbers[i]);
+}
diff --git a/meson.build b/meson.build
index 713fbd9..6b5fb46 100644
--- a/meson.build
+++ b/meson.build
@@ -52,10 +52,15 @@ custom_target('pevents.hpp',
 
 # Sample program demonstrating capabilities
 if get_option('wfmo')
-	sample = executable('sample', ['examples/sample.cpp'],
+	sample = executable('sample0', ['examples/sample0.cpp'],
 		include_directories: incdir,
 		cpp_args: args,
-		   override_options: ['cpp_std=' + test_std],
+		override_options: ['cpp_std=' + test_std],
+		dependencies: [pevents])
+	sample = executable('sample1', ['examples/sample1.cpp'],
+		include_directories: incdir,
+		cpp_args: args,
+		override_options: ['cpp_std=' + test_std],
 		dependencies: [pevents])
 endif