diff options
Diffstat (limited to 'Runtime/Threading/WorkThread.cpp')
| -rw-r--r-- | Runtime/Threading/WorkThread.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/Runtime/Threading/WorkThread.cpp b/Runtime/Threading/WorkThread.cpp index f9bb864..31c3ead 100644 --- a/Runtime/Threading/WorkThread.cpp +++ b/Runtime/Threading/WorkThread.cpp @@ -5,7 +5,7 @@ void WorkThread::Run() { while (true) { - _lock(m_PendingMutex) + Lock(m_PendingMutex) { for (auto iter = m_PendingJobs.begin(); iter != m_PendingJobs.end();) { @@ -13,7 +13,7 @@ void WorkThread::Run() job->Process(); if (job->IsFinished()) { - _lock(m_FinishedMutex) { + Lock(m_FinishedMutex) { m_FinishedJobs.push_back(job); } iter = m_PendingJobs.erase(iter); @@ -29,7 +29,7 @@ void WorkThread::Run() void WorkThread::Dispatch(void* param) { - _lock(m_FinishedMutex) + Lock(m_FinishedMutex) { for (int i = 0; i < m_FinishedJobs.size(); ++i) { @@ -41,7 +41,7 @@ void WorkThread::Dispatch(void* param) void WorkThread::AddJobAtEnd(Job* job) { - _lock(m_PendingMutex) + Lock(m_PendingMutex) { m_PendingJobs.push_back(job); } |