ShuriZma
/
snes9x
mirror of https://github.com/snes9xgit/snes9x.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Use semaphores on Windows for backward compatibility." 

This reverts commit 4ede4b7447.
This commit is contained in:
Brandon Wright 2018-04-13 10:25:22 -05:00
parent 60c6d3e802
commit 49ab4c3f28
1 changed files with 21 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
apu/apu.cpp
View File

@ -260,31 +260,32 @@ static uint8 *resample_buffer = NULL;
static HANDLE worker_thread;
static DWORD worker_thread_id;
static HANDLE thread_running_semaphore;
static HANDLE thread_waiting_semaphore;
static CONDITION_VARIABLE thread_running_cond;
static CRITICAL_SECTION thread_running_mutex;
static bool8 thread_running = FALSE;
static bool8 thread_exit = FALSE;
static DWORD WINAPI S9xAPUWorkerThread(LPVOID lpParam)
{
DWORD result;
while (!thread_exit)
{
result = WaitForSingleObject(thread_waiting_semaphore, INFINITE);
EnterCriticalSection(&thread_running_mutex);
while (!thread_running)
{
SleepConditionVariableCS(&thread_running_cond, &thread_running_mutex, INFINITE);
if (thread_exit)
break;
if (!thread_running || result != WAIT_OBJECT_0)
continue;
}
LeaveCriticalSection(&thread_running_mutex);
S9xAPUExecute();
SNES::dsp.synchronize();
EnterCriticalSection(&thread_running_mutex);
thread_running = FALSE;
ReleaseSemaphore(thread_running_semaphore, 1, NULL);
WakeAllConditionVariable(&thread_running_cond);
LeaveCriticalSection(&thread_running_mutex);
}
return 0;
@ -292,22 +293,26 @@ static DWORD WINAPI S9xAPUWorkerThread(LPVOID lpParam)
static void S9xAPUThreadRun(void)
{
EnterCriticalSection(&thread_running_mutex);
thread_running = TRUE;
ReleaseSemaphore(thread_waiting_semaphore, 1, 0);
WakeAllConditionVariable(&thread_running_cond);
LeaveCriticalSection(&thread_running_mutex);
}
static void S9xAPUThreadWait(void)
{
EnterCriticalSection(&thread_running_mutex);
while (thread_running)
{
WaitForSingleObject(thread_running_semaphore, INFINITE);
SleepConditionVariableCS (&thread_running_cond, &thread_running_mutex, INFINITE);
}
LeaveCriticalSection(&thread_running_mutex);
}
static void S9xAPUThreadInit(void)
{
thread_running_semaphore = CreateSemaphore(NULL, 0, 1, NULL);
thread_waiting_semaphore = CreateSemaphore(NULL, 0, 1, NULL);
InitializeConditionVariable(&thread_running_cond);
InitializeCriticalSection (&thread_running_mutex);
thread_running = FALSE;
worker_thread = CreateThread(NULL, 0,S9xAPUWorkerThread, NULL, 0, &worker_thread_id);
}
@ -318,7 +323,6 @@ static void S9xAPUThreadDeinit(void)
thread_exit = TRUE;
S9xAPUThreadRun();
WaitForSingleObject(worker_thread, INFINITE);
CloseHandle(worker_thread);
}
#else