gistfile1.py

import time
from redis import ConnectionPool, Redis

class WaitingConnectionPool(ConnectionPool):
    "Connection Pool that blocks if a connection is not available"
    def make_connection(self):
        while True:
            if self._created_connections >= self.max_connections:
                time.sleep(0.01)
        self._created_connections += 1
        return self.connection_class(**self.connection_kwargs)


pool = WaitingConnectionPool('localhost', port=6379, max_connections=10)
redis = Redis(connection_pool=pool)