123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113 |
- #pragma once
-
- #include "../C/Baselib_Lock.h"
- #include "Internal/ScopedAcquireMixin.h"
- #include "Time.h"
-
- namespace baselib
- {
- BASELIB_CPP_INTERFACE
- {
- // In computer science, a lock or mutex (from mutual exclusion) is a synchronization mechanism for enforcing limits on access to a resource in an environment
- // where there are many threads of execution. A lock is designed to enforce a mutual exclusion concurrency control policy.
- //
- // "Lock (computer science)", Wikipedia: The Free Encyclopedia
- // https://en.wikipedia.org/w/index.php?title=Lock_(computer_science)&oldid=875674239
- class Lock : public detail::ScopedAcquireMixin<Lock>
- {
- public:
- // non-copyable
- Lock(const Lock& other) = delete;
- Lock& operator=(const Lock& other) = delete;
-
- // non-movable (strictly speaking not needed but listed to signal intent)
- Lock(Lock&& other) = delete;
- Lock& operator=(Lock&& other) = delete;
-
- // Creates a lock synchronization primitive.
- // If there are not enough system resources to create a lock, process abort is triggered.
- Lock()
- {
- Baselib_Lock_CreateInplace(&m_LockData);
- }
-
- // Reclaim resources and memory held by lock.
- // If threads are waiting on the lock, calling free may trigger an assert and may cause process abort.
- ~Lock()
- {
- Baselib_Lock_FreeInplace(&m_LockData);
- }
-
- // Acquire lock.
- //
- // If lock is held, either by this or another thread, then the function wait for lock to be released.
- //
- // This function is guaranteed to emit an acquire barrier.
- //
- // \param maxSpinCount Max number of times to spin in user space before falling back to the kernel. The actual number
- // may differ depending on the underlying implementation but will never exceed the maxSpinCount
- // value.
- inline void Acquire(const uint32_t maxSpinCount = 0)
- {
- if (maxSpinCount && Baselib_Lock_TrySpinAcquire(&m_LockData, maxSpinCount))
- return;
-
- return Baselib_Lock_Acquire(&m_LockData);
- }
-
- // Try to acquire locks.
- //
- // If lock is held, either by this or another thread, then lock is not acquired and function return false.
- //
- // When a lock is acquired this function is guaranteed to emit an acquire barrier.
- //
- // \param maxSpinCount Max number of times to spin in user space before falling back to the kernel. The actual number
- // may differ depending on the underlying implementation but will never exceed the maxSpinCount
- // value.
- // \returns true if lock was acquired.
- COMPILER_WARN_UNUSED_RESULT
- FORCE_INLINE bool TryAcquire(const uint32_t maxSpinCount = 0)
- {
- return Baselib_Lock_TrySpinAcquire(&m_LockData, maxSpinCount);
- }
-
- // Try to acquire lock.
- // If lock is held, either by this or another thread, then the function wait for timeoutInMilliseconds for lock to be released.
- //
- // When a lock is acquired this function is guaranteed to emit an acquire barrier.
- //
- // TryAcquire with a zero timeout differs from TryAcquire() in that TryAcquire() is guaranteed to be a user space operation
- // while TryAcquire with zero timeout may enter the kernel and cause a context switch.
- //
- // Timeout passed to this function may be subject to system clock resolution.
- // If the system clock has a resolution of e.g. 16ms that means this function may exit with a timeout error 16ms earlier than originally scheduled.
- //
- // \param maxSpinCount Max number of times to spin in user space before falling back to the kernel. The actual number
- // may differ depending on the underlying implementation but will never exceed the maxSpinCount
- // value.
- // \returns true if lock was acquired.
- COMPILER_WARN_UNUSED_RESULT
- FORCE_INLINE bool TryTimedAcquire(const timeout_ms timeoutInMilliseconds, const uint32_t maxSpinCount = 0)
- {
- if (maxSpinCount && Baselib_Lock_TrySpinAcquire(&m_LockData, maxSpinCount))
- return true;
-
- return Baselib_Lock_TryTimedAcquire(&m_LockData, timeoutInMilliseconds.count());
- }
-
- // Release lock and make it available to other threads.
- //
- // This function can be called from any thread, not only the thread that acquired the lock.
- // If no lock was previously held calling this function result in a no-op.
- //
- // When the lock is released this function is guaranteed to emit a release barrier.
- FORCE_INLINE void Release()
- {
- return Baselib_Lock_Release(&m_LockData);
- }
-
- private:
- Baselib_Lock m_LockData;
- };
- }
- }
|