在GAE中,我使用任务队列进行某些数据更新。
我的queue.xml文件如下所示
<queue>
<name>data-processing</name>
<rate>20/s</rate>
</queue> 我的队列处理servlet使每个任务的信用减少了1。在处理过程中,它需要检查信贷可用性,只有在信贷可用的情况下才能进一步进行。
信用被存储在一个表中,并在任务完成时得到更新。
我把任务看作线程,并担心同步问题。
如果两个或多个任务同时查询/更新信用表,怎么办?我需要创造一些锁定机制吗?如果是,那怎么做?
发布于 2010-06-21 10:03:29
是的,你确实需要同步。您通常会更新读-修改-写入方案中的学分:首先读取可用的学分,减去一个,然后将其余的学分写回去。如果两个任务同时执行,一个任务可能会覆盖另一个任务的结果,从而导致存储一个不正确的信用计数。(除非存在用于Memcache的原子指令,但对我认为的数据存储没有原子指令)。
您可以使用事务来解决这个问题,请参阅http://code.google.com/appengine/docs/java/datastore/transactions.html。
发布于 2010-06-21 11:31:09
App任务队列负责计算执行率本身。除了配置queue.xml之外,您不需要做任何事情,就像您已经做的那样。
https://stackoverflow.com/questions/3083591
复制相似问题