X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fthreadengines%2Fthreadengine_win32.cpp;h=5666113671fb6d5a56e13912dda73fc78cd4d7d3;hb=82bf46fa061a4f18071e73756e4e0d618eb57320;hp=1b8d113ec25654096de18936ff591e2d9f997301;hpb=1c2b47abadc0907c4642557910b6480150f279d2;p=user%2Fhenk%2Fcode%2Finspircd.git

diff --git a/src/threadengines/threadengine_win32.cpp b/src/threadengines/threadengine_win32.cpp
index 1b8d113ec..566611367 100644
--- a/src/threadengines/threadengine_win32.cpp
+++ b/src/threadengines/threadengine_win32.cpp
@@ -27,16 +27,20 @@ void Win32ThreadEngine::Create(Thread* thread_to_init)
 	HANDLE* MyThread = new HANDLE;
 	DWORD ThreadId = 0;
 
-	if (!(*MyThread = CreateThread(NULL,0,Win32ThreadEngine::Entry,this,0,&ThreadId)))
+	if (NULL == (*MyThread = CreateThread(NULL,0,Win32ThreadEngine::Entry,this,0,&ThreadId)))
 	{
 		delete MyThread;
 		Mutex(false);
-		throw CoreException(std::string("Unable to reate new Win32ThreadEngine: ") + dlerror());
+		throw CoreException(std::string("Unable to create new Win32ThreadEngine: ") + dlerror());
 	}
+
 	NewThread = thread_to_init;
 	NewThread->Creator = this;
 	NewThread->Extend("winthread", MyThread);
 	Mutex(false);
+
+	while (NewThread)
+		SleepEx(100, false);
 }
 
 Win32ThreadEngine::~Win32ThreadEngine()
@@ -46,7 +50,11 @@ Win32ThreadEngine::~Win32ThreadEngine()
 
 void Win32ThreadEngine::Run()
 {
-	NewThread->Run();
+	Mutex(true);
+	Thread* nt = NewThread;
+	NewThread = NULL;
+	Mutex(false);
+	nt->Run();
 }
 
 bool Win32ThreadEngine::Mutex(bool enable)
@@ -77,3 +85,4 @@ void Win32ThreadEngine::FreeThread(Thread* thread)
 	}
 }
 
+