vkd3d: Add simple pthread wrapper for MSVC.

Signed-off-by: Hans-Kristian Arntzen <post@arntzen-software.no>
This commit is contained in:
Hans-Kristian Arntzen 2019-10-01 12:15:05 +02:00
parent 26a82afbc4
commit 97a7748020
1 changed files with 165 additions and 0 deletions

View File

@ -0,0 +1,165 @@
/*
* Copyright 2019 Hans-Kristian Arntzen for Valve
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
*/
#ifndef __VKD3D_THREADS_H
#define __VKD3D_THREADS_H
#include "config.h"
#if defined(HAVE_PTHREAD_H)
#include <pthread.h>
#elif defined(_WIN32) /* HAVE_PTHREAD_H */
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
/* pthread_t is passed by value in some functions,
* which implies we need pthread_t to be a pointer type here. */
struct pthread
{
HANDLE thread;
DWORD id;
void * (*routine)(void *);
void *arg;
};
typedef struct pthread *pthread_t;
/* pthread_mutex_t is not copyable, so embed CS inline. */
typedef struct pthread_mutex
{
CRITICAL_SECTION lock;
} pthread_mutex_t;
/* pthread_cond_t is not copyable, so embed CV inline. */
typedef struct pthread_cond
{
CONDITION_VARIABLE cond;
} pthread_cond_t;
static DWORD WINAPI win32_thread_wrapper_routine(void *arg)
{
pthread_t thread = arg;
thread->routine(thread->arg);
return 0;
}
static inline int pthread_create(pthread_t *out_thread, void *attr, void * (*thread_fun)(void *), void *arg)
{
pthread_t thread = vkd3d_calloc(1, sizeof(*thread));
if (!thread)
return -1;
(void)attr;
thread->routine = thread_fun;
thread->arg = arg;
thread->thread = CreateThread(NULL, 0, win32_thread_wrapper_routine, thread, 0, &thread->id);
if (!thread->thread)
{
vkd3d_free(thread);
return -1;
}
*out_thread = thread;
return 0;
}
static inline int pthread_join(pthread_t thread, void **ret)
{
(void)ret;
int success = WaitForSingleObject(thread->thread, INFINITE) == WAIT_OBJECT_0;
if (success)
{
CloseHandle(thread->thread);
vkd3d_free(thread);
}
return success ? 0 : -1;
}
static inline int pthread_mutex_init(pthread_mutex_t *lock, void *attr)
{
(void)attr;
InitializeCriticalSection(&lock->lock);
return 0;
}
static inline int pthread_mutex_lock(pthread_mutex_t *lock)
{
EnterCriticalSection(&lock->lock);
return 0;
}
static inline int pthread_mutex_unlock(pthread_mutex_t *lock)
{
LeaveCriticalSection(&lock->lock);
return 0;
}
static inline int pthread_mutex_destroy(pthread_mutex_t *lock)
{
DeleteCriticalSection(&lock->lock);
return 0;
}
static inline int pthread_cond_init(pthread_cond_t *cond, void *attr)
{
(void)attr;
InitializeConditionVariable(&cond->cond);
return 0;
}
static inline void pthread_cond_destroy(pthread_cond_t *cond)
{
(void)cond;
}
static inline int pthread_cond_signal(pthread_cond_t *cond)
{
WakeConditionVariable(&cond->cond);
return 0;
}
static inline int pthread_cond_broadcast(pthread_cond_t *cond)
{
WakeAllConditionVariable(&cond->cond);
return 0;
}
static inline int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *lock)
{
bool ret = SleepConditionVariableCS(&cond->cond, &lock->lock, INFINITE);
return ret ? 0 : -1;
}
#else /* HAVE_PTHREAD_H */
#error "Threads are not supported. Cannot build."
#endif /* HAVE_PTHREAD_H */
static inline void vkd3d_set_thread_name(const char *name)
{
#if defined(_MSC_VER)
(void)name;
#elif defined(HAVE_PTHREAD_SETNAME_NP_2)
pthread_setname_np(pthread_self(), name);
#elif defined(HAVE_PTHREAD_SETNAME_NP_1)
pthread_setname_np(name);
#else
(void)name;
#endif
}
#endif /* __VKD3D_THREADS_H */