Use atomic variables for thread communication

Fixes https://github.com/libsdl-org/SDL/issues/10711

(cherry picked from commit a0f36fb85b)
This commit is contained in:
Sam Lantinga committed 2024-09-05 07:09:27 -07:00
1 parent 37d3eea939
commit a75227aaeb
2 files changed
+12 -11

No files matched your search

+6 -5
View File
@@ -34,8 +34,9 @@ quit(int rc)
int SDLCALL
SubThreadFunc(void *data)
{
while (!*(int volatile *)data) {
; /* SDL_Delay(10); */ /* do nothing */
SDL_atomic_t *flag = (SDL_atomic_t *)data;
while (!SDL_AtomicGet(flag)) {
SDL_Delay(10);
}
return 0;
}
@@ -44,7 +45,7 @@ int SDLCALL
ThreadFunc(void *data)
{
SDL_Thread *sub_threads[NUMTHREADS];
int flags[NUMTHREADS];
SDL_atomic_t flags[NUMTHREADS];
int i;
int tid = (int)(uintptr_t)data;
@@ -53,7 +54,7 @@ ThreadFunc(void *data)
for (i = 0; i < NUMTHREADS; i++) {
char name[64];
(void)SDL_snprintf(name, sizeof(name), "Child%d_%d", tid, i);
flags[i] = 0;
SDL_AtomicSet(&flags[i], 0);
sub_threads[i] = SDL_CreateThread(SubThreadFunc, name, &flags[i]);
}
@@ -64,7 +65,7 @@ ThreadFunc(void *data)
SDL_Log("Thread '%d' sending signals to subthreads\n", tid);
for (i = 0; i < NUMTHREADS; i++) {
flags[i] = 1;
SDL_AtomicSet(&flags[i], 1);
SDL_WaitThread(sub_threads[i], NULL);
}