Skip to content

Commit b9abc60

Browse files
authored
fix: prevent race condition for socket (#134)
1 parent 2433137 commit b9abc60

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

lib/redis_client/cluster/pipeline.rb

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,9 +155,8 @@ def execute # rubocop:disable Metrics/AbcSize, Metrics/CyclomaticComplexity, Met
155155
end
156156
end
157157

158+
threads.each(&:join)
158159
threads.each do |t|
159-
t.join
160-
161160
if t.thread_variable?(:replies)
162161
all_replies ||= Array.new(@size)
163162
@pipelines[t.thread_variable_get(:node_key)]

0 commit comments

Comments
 (0)