diff --git a/curvefs/src/client/kvclient/kvclient_manager.cpp b/curvefs/src/client/kvclient/kvclient_manager.cpp
index c87630758b..b72a356fa6 100644
--- a/curvefs/src/client/kvclient/kvclient_manager.cpp
+++ b/curvefs/src/client/kvclient/kvclient_manager.cpp
@@ -64,9 +64,11 @@ void KVClientManager::Uninit() {
 void KVClientManager::Set(std::shared_ptr<SetKVCacheTask> task) {
     threadPool_.Enqueue([task, this]() {
         std::string error_log;
+        kvClientManagerMetric_->setQueueSize << 1;
         task->res =
             client_->Set(task->key, task->value, task->length, &error_log);
-        if (task->res) {
+        kvClientManagerMetric_->setQueueSize << -1;
+        if (task->res) { 
             kvClientManagerMetric_->count << 1;
         }
         OnReturn(&kvClientManagerMetric_->set, task);
@@ -99,9 +101,11 @@ void KVClientManager::Get(std::shared_ptr<GetKVCacheTask> task) {
     threadPool_.Enqueue([task, this]() {
         std::string error_log;
         memcached_return_t retCode;
+        kvClientManagerMetric_->getQueueSize << 1;
         task->res = client_->Get(task->key, task->value, task->offset,
                                  task->valueLength, &error_log, &task->length,
                                  &retCode);
+        kvClientManagerMetric_->getQueueSize << -1;
         UpdateHitMissMetric(retCode, kvClientManagerMetric_.get());
         OnReturn(&kvClientManagerMetric_->get, task);
     });
diff --git a/curvefs/src/client/metric/client_metric.h b/curvefs/src/client/metric/client_metric.h
index bfbf0f3373..3253287ff9 100644
--- a/curvefs/src/client/metric/client_metric.h
+++ b/curvefs/src/client/metric/client_metric.h
@@ -317,6 +317,10 @@ struct KVClientManagerMetric {
     bvar::Adder<uint64_t> hit;
     // kvcache miss
     bvar::Adder<uint64_t> miss;
+    // kvcache getQueueSize
+    bvar::Adder<uint64_t> getQueueSize;
+    // kvcache setQueueSize
+    bvar::Adder<uint64_t> setQueueSize;
 
     explicit KVClientManagerMetric(const std::string& name = "")
         : fsName(!name.empty() ? name
@@ -325,7 +329,9 @@ struct KVClientManagerMetric {
           set(prefix, fsName + "_set"),
           count(prefix, fsName + "_count"),
           hit(prefix, fsName + "_hit"),
-          miss(prefix, fsName + "_miss") {}
+          miss(prefix, fsName + "_miss"),
+          getQueueSize(prefix, fsName + "_getQueueSize"),
+          setQueueSize(prefix, fsName + "_setQueueSize") {}
 };
 
 struct MemcacheClientMetric {