将 Async/Await 与 Pickle 一起使用

Question

我是async/await 的新手，遇到了一些困惑。 pickle 应该以某种方式成为 awaited 吗？

例如，假设我有以下async 类方法：

async def get(self, key):
    redis = await self.getRedis()
    data = await redis.get(key)
    if not data:
        return None

    return pickle.loads(data)

async def set(self, key, value, ttlInSeconds):
    pickled = pickle.dumps(value)

    redis = await self.getRedis()
    await redis.setex(key, pickled, ttlInSeconds)

如果我正在序列化或反序列化一个大对象，pickle 上的整个循环不会阻塞吗？出于实际目的，对于较小的对象，这种瞬时阻塞是否可以接受？谢谢！

Answer 1

你应该阻止酸洗，因为如果你的类中的另一个方法可以在set()仍在处理pickle.dumps()时执行和修改value，那么酸洗的数据将被破坏。

即使该对象一次肯定只有一个实例，这也适用。

顺便说一句，get()，您可以将await 替换为return pickle.loads(data)，因为您不太可能修改尚未从该方法返回的数据。