#include "il2cpp-config.h"
|
|
#if IL2CPP_THREADS_STD
|
|
#include "os/Thread.h"
|
#include "ThreadImpl.h"
|
|
#include <thread>
|
|
namespace il2cpp
|
{
|
namespace os
|
{
|
struct StartData
|
{
|
Thread::StartFunc m_StartFunc;
|
void* m_StartArg;
|
};
|
|
|
static void ThreadStartWrapper(void* arg)
|
{
|
StartData* startData = (StartData*)arg;
|
startData->m_StartFunc(startData->m_StartArg);
|
|
free(startData);
|
}
|
|
uint64_t ThreadImpl::Id()
|
{
|
return m_Thread.get_id().hash();
|
}
|
|
ErrorCode ThreadImpl::Run(Thread::StartFunc func, void* arg, int64_t affinityMask)
|
{
|
StartData* startData = (StartData*)malloc(sizeof(StartData));
|
startData->m_StartFunc = func;
|
startData->m_StartArg = arg;
|
|
std::thread t(ThreadStartWrapper, startData);
|
if (affinityMask != Thread::kThreadAffinityAll)
|
{
|
IL2CPP_ASSERT(0 && "Using non-default thread affinity is not supported on the STD implementation.");
|
}
|
|
m_Thread.swap(t);
|
|
return kErrorCodeSuccess;
|
}
|
|
WaitStatus ThreadImpl::Join(uint32_t ms)
|
{
|
m_Thread.join();
|
|
return kWaitStatusSuccess;
|
}
|
|
ErrorCode ThreadImpl::Sleep(uint32_t milliseconds)
|
{
|
std::chrono::milliseconds dura(milliseconds);
|
std::this_thread::sleep_for(dura);
|
|
return kErrorCodeSuccess;
|
}
|
|
uint64_t ThreadImpl::CurrentThreadId()
|
{
|
return std::this_thread::get_id().hash();
|
}
|
}
|
}
|
|
#endif
|
