++

Zainullin Damir · Zainullin Damir · commit 37e30a8ee316 · 2026-03-09T14:56:40.000+01:00
diff --git a/include/ipfixprobe/outputPlugin/outputStorage/spinlock.hpp b/include/ipfixprobe/outputPlugin/outputStorage/spinlock.hpp
@@ -1,5 +1,7 @@
 #pragma once
 
+#include "backoffScheme.hpp"
+
 #include <atomic>
 #include <cstddef>
 #include <cstdint>
@@ -13,9 +15,10 @@ class Spinlock {
 public:
 	void lock() noexcept
 	{
+		BackoffScheme backoffScheme(20, std::numeric_limits<std::size_t>::max());
 		while (flag.test(std::memory_order_relaxed)
 			   || flag.test_and_set(std::memory_order_acquire)) {
-			std::this_thread::yield();
+			backoffScheme.backoff();
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,7 @@`
`1`	`1`	`#pragma once`
`2`	`2`
	`3`	`+#include "backoffScheme.hpp"`
	`4`	`+`
`3`	`5`	`#include <atomic>`
`4`	`6`	`#include <cstddef>`
`5`	`7`	`#include <cstdint>`
`@@ -13,9 +15,10 @@ class Spinlock {`
`13`	`15`	`public:`
`14`	`16`	`void lock() noexcept`
`15`	`17`	`{`
	`18`	`+ BackoffScheme backoffScheme(20, std::numeric_limits<std::size_t>::max());`
`16`	`19`	`while (flag.test(std::memory_order_relaxed)`
`17`	`20`	`\|\| flag.test_and_set(std::memory_order_acquire)) {`
`18`		`- std::this_thread::yield();`
	`21`	`+ backoffScheme.backoff();`
`19`	`22`	`}`
`20`	`23`	`}`
`21`	`24`