Prefer using a local object rather than Thread.current.

Author: djanowski

lib/redis.rb

@@ -49,6 +49,7 @@ def self.current=(redis)
   def initialize(options = {})
     @options = options.dup
     @original_client = @client = Client.new(options)
+    @queue = Hash.new { |h, k| h[k] = [] }
 
     super() # Monitor#initialize
   end
@@ -101,7 +102,7 @@ def call(*command)
   # See http://redis.io/topics/pipelining for more details.
   #
   def queue(*command)
-    _queue << command
+    @queue[Thread.current.object_id] << command
   end
 
   # Sends all commands in the queue.
@@ -111,9 +112,9 @@ def queue(*command)
   def commit
     synchronize do |client|
       begin
-        client.call_pipelined(_queue)
+        client.call_pipelined(@queue[Thread.current.object_id])
       ensure
-        _queue.clear
+        @queue.delete(Thread.current.object_id)
       end
     end
   end
@@ -2778,10 +2779,6 @@ def _subscription(method, timeout, channels, block)
     end
   end
 
-  def _queue
-    Thread.current[:redis_queue] ||= []
-  end
-
 end
 
 require "redis/version"