diff --git a/etcd/v3/AsyncLeaseAction.hpp b/etcd/v3/AsyncLeaseAction.hpp
index b50b98a..f8fc972 100644
--- a/etcd/v3/AsyncLeaseAction.hpp
+++ b/etcd/v3/AsyncLeaseAction.hpp
@@ -62,7 +62,7 @@ namespace etcdv3
 
       LeaseKeepAliveRequest req;
       bool isCancelled;
-      std::mutex protect_is_cancelled;
+      std::recursive_mutex protect_is_cancelled;
 
       friend class etcd::KeepAlive;
   };
diff --git a/src/v3/AsyncLeaseAction.cpp b/src/v3/AsyncLeaseAction.cpp
index 8e6f34e..8415b54 100644
--- a/src/v3/AsyncLeaseAction.cpp
+++ b/src/v3/AsyncLeaseAction.cpp
@@ -97,7 +97,7 @@ etcdv3::AsyncLeaseKeepAliveResponse etcdv3::AsyncLeaseKeepAliveAction::ParseResp
 
 etcd::Response etcdv3::AsyncLeaseKeepAliveAction::Refresh()
 {
-  std::lock_guard<std::mutex> scope_lock(this->protect_is_cancelled);
+  std::lock_guard<std::recursive_mutex> scope_lock(this->protect_is_cancelled);
 
   auto start_timepoint = std::chrono::high_resolution_clock::now();
   if (isCancelled) {
@@ -171,7 +171,7 @@ etcd::Response etcdv3::AsyncLeaseKeepAliveAction::Refresh()
 
 void etcdv3::AsyncLeaseKeepAliveAction::CancelKeepAlive()
 {
-  std::lock_guard<std::mutex> scope_lock(this->protect_is_cancelled);
+  std::lock_guard<std::recursive_mutex> scope_lock(this->protect_is_cancelled);
   if(isCancelled == false)
   {
     isCancelled = true;