From 708036e26d2409a7fba972b8d492d0ac3ca4c094 Mon Sep 17 00:00:00 2001 From: Taishi Kasuga Date: Sat, 12 Aug 2023 07:59:07 +0900 Subject: [PATCH] perf: lessen wasting time for pubsub --- lib/redis_client/cluster/pub_sub.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/redis_client/cluster/pub_sub.rb b/lib/redis_client/cluster/pub_sub.rb index de1811dc..02893943 100644 --- a/lib/redis_client/cluster/pub_sub.rb +++ b/lib/redis_client/cluster/pub_sub.rb @@ -22,7 +22,7 @@ def close def take_message(timeout) @worker = subscribe(@client, timeout) if @worker.nil? - return if @worker.join(0.01).nil? + return if @worker.alive? message = @worker[:reply] @worker = nil