Page MenuHomePhabricator (Chris)
Files F630230

threads_windows.cpp
No OneTemporary
Actions

Authored By
Unknown
Size
3 KB
Referenced Files
None
Subscribers
None

threads_windows.cpp
View Options

#include "threads.h"
#include <Windows.h>
#include <intrin.h>
namespace threads {
atomic_int nextThreadID(1);
const int invalidThreadID = 0;
Threaded(int) threadID = invalidThreadID;
int getThreadID() {
if(threadID == invalidThreadID) {
threadID = nextThreadID++;
return threadID;
}
else {
return threadID;
}
}
void setThreadPriority(ThreadPriority priority) {
int priority_val;
switch(priority) {
case TP_High:
priority_val = THREAD_PRIORITY_ABOVE_NORMAL; break;
case TP_Normal: default:
priority_val = THREAD_PRIORITY_NORMAL; break;
case TP_Low:
priority_val = THREAD_PRIORITY_BELOW_NORMAL; break;
}
SetThreadPriority(GetCurrentThread(), priority_val);
}
void createThread(unsigned long threadcall entry(void*), void* arg) {
CreateThread(NULL, 0, entry, arg, 0, NULL);
}
int atomic_int::operator++() {
return _InterlockedIncrement(&value);
}
int atomic_int::operator++(int) {
return (int)_InterlockedIncrement(&value) - 1;
}
int atomic_int::operator--() {
return (int)_InterlockedDecrement(&value);
}
int atomic_int::operator--(int) {
return (int)_InterlockedDecrement(&value) + 1;
}
int atomic_int::operator+=(int _add) {
return (int)_InterlockedExchangeAdd(&value, (long)_add);
}
int atomic_int::operator-=(int _sub) {
return (int)_InterlockedExchangeAdd(&value, -(long)_sub);
}
int atomic_int::operator&=(int mask) {
return (int)_InterlockedAnd(&value, (long)mask);
}
int atomic_int::operator|=(int mask) {
return (int)_InterlockedOr(&value, (long)mask);
}
void atomic_int::operator=(int _value) {
value = _value;
}
int atomic_int::exchange(int _xchg) {
return (int)_InterlockedExchange(&value, (long)_xchg);
}
int atomic_int::compare_exchange_strong(int _xchg, int compareTo) {
return (int)_InterlockedCompareExchange(&value, (long)_xchg, (long)compareTo);
}
int atomic_int::get_basic() {
return value;
}
void atomic_int::set_basic(int val) {
value = val;
}
_threadlocalPointer::_threadlocalPointer() : index(TlsAlloc()) {
}
_threadlocalPointer::~_threadlocalPointer() {
TlsFree(index);
}
void _threadlocalPointer::set(void* ptr) {
TlsSetValue(index, ptr);
}
void* _threadlocalPointer::get() {
return TlsGetValue(index);
}
unsigned getNumberOfProcessors() {
SYSTEM_INFO info;
GetSystemInfo(&info);
return info.dwNumberOfProcessors;
}
void sleep(unsigned int milliseconds) {
Sleep(milliseconds);
}
void idle() {
Sleep(1);
}
int swap(int* ptr, int newval) {
return (int)_InterlockedExchange((long*)ptr, (long)newval);
}
int compare_and_swap(int* ptr, int oldval, int newval) {
return (int)_InterlockedCompareExchange((long*)ptr, (long)newval, (long)oldval);
}
//long long swap(long long* ptr, long long newval) {
// return _InterlockedExchange64(ptr, newval);
//}
long long compare_and_swap(long long* ptr, long long oldval, long long newval) {
return _InterlockedCompareExchange64(ptr, newval, oldval);
}
#ifdef _M_AMD64
void* swap(void** ptr, void* newval) {
return (void*)_InterlockedExchange64((long long*)ptr, (long long)newval);
}
void* compare_and_swap(void** ptr, void* oldval, void* newval) {
return (void*)_InterlockedCompareExchange64((long long*)ptr, (long long)newval, (long long)oldval);
}
#else
void* swap(void** ptr, void* newval) {
return (void*)_InterlockedExchange((long*)ptr, (long)newval);
}
void* compare_and_swap(void** ptr, void* oldval, void* newval) {
return (void*)_InterlockedCompareExchange((long*)ptr, (long)newval, (long)oldval);
}
#endif
};

File Metadata

Mime Type
text/x-c++
Expires
Sun, Nov 15, 9:00 AM (1 h, 2 s)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
133837
Default Alt Text
threads_windows.cpp (3 KB)

Event Timeline