core.py 文件源码

def __init__(self, name, ttl=None):
        """Init Lock object.
        :param name: name of the lock
        :param ttl: number of seconds after acquiring when the lock must
        be automatically released.
        """
        self._redis_con = ConnectionPool().get_connection()
        self._lock = None
        self.name = self.lock_prefix + name
        self.ttl = ttl