summaryrefslogtreecommitdiff
path: root/Source/WTF/wtf/ParallelJobsGeneric.cpp
diff options
context:
space:
mode:
authorLorry Tar Creator <lorry-tar-importer@lorry>2017-06-27 06:07:23 +0000
committerLorry Tar Creator <lorry-tar-importer@lorry>2017-06-27 06:07:23 +0000
commit1bf1084f2b10c3b47fd1a588d85d21ed0eb41d0c (patch)
tree46dcd36c86e7fbc6e5df36deb463b33e9967a6f7 /Source/WTF/wtf/ParallelJobsGeneric.cpp
parent32761a6cee1d0dee366b885b7b9c777e67885688 (diff)
downloadWebKitGtk-tarball-master.tar.gz
Diffstat (limited to 'Source/WTF/wtf/ParallelJobsGeneric.cpp')
-rw-r--r--Source/WTF/wtf/ParallelJobsGeneric.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/Source/WTF/wtf/ParallelJobsGeneric.cpp b/Source/WTF/wtf/ParallelJobsGeneric.cpp
index 2cc0bc643..4023f43e6 100644
--- a/Source/WTF/wtf/ParallelJobsGeneric.cpp
+++ b/Source/WTF/wtf/ParallelJobsGeneric.cpp
@@ -105,17 +105,17 @@ bool ParallelEnvironment::ThreadPrivate::tryLockFor(ParallelEnvironment* parent)
void ParallelEnvironment::ThreadPrivate::execute(ThreadFunction threadFunction, void* parameters)
{
- MutexLocker lock(m_mutex);
+ LockHolder lock(m_mutex);
m_threadFunction = threadFunction;
m_parameters = parameters;
m_running = true;
- m_threadCondition.signal();
+ m_threadCondition.notifyOne();
}
void ParallelEnvironment::ThreadPrivate::waitForFinish()
{
- MutexLocker lock(m_mutex);
+ LockHolder lock(m_mutex);
while (m_running)
m_threadCondition.wait(m_mutex);
@@ -124,14 +124,14 @@ void ParallelEnvironment::ThreadPrivate::waitForFinish()
void ParallelEnvironment::ThreadPrivate::workerThread(void* threadData)
{
ThreadPrivate* sharedThread = reinterpret_cast<ThreadPrivate*>(threadData);
- MutexLocker lock(sharedThread->m_mutex);
+ LockHolder lock(sharedThread->m_mutex);
while (sharedThread->m_threadID) {
if (sharedThread->m_running) {
(*sharedThread->m_threadFunction)(sharedThread->m_parameters);
sharedThread->m_running = false;
sharedThread->m_parent = 0;
- sharedThread->m_threadCondition.signal();
+ sharedThread->m_threadCondition.notifyOne();
}
sharedThread->m_threadCondition.wait(sharedThread->m_mutex);