140 lines
3.2 KiB
C++
140 lines
3.2 KiB
C++
#pragma once
|
|
|
|
//simple thread library
|
|
//primary rationale is that std::thread does not support custom stack sizes
|
|
//this is highly critical in certain applications such as threaded web servers
|
|
//an added bonus is that it avoids licensing issues on Windows
|
|
//win32-pthreads (needed for std::thread) is licensed under the GPL only
|
|
|
|
#include <nall/platform.hpp>
|
|
#include <nall/function.hpp>
|
|
#include <nall/intrinsics.hpp>
|
|
|
|
namespace nall {
|
|
using mutex = std::mutex;
|
|
using recursive_mutex = std::recursive_mutex;
|
|
using condition_variable = std::condition_variable;
|
|
template<typename T> using lock_guard = std::lock_guard<T>;
|
|
template<typename T> using atomic = std::atomic<T>;
|
|
template<typename T> using unique_lock = std::unique_lock<T>;
|
|
}
|
|
|
|
#if defined(API_POSIX)
|
|
|
|
#include <pthread.h>
|
|
|
|
namespace nall {
|
|
|
|
struct thread {
|
|
thread(const thread&) = delete;
|
|
auto operator=(const thread&) -> thread& = delete;
|
|
|
|
thread() = default;
|
|
thread(thread&& source) { operator=(std::move(source)); }
|
|
|
|
auto operator=(thread&& source) -> thread& {
|
|
if(this == &source) return *this;
|
|
handle = source.handle;
|
|
source.handle = 0;
|
|
return *this;
|
|
}
|
|
|
|
auto join() -> void;
|
|
|
|
static auto create(const function<void (uintptr)>& callback, uintptr parameter = 0, u32 stacksize = 0) -> thread;
|
|
static auto detach() -> void;
|
|
static auto exit() -> void;
|
|
|
|
struct context {
|
|
function<auto (uintptr) -> void> callback;
|
|
uintptr parameter = 0;
|
|
};
|
|
|
|
private:
|
|
pthread_t handle = (pthread_t)nullptr;
|
|
};
|
|
|
|
inline auto _threadCallback(void* parameter) -> void* {
|
|
auto context = (thread::context*)parameter;
|
|
context->callback(context->parameter);
|
|
delete context;
|
|
return nullptr;
|
|
}
|
|
|
|
inline auto thread::join() -> void {
|
|
if(handle) {
|
|
pthread_join(handle, nullptr);
|
|
handle = 0;
|
|
}
|
|
}
|
|
|
|
inline auto thread::create(const function<void (uintptr)>& callback, uintptr parameter, u32 stacksize) -> thread {
|
|
thread instance;
|
|
|
|
auto context = new thread::context;
|
|
context->callback = callback;
|
|
context->parameter = parameter;
|
|
|
|
pthread_attr_t attr;
|
|
pthread_attr_init(&attr);
|
|
if(stacksize) pthread_attr_setstacksize(&attr, max(PTHREAD_STACK_MIN, stacksize));
|
|
|
|
pthread_create(&instance.handle, &attr, _threadCallback, (void*)context);
|
|
return instance;
|
|
}
|
|
|
|
inline auto thread::detach() -> void {
|
|
pthread_detach(pthread_self());
|
|
}
|
|
|
|
inline auto thread::exit() -> void {
|
|
pthread_exit(nullptr);
|
|
}
|
|
|
|
}
|
|
|
|
#elif defined(API_WINDOWS)
|
|
|
|
namespace nall {
|
|
|
|
struct thread {
|
|
thread(const thread&) = delete;
|
|
auto operator=(const thread&) -> thread& = delete;
|
|
|
|
thread() = default;
|
|
thread(thread&& source) { operator=(std::move(source)); }
|
|
|
|
~thread() { close(); }
|
|
|
|
auto operator=(thread&& source) -> thread& {
|
|
if(this == &source) return *this;
|
|
close();
|
|
handle = source.handle;
|
|
source.handle = 0;
|
|
return *this;
|
|
}
|
|
|
|
auto close() -> void;
|
|
auto join() -> void;
|
|
|
|
static auto create(const function<void (uintptr)>& callback, uintptr parameter = 0, u32 stacksize = 0) -> thread;
|
|
static auto detach() -> void;
|
|
static auto exit() -> void;
|
|
|
|
struct context {
|
|
function<auto (uintptr) -> void> callback;
|
|
uintptr parameter = 0;
|
|
};
|
|
|
|
private:
|
|
HANDLE handle = 0;
|
|
};
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
#if defined(NALL_HEADER_ONLY)
|
|
#include <nall/thread.cpp>
|
|
#endif
|