mgba/include/mgba-util/platform/windows/threading.h

92 lines
2.1 KiB
C
Raw Normal View History

/* Copyright (c) 2013-2015 Jeffrey Pfau
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
#ifndef WINDOWS_THREADING_H
#define WINDOWS_THREADING_H
#include <mgba-util/common.h>
#define _WIN32_WINNT 0x0600
#include <windows.h>
#define THREAD_ENTRY DWORD WINAPI
typedef THREAD_ENTRY ThreadEntry(LPVOID);
typedef HANDLE Thread;
typedef CRITICAL_SECTION Mutex;
typedef CONDITION_VARIABLE Condition;
static inline int MutexInit(Mutex* mutex) {
InitializeCriticalSection(mutex);
return GetLastError();
}
static inline int MutexDeinit(Mutex* mutex) {
DeleteCriticalSection(mutex);
return GetLastError();
}
static inline int MutexLock(Mutex* mutex) {
EnterCriticalSection(mutex);
return GetLastError();
}
2015-11-13 06:50:09 +00:00
static inline int MutexTryLock(Mutex* mutex) {
if (TryEnterCriticalSection(mutex)) {
2016-01-23 06:43:51 +00:00
return 0;
2015-11-13 06:50:09 +00:00
}
return 1;
}
static inline int MutexUnlock(Mutex* mutex) {
LeaveCriticalSection(mutex);
return GetLastError();
}
static inline int ConditionInit(Condition* cond) {
InitializeConditionVariable(cond);
return GetLastError();
}
static inline int ConditionDeinit(Condition* cond) {
// This is a no-op on Windows
UNUSED(cond);
return 0;
}
static inline int ConditionWait(Condition* cond, Mutex* mutex) {
SleepConditionVariableCS(cond, mutex, INFINITE);
return GetLastError();
}
static inline int ConditionWaitTimed(Condition* cond, Mutex* mutex, int32_t timeoutMs) {
SleepConditionVariableCS(cond, mutex, timeoutMs);
return GetLastError();
}
static inline int ConditionWake(Condition* cond) {
WakeAllConditionVariable(cond);
return GetLastError();
}
static inline int ThreadCreate(Thread* thread, ThreadEntry entry, void* context) {
*thread = CreateThread(NULL, 0, entry, context, 0, 0);
return GetLastError();
}
static inline int ThreadJoin(Thread* thread) {
DWORD error = WaitForSingleObject(*thread, INFINITE);
if (error == WAIT_FAILED) {
return GetLastError();
}
return 0;
}
static inline int ThreadSetName(const char* name) {
UNUSED(name);
return -1;
}
#endif