avoid push when evicting

OpenAtomFoundation · Aug 16, 2024 · 64fc4de · 64fc4de
1 parent b5b97e7
commit 64fc4de
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/pikiwidb.cc b/src/pikiwidb.cc
@@ -117,7 +117,7 @@ void PikiwiDB::ScanEvictedBlockedConnsOfBlrpop() {
   for (auto& it : key_to_blocked_conns) {
     auto& conns_list = it.second;
     for (auto conn_node = conns_list->begin(); conn_node != conns_list->end();) {
-      if (conn_node->is_done_->load()) {
+      if (conn_node->is_done_->exchange(true)) {
         conn_node = conns_list->erase(conn_node);
       } else if (conn_node->IsExpired()) {
         PClient* conn_ptr = conn_node->GetBlockedClient();