Refacotor spinlocks to make it simpler to insert actions after CAS fails.

lib/pls/src/internal/base/tas_spin_lock.cpp

@@ -8,26 +8,34 @@ namespace base {
 void tas_spin_lock::lock() {
 void tas_spin_lock::lock() {
   PROFILE_LOCK("Acquire Lock")
   PROFILE_LOCK("Acquire Lock")
   int tries = 0;
   int tries = 0;
-  while (flag_.test_and_set(std::memory_order_acquire)) {
+  while (true) {
     tries++;
     tries++;
     if (tries % yield_at_tries_ == 0) {
     if (tries % yield_at_tries_ == 0) {
       this_thread::yield();
       this_thread::yield();
     }
     }
+
+    if (flag_.test_and_set(std::memory_order_acquire) == 0) {
+      return;
+    }
   }
   }
 }
 }
 
 
 bool tas_spin_lock::try_lock(unsigned int num_tries) {
 bool tas_spin_lock::try_lock(unsigned int num_tries) {
   PROFILE_LOCK("Try Acquire Lock")
   PROFILE_LOCK("Try Acquire Lock")
-  while (flag_.test_and_set(std::memory_order_acquire)) {
+  while (true) {
     num_tries--;
     num_tries--;
     if (num_tries <= 0) {
     if (num_tries <= 0) {
       return false;
       return false;
     }
     }
+
+    if (flag_.test_and_set(std::memory_order_acquire) == 0) {
+      return true;
+    }
   }
   }
-  return true;
 }
 }
 
 
 void tas_spin_lock::unlock() {
 void tas_spin_lock::unlock() {
+  PROFILE_LOCK("Unlock")
   flag_.clear(std::memory_order_release);
   flag_.clear(std::memory_order_release);
 }
 }
 
 

lib/pls/src/internal/base/ttas_spin_lock.cpp

@@ -10,7 +10,7 @@ void ttas_spin_lock::lock() {
   int tries = 0;
   int tries = 0;
   int expected = 0;
   int expected = 0;
 
 
-  do {
+  while (true) {
     while (flag_.load(std::memory_order_relaxed) == 1) {
     while (flag_.load(std::memory_order_relaxed) == 1) {
       tries++;
       tries++;
       if (tries % yield_at_tries_ == 0) {
       if (tries % yield_at_tries_ == 0) {
@@ -19,14 +19,17 @@ void ttas_spin_lock::lock() {
     }
     }
 
 
     expected = 0;
     expected = 0;
-  } while (!flag_.compare_exchange_weak(expected, 1, std::memory_order_acquire));
+    if (flag_.compare_exchange_weak(expected, 1, std::memory_order_acquire)) {
+      return;
+    }
+  }
 }
 }
 
 
 bool ttas_spin_lock::try_lock(unsigned int num_tries) {
 bool ttas_spin_lock::try_lock(unsigned int num_tries) {
   PROFILE_LOCK("Try Acquire Lock")
   PROFILE_LOCK("Try Acquire Lock")
   int expected = 0;
   int expected = 0;
 
 
-  do {
+  while (true) {
     while (flag_.load(std::memory_order_relaxed) == 1) {
     while (flag_.load(std::memory_order_relaxed) == 1) {
       num_tries--;
       num_tries--;
       if (num_tries <= 0) {
       if (num_tries <= 0) {
@@ -35,12 +38,14 @@ bool ttas_spin_lock::try_lock(unsigned int num_tries) {
     }
     }
 
 
     expected = 0;
     expected = 0;
-  } while (!flag_.compare_exchange_weak(expected, 1, std::memory_order_acquire));
-
-  return true;
+    if (flag_.compare_exchange_weak(expected, 1, std::memory_order_acquire)) {
+      return true;
+    }
+  }
 }
 }
 
 
 void ttas_spin_lock::unlock() {
 void ttas_spin_lock::unlock() {
+  PROFILE_LOCK("Unlock")
   flag_.store(0, std::memory_order_release);
   flag_.store(0, std::memory_order_release);
 }
 }