the Redis class is now a thread local. This means you can safely pass it around between threads and connections will get swapped out correctly.

Author: andymccurdy

redis/client.py

@@ -143,7 +143,7 @@ def zset_score_pairs(response, **options):
     return zip(response[::2], map(float, response[1::2]))
 
 
-class Redis(object):
+class Redis(threading.local):
     """
     Implementation of the Redis protocol.
     

tests/connection_pool.py

@@ -1,4 +1,6 @@
 import redis
+import threading
+import time
 import unittest
 
 class ConnectionPoolTestCase(unittest.TestCase):
@@ -17,4 +19,27 @@ def test_multiple_connections(self):
         r2.select('localhost', 6379, db=9)
         self.assertEquals(r1.connection, r2.connection)
 
-    
+    def test_threaded_workers(self):
+        r = redis.Redis(host='localhost', port=6379, db=9)
+        r.set('a', 'foo')
+        r.set('b', 'bar')
+        
+        def _info_worker():
+            for i in range(50):
+                _ = r.info()
+                time.sleep(0.01)
+            
+        def _keys_worker():
+            for i in range(50):
+                _ = r.keys()
+                time.sleep(0.01)
+            
+        t1 = threading.Thread(target=_info_worker)
+        t2 = threading.Thread(target=_keys_worker)
+        t1.start()
+        t2.start()
+        
+        for i in [t1, t2]:
+            i.join()
+        
+