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

[*] cleanup: added gUseNativeWaitSemapahore

Browse Source
This commit is contained in:
Reece Wilson 2023-06-16 00:05:46 +01:00
parent 25b933aafa
commit 48075bfda7
4 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Source/AuProcAddresses.NT.cpp
View File

@ -90,5 +90,7 @@ namespace Aurora
!gRuntimeConfig.threadingConfig.bPerferNt51XpCondvarsOver8 && !gRuntimeConfig.threadingConfig.bPerferNt51XpCondvarsOver8 &&
(pRtlWaitOnAddress || AuBuild::kCurrentPlatform != AuBuild::EPlatform::ePlatformWin32)) || (pRtlWaitOnAddress || AuBuild::kCurrentPlatform != AuBuild::EPlatform::ePlatformWin32)) ||
!pNtWaitForKeyedEvent; !pNtWaitForKeyedEvent;
gUseNativeWaitSemapahore = bool(pWaitOnAddress);
} }
} }

1
Source/AuProcAddresses.NT.hpp
View File

@ -106,4 +106,5 @@ namespace Aurora
inline bool gUseNativeWaitMutex {}; inline bool gUseNativeWaitMutex {};
inline bool gUseNativeWaitCondvar {}; inline bool gUseNativeWaitCondvar {};
inline bool gUseNativeWaitSemapahore {};
} }

2
Source/AuProcAddresses.hpp
View File

@ -14,4 +14,6 @@
namespace Aurora namespace Aurora
{ {
void InitProcAddresses(); void InitProcAddresses();
inline bool gUseNativeWaitRWLock {};
} }

28
Source/Threading/Primitives/AuSemaphore.NT.cpp
View File

@ -65,7 +65,7 @@ namespace Aurora::Threading::Primitives
AuUInt64 uStart = AuTime::SteadyClockNS(); AuUInt64 uStart = AuTime::SteadyClockNS();
AuUInt64 uEnd = uTimeout ? uStart + uTimeout : 0; AuUInt64 uEnd = uTimeout ? uStart + uTimeout : 0;
if (pWaitOnAddress) if (gUseNativeWaitSemapahore)
{ {
AuUInt32 uYieldCounter {}; AuUInt32 uYieldCounter {};
auto old = this->value_; auto old = this->value_;
@ -120,9 +120,21 @@ namespace Aurora::Threading::Primitives
void SemaphoreImpl::Unlock(long count) void SemaphoreImpl::Unlock(long count)
{ {
if (!pWaitOnAddress) if (gUseNativeWaitSemapahore)
{ {
AuAtomicAdd<AuInt32>(&this->value_, count);
if (count == 1)
{
pWakeByAddressSingle(&this->value_);
}
else
{
pWakeByAddressAll(&this->value_);
}
this->mutex.Lock(); this->mutex.Lock();
}
else
{
AuAtomicAdd<AuInt32>(&this->value_, count); AuAtomicAdd<AuInt32>(&this->value_, count);
if (count == 1) if (count == 1)
@ -139,18 +151,6 @@ namespace Aurora::Threading::Primitives
} }
this->mutex.Unlock(); this->mutex.Unlock();
} }
else
{
AuAtomicAdd<AuInt32>(&this->value_, count);
if (count == 1)
{
pWakeByAddressSingle(&this->value_);
}
else
{
pWakeByAddressAll(&this->value_);
}
}
} }
void SemaphoreImpl::Unlock() void SemaphoreImpl::Unlock()