mutex lock add retries (#164)

alibaba · Jul 25, 2023 · e8d082e · e8d082e
1 parent ec4f49c
commit e8d082e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/thread/thread.cpp b/thread/thread.cpp
@@ -1453,8 +1453,11 @@ R"(
  }
  int mutex::lock(uint64_t timeout)
  {
- if (try_lock() == 0)
- return 0;
+ for (int tries = 0; tries < MaxTries; ++tries) {
+ if (try_lock() == 0)
+ return 0;
+ thread_yield();
+ }
  splock.lock();
  if (try_lock() == 0) {
  splock.unlock();

diff --git a/thread/thread.h b/thread/thread.h
@@ -235,6 +235,7 @@ namespace photon
  }
 
  protected:
+ static constexpr const int MaxTries = 100;
  std::atomic<thread*> owner{nullptr};
  spinlock splock;
  };