From 5566c5dff4d6430f704aeb66ca45615cb0df0176 Mon Sep 17 00:00:00 2001 From: Nicolas James Date: Wed, 8 Apr 2026 14:04:03 +1000 Subject: Reduce thread contention by introducing an atomic time point class - greatly reduces locking --- src/atomic_time_point.cc | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 src/atomic_time_point.cc (limited to 'src/atomic_time_point.cc') diff --git a/src/atomic_time_point.cc b/src/atomic_time_point.cc new file mode 100644 index 0000000..4aaef7f --- /dev/null +++ b/src/atomic_time_point.cc @@ -0,0 +1,27 @@ +#include "atomic_time_point.hh" + +#include + +namespace low_latency { + +AtomicTimePoint::AtomicTimePoint() {} + +AtomicTimePoint::~AtomicTimePoint() {} + +bool AtomicTimePoint::has_value() const { + return this->count.load(std::memory_order_relaxed); +} + +std::chrono::steady_clock::time_point AtomicTimePoint::get() const { + const auto result = this->count.load(std::memory_order_relaxed); + assert(result); + using namespace std::chrono; + return steady_clock::time_point{steady_clock::duration{result}}; +} + +void AtomicTimePoint::set(const std::chrono::steady_clock::time_point target) { + this->count.store(target.time_since_epoch().count(), + std::memory_order_relaxed); +} + +} // namespace low_latency \ No newline at end of file -- cgit v1.2.3