aboutsummaryrefslogtreecommitdiff
path: root/store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp
diff options
context:
space:
mode:
authorYuqian Yang <crupest@crupest.life>2025-02-28 23:13:39 +0800
committerYuqian Yang <crupest@crupest.life>2025-02-28 23:13:39 +0800
commit99e2e923d0c77b02f3fb4ff648ea916954868606 (patch)
treeec8e03f6f2cd1ce43990fb4fe6cd631967d0237e /store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp
parent1cee979f5d36b311a03cc7397a036ba11caf3d42 (diff)
downloadcrupest-99e2e923d0c77b02f3fb4ff648ea916954868606.tar.gz
crupest-99e2e923d0c77b02f3fb4ff648ea916954868606.tar.bz2
crupest-99e2e923d0c77b02f3fb4ff648ea916954868606.zip
chore(store): move everything to store.
Diffstat (limited to 'store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp')
-rw-r--r--store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp36
1 files changed, 36 insertions, 0 deletions
diff --git a/store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp b/store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp
new file mode 100644
index 0000000..0068082
--- /dev/null
+++ b/store/works/life/operating-system-experiment/SemaphoreAvoidDataRaceDemo.cpp
@@ -0,0 +1,36 @@
+#include "Semaphore.h"
+#include "Thread.h"
+
+#include <iostream>
+
+int main() {
+ unsigned data = 0;
+
+ cru::Semaphore semaphore;
+
+ cru::Thread t1([&data, &semaphore] {
+ for (int i = 0; i < 100000; i++) {
+ semaphore.P();
+ data += 10;
+ semaphore.V();
+ }
+ });
+
+ cru::Thread t2([&data, &semaphore] {
+ for (int i = 0; i < 100000; i++) {
+ semaphore.P();
+ data += 10;
+ semaphore.V();
+ }
+ });
+
+ std::cout << "Created thread: " << t1.GetNativeID() << '\n';
+ std::cout << "Created thread: " << t2.GetNativeID() << '\n';
+
+ t1.Join();
+ t2.Join();
+ std::cout << "Answer is " << data << ", which is "
+ << (data == 2000000 ? "correct" : "false") << '\n';
+
+ return 0;
+}