AuroraSupport/AuroraRuntime
2
1
Fork 0
Code Issues 27 Pull Requests Releases Wiki Activity

[*] This this this

Browse Source
This commit is contained in:
Reece Wilson 2021-11-07 20:17:08 +00:00
parent f6b254e436
commit 22103a8ad3
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Source/Async/ThreadPool.cpp
View File

@ -165,7 +165,7 @@ namespace Aurora::Async
size_t ThreadPool::GetThreadWorkersCount(ThreadGroup_t group) size_t ThreadPool::GetThreadWorkersCount(ThreadGroup_t group)
{ {
AU_LOCK_GUARD(rwlock_->AsReadable()); AU_LOCK_GUARD(this->rwlock_->AsReadable());
return GetGroup(group)->workers.size(); return GetGroup(group)->workers.size();
} }
@ -601,7 +601,7 @@ namespace Aurora::Async
bool ThreadPool::Exiting() bool ThreadPool::Exiting()
{ {
return shuttingdown_ || GetThreadState()->exiting; return this->shuttingdown_ || GetThreadState()->exiting;
} }
AuSPtr<IWorkItem> ThreadPool::NewWorkItem(const WorkerId_t &worker, const AuSPtr<IWorkItemHandler> &task, bool supportsBlocking) AuSPtr<IWorkItem> ThreadPool::NewWorkItem(const WorkerId_t &worker, const AuSPtr<IWorkItemHandler> &task, bool supportsBlocking)
@ -651,7 +651,7 @@ namespace Aurora::Async
bool ThreadPool::Sync(WorkerId_t workerId, AuUInt32 timeoutMs, bool requireSignal) bool ThreadPool::Sync(WorkerId_t workerId, AuUInt32 timeoutMs, bool requireSignal)
{ {
AU_LOCK_GUARD(rwlock_->AsReadable()); AU_LOCK_GUARD(this->rwlock_->AsReadable());
auto group = GetGroup(workerId.first); auto group = GetGroup(workerId.first);
auto currentWorkerId = GetCurrentThread().second; auto currentWorkerId = GetCurrentThread().second;
@ -676,7 +676,7 @@ namespace Aurora::Async
void ThreadPool::Signal(WorkerId_t workerId) void ThreadPool::Signal(WorkerId_t workerId)
{ {
AU_LOCK_GUARD(rwlock_->AsReadable()); AU_LOCK_GUARD(this->rwlock_->AsReadable());
auto group = GetGroup(workerId.first); auto group = GetGroup(workerId.first);
if (workerId.second == Async::kThreadIdAny) if (workerId.second == Async::kThreadIdAny)
@ -694,7 +694,7 @@ namespace Aurora::Async
void ThreadPool::SyncAllSafe() void ThreadPool::SyncAllSafe()
{ {
AU_LOCK_GUARD(rwlock_->AsReadable()); AU_LOCK_GUARD(this->rwlock_->AsReadable());
for (const auto &re : this->threads_) for (const auto &re : this->threads_)
{ {