aec7ca0ce9
Fixes: https://github.com/supertuxkart/stk-code/issues/2528 Signed-off-by: Igor Gnatenko <i.gnatenko.brain@gmail.com>
190 lines
4.3 KiB
C++
190 lines
4.3 KiB
C++
/*
|
|
AngelCode Scripting Library
|
|
Copyright (c) 2003-2017 Andreas Jonsson
|
|
|
|
This software is provided 'as-is', without any express or implied
|
|
warranty. In no event will the authors be held liable for any
|
|
damages arising from the use of this software.
|
|
|
|
Permission is granted to anyone to use this software for any
|
|
purpose, including commercial applications, and to alter it and
|
|
redistribute it freely, subject to the following restrictions:
|
|
|
|
1. The origin of this software must not be misrepresented; you
|
|
must not claim that you wrote the original software. If you use
|
|
this software in a product, an acknowledgment in the product
|
|
documentation would be appreciated but is not required.
|
|
|
|
2. Altered source versions must be plainly marked as such, and
|
|
must not be misrepresented as being the original software.
|
|
|
|
3. This notice may not be removed or altered from any source
|
|
distribution.
|
|
|
|
The original version of this library can be located at:
|
|
http://www.angelcode.com/angelscript/
|
|
|
|
Andreas Jonsson
|
|
andreas@angelcode.com
|
|
*/
|
|
|
|
|
|
|
|
//
|
|
// as_criticalsection.h
|
|
//
|
|
// Classes for multi threading support
|
|
//
|
|
|
|
#ifndef AS_CRITICALSECTION_H
|
|
#define AS_CRITICALSECTION_H
|
|
|
|
#include "as_config.h"
|
|
|
|
BEGIN_AS_NAMESPACE
|
|
|
|
#ifdef AS_NO_THREADS
|
|
|
|
#define DECLARECRITICALSECTION(x)
|
|
#define ENTERCRITICALSECTION(x)
|
|
#define LEAVECRITICALSECTION(x)
|
|
|
|
inline bool tryEnter() { return true; }
|
|
#define TRYENTERCRITICALSECTION(x) tryEnter()
|
|
|
|
#define DECLAREREADWRITELOCK(x)
|
|
#define ACQUIREEXCLUSIVE(x)
|
|
#define RELEASEEXCLUSIVE(x)
|
|
#define ACQUIRESHARED(x)
|
|
#define RELEASESHARED(x)
|
|
|
|
#else
|
|
|
|
#define DECLARECRITICALSECTION(x) asCThreadCriticalSection x;
|
|
#define ENTERCRITICALSECTION(x) x.Enter()
|
|
#define LEAVECRITICALSECTION(x) x.Leave()
|
|
#define TRYENTERCRITICALSECTION(x) x.TryEnter()
|
|
|
|
#define DECLAREREADWRITELOCK(x) asCThreadReadWriteLock x;
|
|
#define ACQUIREEXCLUSIVE(x) x.AcquireExclusive()
|
|
#define RELEASEEXCLUSIVE(x) x.ReleaseExclusive()
|
|
#define ACQUIRESHARED(x) x.AcquireShared()
|
|
#define RELEASESHARED(x) x.ReleaseShared()
|
|
|
|
#ifdef AS_POSIX_THREADS
|
|
|
|
END_AS_NAMESPACE
|
|
#include <pthread.h>
|
|
BEGIN_AS_NAMESPACE
|
|
|
|
class asCThreadCriticalSection
|
|
{
|
|
public:
|
|
asCThreadCriticalSection();
|
|
~asCThreadCriticalSection();
|
|
|
|
void Enter();
|
|
void Leave();
|
|
bool TryEnter();
|
|
|
|
protected:
|
|
pthread_mutex_t cs;
|
|
};
|
|
|
|
class asCThreadReadWriteLock
|
|
{
|
|
public:
|
|
asCThreadReadWriteLock();
|
|
~asCThreadReadWriteLock();
|
|
|
|
void AcquireExclusive();
|
|
void ReleaseExclusive();
|
|
bool TryAcquireExclusive();
|
|
|
|
void AcquireShared();
|
|
void ReleaseShared();
|
|
bool TryAcquireShared();
|
|
|
|
protected:
|
|
pthread_rwlock_t lock;
|
|
};
|
|
|
|
#elif defined(AS_WINDOWS_THREADS)
|
|
|
|
END_AS_NAMESPACE
|
|
#ifdef AS_XBOX360
|
|
#include <xtl.h>
|
|
#else
|
|
#ifndef WIN32_LEAN_AND_MEAN
|
|
#define WIN32_LEAN_AND_MEAN
|
|
#endif
|
|
#ifndef _WIN32_WINNT
|
|
#define _WIN32_WINNT 0x0600 // We need this to get the declaration for Windows Phone compatible Ex functions
|
|
#endif
|
|
#include <windows.h>
|
|
#endif
|
|
BEGIN_AS_NAMESPACE
|
|
|
|
// Undefine macros that cause problems in our code
|
|
#undef GetObject
|
|
#undef RegisterClass
|
|
|
|
class asCThreadCriticalSection
|
|
{
|
|
public:
|
|
asCThreadCriticalSection();
|
|
~asCThreadCriticalSection();
|
|
|
|
void Enter();
|
|
void Leave();
|
|
bool TryEnter();
|
|
|
|
protected:
|
|
CRITICAL_SECTION cs;
|
|
};
|
|
|
|
class asCThreadReadWriteLock
|
|
{
|
|
public:
|
|
asCThreadReadWriteLock();
|
|
~asCThreadReadWriteLock();
|
|
|
|
void AcquireExclusive();
|
|
void ReleaseExclusive();
|
|
|
|
void AcquireShared();
|
|
void ReleaseShared();
|
|
|
|
protected:
|
|
// The Slim Read Write Lock object, SRWLOCK, is more efficient
|
|
// but it is only available from Windows Vista so we cannot use it and
|
|
// maintain compatibility with olders versions of Windows.
|
|
|
|
// Critical sections and semaphores are available on Windows XP and onwards.
|
|
// Windows XP is oldest version we support with multithreading.
|
|
|
|
// The implementation is based on the following article, that shows
|
|
// how to implement a fair read/write lock that doesn't risk starving
|
|
// the writers:
|
|
|
|
// http://doc.qt.nokia.com/qq/qq11-mutex.html
|
|
|
|
// TODO: Allow use of SRWLOCK through configuration in as_config.h
|
|
|
|
CRITICAL_SECTION writeLock;
|
|
HANDLE readLocks;
|
|
};
|
|
|
|
// This constant really should be a member of asCThreadReadWriteLock,
|
|
// but it gives a compiler error on MSVC6 so I'm leaving it outside
|
|
static const asUINT maxReaders = 10;
|
|
|
|
#endif
|
|
|
|
#endif
|
|
|
|
END_AS_NAMESPACE
|
|
|
|
#endif
|
|
|