BRNSystems/minetest
1
0
Fork 0
forked from Mirrorlandia_minetest/minetest
Code Pull Requests 1 Activity

Fix race on thread creation

Browse Source 
This often broke the threading tests on OSX.
This commit is contained in:
ShadowNinja 2016-03-07 16:55:32 -05:00
parent e41673820f
commit 46fd114e9a
2 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/threading/thread.cpp
View File

@ -117,8 +117,6 @@ bool Thread::start()
try {
m_thread_obj = new std::thread(threadProc, this);
m_thread_id = m_thread_obj->get_id();
m_thread_handle = m_thread_obj->native_handle();
} catch (const std::system_error &e) {
return false;
}
@ -135,8 +133,6 @@ bool Thread::start()
if (status)
return false;
m_thread_id = m_thread_handle;
#endif
while (!m_running)
@ -234,12 +230,6 @@ bool Thread::getReturnValue(void **ret)
}
bool Thread::isCurrentThread()
{
return thr_is_current_thread(m_thread_id);
}
#if USE_CPP11_THREADS || USE_POSIX_THREADS
void *Thread::threadProc(void *param)
#elif defined(_WIN32_WCE)

18
src/threading/thread.h
View File

@ -90,12 +90,22 @@ public:
/*
* Returns true if the calling thread is this Thread object.
*/
bool isCurrentThread();
bool isCurrentThread() { return thr_is_current_thread(getThreadId()); }
inline bool isRunning() { return m_running; }
inline bool stopRequested() { return m_request_stop; }
#if USE_CPP11_THREADS
inline threadid_t getThreadId() { return m_thread_obj->get_id(); }
inline threadhandle_t getThreadHandle() { return m_thread_obj->native_handle(); }
#else
# if USE_WIN_THREADS
inline threadid_t getThreadId() { return m_thread_id; }
# else
inline threadid_t getThreadId() { return m_thread_handle; }
# endif
inline threadhandle_t getThreadHandle() { return m_thread_handle; }
#endif
/*
* Gets the thread return value.
@ -147,8 +157,12 @@ private:
Atomic<bool> m_running;
Mutex m_mutex;
threadid_t m_thread_id;
#if !USE_CPP11_THREADS
threadhandle_t m_thread_handle;
#if _WIN32
threadid_t m_thread_id;
#endif
#endif
static ThreadStartFunc threadProc;