1

我正在使用 django-channel 实现一项服务，我已经对我的问题做了一些解释，但是您可以向下滚动到底部我提出问题并忽略它们。

在这项服务中，我使用异步缓存系统来提高服务的性能。写入此缓存会引发竞争条件问题。这是这个缓存的两个主要功能

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

现在，如果您仔细观察并接受过一些操作系统教育，您会发现协程 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

当且仅当代码中的信号量在组通道中共享时，此方法才能解决我的问题。

所以这是我要问的事情，如果您能回答任何问题，我可以解决我的问题：

  1. 如何在两个协程之间共享一个对象的实例（在我的两个组通道之间的问题中）？
  2. 在 python 中，当你执行 an_instance.str() 时，你会得到一些显示实例的内存地址的东西......我可以用那个地址获取那个特定的实例吗？
  3. 除了我的问题（使用信号量）之外，我的问题的任何其他解决方案将不胜感激。
4

1 回答 1

0

如何获取/释放外部范围内的锁（协程 1）。

无论如何，各种锁定系统都允许您使用字符串键来识别锁，以便可以从不同的范围获取/释放它。你甚至可以使用像 python-redis-lock 这样的分布式锁。

于 2020-03-30T11:05:15.377 回答