Website Summary Files Commits Branches @commit @diff @stats
path: root / gctest / minitrace / minitrace_test_mt.cpp
diff options
context:
space:
mode:
1 files changed, 60 insertions, 0 deletions
-rw-r--r--gctest/minitrace/minitrace_test_mt.cpp60
diff --git a/gctest/minitrace/minitrace_test_mt.cpp b/gctest/minitrace/minitrace_test_mt.cpp
new file mode 100644
index 0000000..899a193
--- /dev/null
+++ b/gctest/minitrace/minitrace_test_mt.cpp
@@ -0,0 +1,60 @@
+// Test minitrace with multiple threads.
+
+#include <inttypes.h>
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+
+#include "minitrace.h"
+
+// Does some meaningless work.
+int work(int cycles) {
+ int a = cycles;
+ for (int i = 0; i < cycles; i++) {
+ a ^= 373;
+ a = (a << 13) | (a >> (32 - 13));
+ }
+ return a;
+}
+
+void *worker_thread(void *param) {
+ int id = (int)(intptr_t)param;
+ char temp[256]; sprintf(temp, "Worker Thread %i", id);
+ MTR_META_THREAD_NAME(temp);
+ int x = 0;
+ for (int i = 0; i < 32; i++) {
+ MTR_BEGIN_I(__FILE__, "Worker", "ID", id);
+ x += work((rand() & 0x7fff) * 1000);
+ MTR_END(__FILE__, "Worker");
+ }
+ return (void *)(intptr_t)x;
+}
+
+void phase2() {
+ for (int i = 0; i < 10000; i++) {
+ MTR_BEGIN_FUNC();
+ MTR_END_FUNC();
+ }
+}
+
+int main() {
+ int i;
+ mtr_init("mt_trace.json");
+ MTR_META_PROCESS_NAME("Multithreaded Test");
+ MTR_META_THREAD_NAME("Main Thread");
+ MTR_BEGIN_FUNC();
+ #define NUMT 8
+ pthread_t threads[NUMT];
+ for (i = 0; i < NUMT; i++) {
+ pthread_create(&threads[i], 0, &worker_thread, (void *)(intptr_t)i);
+ }
+ for (i = 0; i < NUMT; i++) {
+ pthread_join(threads[i], 0);
+ }
+ phase2();
+
+ MTR_END_FUNC();
+ mtr_shutdown();
+ return 0;
+}