diff options
author | chai <chaifix@163.com> | 2021-10-26 09:48:47 +0800 |
---|---|---|
committer | chai <chaifix@163.com> | 2021-10-26 09:48:47 +0800 |
commit | ef7aedf5f272c52247d8ee9522d7b2896d21af63 (patch) | |
tree | c1259190bd51ed1225017507cd01612cc5a73a8c /Runtime/Threading/WorkThread.cpp | |
parent | e7c760c884d90ef22fe46508b18081fe6e0f9291 (diff) |
*misc
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); } |