我正在用django通道实现一项服务,我已经对我的问题做了一些解释,但你可以向下滚动到我提出问题的底部,然后忽略它们。
在这个服务中,我使用异步缓存系统来提高服务的性能。写入此缓存会引发竞争条件问题。以下是这个缓存的两个主要功能
async def get_room_data_dict(self):
data = await self.cache_client.get(self.key)
return data
async def set_room_data_dict(self, room_data_dict):
is_success = await self.cache_client.set(self.key, room_data_dict)
return is_success
现在这个方法的问题来了。
### coroutine 1 ###
room_data_dict = await cache_manager.get_room_data_dict()
# In the line below a context switch occurs and coroutine 2 continues to do some tasks
new_room_data_dict = await do_somthing(room_data_dict)
# coroutine 1 continue but room_data_dict is the old one and coroutine 1 going to save it so what coroutine 2 did is actually not applied
await cache_manager.set_room_data_dict(new_room_data_dict)
### coroutine 2 ###
# this coroutine continues without a context switch
room_data_dict = await cache_manager.get_room_data_dict()
new_room_data_dict = await do_somthing(room_data_dict)
await cache_manager.set_room_data_dict(new_room_data_dict)
# gets back to coroutine 1 and continues its code
现在,如果你仔细观察并接受了一些操作系统教育,你会发现coroutine 2对room_data_dict所做的更改实际上并没有应用。
这是我应该做的事情来防止这个问题,我会改变下面的功能
async def get_room_data_dict(self):
await self.room_data_dict_semaphore.acquire()
data = await self.cache_client.get(self.key)
return data
async def set_room_data_dict(self, room_data_dict):
is_success = await self.cache_client.set(self.key, room_data_dict)
self.room_data_dict_semaphore.release()
return is_success
如果并且只有当代码中的信号量在组通道中共享时,这种方法才能解决我的问题。
以下是我要问的问题,如果你能回答其中的任何一个,我就能解决我的问题:
- 如何在两个协程之间共享对象的实例(在两个组通道之间的问题中(
- 在python中,当您执行an_instance.str((时,您会得到一些显示实例内存地址的内容。。。我能得到那个地址的特定实例吗
- 除我的问题外,任何其他解决方案(使用信号量(都将不胜感激
如何获取/释放外部作用域中的锁(协程1(。
无论如何,各种锁定系统允许您使用字符串键来识别锁,这样就可以从不同的范围获取/释放它。您甚至可以使用像python-redis锁这样的分布式锁。