redis.py 文件源码

def sync(self):
        if not self._cache:
            return

        with self._cache_write_lock, self._storage.redis.pipeline() as pipeline:
            for key, entry in self._cache.items():
                f = StringIO()
                p = Pickler(f, self._protocol)
                p.dump(entry)
                pipeline.hset(self._hash_key, key, f.getvalue())

            pipeline.execute()
            self._cache.clear()