Avoid data corruption in #queue.

Potential fix for redis#878.
ioquatix · Oct 28, 2019 · 82d81b6 · 82d81b6
1 parent 6b894f8
commit 82d81b6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/redis.rb b/lib/redis.rb
@@ -100,7 +100,9 @@ def call(*command)
   # See http://redis.io/topics/pipelining for more details.
   #
   def queue(*command)
-    @queue[Thread.current.object_id] << command
+    synchronize do
+      @queue[Thread.current.object_id] << command
+    end
   end
 
   # Sends all commands in the queue.