From b2626237300bab6f4a26cb391dbfe718c0f9aeca Mon Sep 17 00:00:00 2001
From: Xie Han <63350856@qq.com>
Date: Mon, 19 Aug 2024 17:54:31 +0800
Subject: [PATCH] Lock when clearing resp.

---
 src/factory/RedisTaskImpl.cc | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/factory/RedisTaskImpl.cc b/src/factory/RedisTaskImpl.cc
index 9e3e239a87..1ed24f08d2 100644
--- a/src/factory/RedisTaskImpl.cc
+++ b/src/factory/RedisTaskImpl.cc
@@ -388,7 +388,9 @@ ComplexRedisSubscribeTask::SubscribeWrapper::next_in(ProtocolMessage *message)
 	task_->watching_ = true;
 	task_->extract_(task_);
 
+	task_.mutex.lock();
 	task_->clear_resp();
+	task_.mutex.unlock();
 	return task_->finished_ ? NULL : &task_->resp;
 }