阅读 - >更改 - >保存。线程安全

Question

此代码应该在玩家进入游戏时自动连接。
但问题是两个用户同时尝试连接 - 在这种情况下，第二个用户可以轻松地覆盖第一个用户（'room_1'变量）所做的更改。

我怎么能使它线程安全？

 
def join(userId): 
    users = memcache.get('room_1') 
    users.append(userId) 
    memcache.set('room_1', users) 
    return users 

我使用的是Google App Engine（python），并将实现简单的游戏服务器来交换由Adobe Stratus提供的同伴。

Answer 1

这样的事情可能工作。

class Room(db.Model): 
    users = db.StringListProperty() 

def join(userId): 
    def _transaction(): 
     room = Room.get_by_key_name('room_1') 
     if room is None: 
      room = Room(key_name = 'room_1', users = []) 
     room.users.append(userId) 
     room.put() 
     return room.users 
    return db.run_in_transaction(_transaction) 

Answer 2

您的房间列表上需要一个read/write lock。

Answer 3

memcache仅仅是一个缓存，并且它通常不适合原子数据存储，这正是您尝试使用它的原因。我建议使用GAE数据存储，而不是这种问题。

Answer 4

在Memcache中，INCR操作是原子操作，并返回递增的新值。例如，如果将值设置为0，则可以通过增加值来乐观地获取锁。如果你得到1，你可以安全地写出一个值。如果你回到2，你应该重试交易。

http://code.google.com/appengine/docs/python/memcache/functions.html