sid
/
NazaraEngine
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Seems more correct 

Former-commit-id: fa83f37d65c97bd5bfb7840865fab0e838804c30
This commit is contained in:
Youri Hubaut 2015-05-16 13:28:28 +02:00
parent 2cb669a558
commit 2cb6fca127
2 changed files with 12 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/Nazara/Core/Posix/TaskSchedulerImpl.cpp
View File

@ -76,17 +76,14 @@ void NzTaskSchedulerImpl::Uninitialize()
}
#endif
// On réveille les threads pour qu'ils sortent de la boucle et terminent.
pthread_mutex_lock(&s_mutexQueue);
// On commence par vider la queue et demander qu'ils s'arrêtent.
std::queue<NzFunctor*> emptyQueue;
std::swap(s_tasks, emptyQueue);
s_shouldFinish = true;
ClearQueue();
{
// On réveille les threads pour qu'ils sortent de la boucle et terminent.
pthread_mutex_lock(&s_mutexQueue);
pthread_cond_broadcast(&s_cvNotEmpty);
pthread_mutex_unlock(&s_mutexQueue);
}
pthread_cond_broadcast(&s_cvNotEmpty);
pthread_mutex_unlock(&s_mutexQueue);
// On attend que chaque thread se termine
for (unsigned int i = 0; i < s_workerCount; ++i)
@ -114,14 +111,6 @@ void NzTaskSchedulerImpl::WaitForTasks()
Wait();
}
void NzTaskSchedulerImpl::ClearQueue()
{
pthread_mutex_lock(&s_mutexQueue);
std::queue<NzFunctor*> emptyQueue;
std::swap(s_tasks, emptyQueue);
pthread_mutex_unlock(&s_mutexQueue);
}
NzFunctor* NzTaskSchedulerImpl::PopQueue()
{
NzFunctor* task = nullptr;
@ -144,14 +133,12 @@ void NzTaskSchedulerImpl::Wait()
if (s_isDone)
return;
if (!s_isDone)
{
s_isWaiting = true;
pthread_mutex_lock(&s_mutexQueue);
pthread_cond_broadcast(&s_cvNotEmpty);
pthread_cond_wait(&s_cvEmpty, &s_mutexQueue);
pthread_mutex_unlock(&s_mutexQueue);
}
pthread_mutex_lock(&s_mutexQueue);
s_isWaiting = true;
pthread_cond_broadcast(&s_cvNotEmpty);
pthread_cond_wait(&s_cvEmpty, &s_mutexQueue);
pthread_mutex_unlock(&s_mutexQueue);
s_isDone = true;
}

1
src/Nazara/Core/Posix/TaskSchedulerImpl.hpp
View File

@ -27,7 +27,6 @@ class NzTaskSchedulerImpl
static void WaitForTasks();
private:
static void ClearQueue();
static NzFunctor* PopQueue();
static void Wait();
static void* WorkerProc(void* userdata);