如何将项目原子添加到memcached的列表（在Python）

Question

看哪，下面我简单的Python的memcached代码：

import memcache 
memcache_client = memcache.Client(['127.0.0.1:11211'], debug=True) 
key = "myList" 
obj = ["A", "B", "C"] 
memcache_client.set(key, obj) 

现在，假设我想一个元素“d”附加到缓存为myList列表，我怎样才能做到原子性？

我知道这是错误的，因为它不是原子：

memcache_client.set(key, memcache_client.get(key) + ["D"]) 

上面的语句包含的竞争条件。如果另一个线程在恰当的时刻执行这个相同的指令，其中一个更新会被破坏。

我该如何解决这种竞争条件？我如何更新以原子方式存储在memcached中的列表或字典？

Answer 1

这里的蟒蛇客户端API的相应功能

https://cloud.google.com/appengine/docs/python/memcache/clientclass#Client_cas

而且这里有一个nice tutorial由Guido van Rossum的。希望他最好解释蟒蛇的东西比我;）

下面的代码看起来应该像你的情况：

memcache_client = memcache.Client(['127.0.0.1:11211'], debug=True) 
key = "myList" 
while True: # Retry loop, probably it should be limited to some reasonable retries 
    obj = memcache_client.gets(key) 
    assert obj is not None, 'Uninitialized object' 
    if memcache_client.cas(key, obj + ["D"]): 
    break 

的整个工作流程是一样的：首先你取一个值（W /一些绑定到键的内部信息），然后修改获取的值，然后尝试在内存缓存中对其进行更新。唯一的区别是该值（实际上是键/值对）被检查为它没有从并行进程中同时改变。在后一种情况下，调用失败，您应该从头开始重试工作流程。另外，如果您有多线程应用程序，则每个memcache_client实例可能应该是线程本地的。

另外不要忘记，对于简单的整型计数器来说，incr（）和decr（）方法本质上是“原子”的。

Answer 2

如果您不想接收竞争条件，那么您必须使用来自线程模块的锁定原语。例如

lock = threading.Lock() 

def thread_func(): 
    obj = get_obj() 
    lock.acquire() 
    memcache_client.set(key, obj) 
    lock.release()