ed/metadesk
1
0
Fork 0
mirror of https://github.com/Ed94/metadesk.git synced 2026-08-06 23:58:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5 from mmozeiko/pthreads

Browse Source 
add pthreads support to multi_threaded.c example
This commit is contained in:
Ryan Fleury
2021-11-16 21:43:07 -07:00
committed by GitHub
parent 642d2cd895 1d23319460
commit afc076187b
2 changed files with 37 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bin/linker_flags.txt
+1
View File
@@ -5,3 +5,4 @@ lld-link>-OPT:REF
lld-link>-INCREMENTAL:NO lld-link>-INCREMENTAL:NO
lld-link>debug>-DEBUG lld-link>debug>-DEBUG
lld-link>dll>-DLL lld-link>dll>-DLL
clang>-lpthread
examples/integration/multi_threaded.c
+36 -17
View File
@@ -21,6 +21,8 @@
#if MD_OS_WINDOWS #if MD_OS_WINDOWS
# include <Windows.h> # include <Windows.h>
#elif MD_OS_MAC || MD_OS_LINUX
# include <pthread.h>
#else #else
# error Not implemented for this OS # error Not implemented for this OS
#endif #endif
@@ -29,10 +31,13 @@
// for this intrinsic we're assume pre-increment behavior // for this intrinsic we're assume pre-increment behavior
#if MD_OS_WINDOWS #if MD_COMPILER_CL
# define atomic_inc_then_eval_u64(p) InterlockedIncrement64((LONG64*)p) # include <intrin.h>
# define atomic_inc_then_eval_u64(p) _InterlockedIncrement64((volatile __int64*)p)
#elif MD_COMPILER_CLANG || MD_COMPILER_GCC
# define atomic_inc_then_eval_u64(p) __sync_add_and_fetch(p, 1)
#else #else
# error Not implemented for this OS # error Not implemented for this compiler
#endif #endif
// @notes We use one structure that describes the whole multi-threaded parse // @notes We use one structure that describes the whole multi-threaded parse
@@ -97,6 +102,13 @@ parse_worker_win32(LPVOID parameter)
parse_worker_loop((ThreadData*)parameter); parse_worker_loop((ThreadData*)parameter);
return(0); return(0);
} }
#elif MD_OS_MAC || MD_OS_LINUX
void *
parse_worker_pthread(void *parameter)
{
parse_worker_loop((ThreadData*)parameter);
return(0);
}
#else #else
# error Not implemented for this OS # error Not implemented for this OS
#endif #endif
@@ -131,33 +143,40 @@ main(int argc, char **argv)
// launch the worker threads // launch the worker threads
// (no worker thread 0) // (no worker thread 0)
#if MD_OS_WINDOWS
HANDLE handles[THREAD_COUNT];
for (int i = 1; i < THREAD_COUNT; i += 1) for (int i = 1; i < THREAD_COUNT; i += 1)
{ {
#if MD_OS_WINDOWS handles[i] = CreateThread(0, 0, &parse_worker_win32, threads + i, 0, 0);
HANDLE handle = CreateThread(0, 0, parse_worker_win32, threads + i, 0, 0); }
CloseHandle(handle); #elif MD_OS_MAC || MD_OS_LINUX
pthread_t handles[THREAD_COUNT];
for (int i = 1; i < THREAD_COUNT; i += 1)
{
pthread_create(&handles[i], 0, &parse_worker_pthread, threads + i);
}
#else #else
# error Not implemented for this OS # error Not implemented for this OS
#endif #endif
}
// let the main thread act as thread 0 // let the main thread act as thread 0
parse_worker_loop(&threads[0]); parse_worker_loop(&threads[0]);
// wait for all threads to be finished // wait for all threads to be finished
for (;;)
{
MD_u64 thread_counter = task.thread_counter;
if (thread_counter >= THREAD_COUNT)
{
break;
}
#if MD_OS_WINDOWS #if MD_OS_WINDOWS
Sleep(0); WaitForMultipleObjects(THREAD_COUNT-1, handles+1, TRUE, INFINITE);
for (int i = 1; i < THREAD_COUNT; i += 1)
{
CloseHandle(handles[i]);
}
#elif MD_OS_MAC || MD_OS_LINUX
for (int i = 1; i < THREAD_COUNT; i += 1)
{
pthread_join(handles[i], 0);
}
#else #else
# error Not implemented for this OS # error Not implemented for this OS
#endif #endif
}
// print results // print results
for (int i = 0; i < THREAD_COUNT; i += 1) for (int i = 0; i < THREAD_COUNT; i += 1)