4

我探索了一些解决方案，但没有取得多大成功。我有两个 python 进程（使用子进程中的 Popen 创建）和一个 mysql 表（称为persone），其中包含一行两列：Age:0, id:1. 一个进程选择该行，获取它的年龄并将其递增一。它这样做了 1000 次。第二个做同样的事情，但减少它。我并行运行每个进程。

从理论上讲，我希望最终年龄保持在零。问题是我在 mymain.py 的末尾不断获得介于 100 和 -100 之间的随机值，我猜这意味着有同时完成的访问，破坏了数据库。我想知道我错过了什么？

这是我用来测试的代码：

ajoutAge.py

import MySQLdb as lite

num=1000
connexion = lite.connect(host="localhost", user="root", passwd="123", db="test")
with connexion:
    for i in range(num):
       cur = connexion.cursor()
       cur.execute('start transaction')
       cur.execute('select Age from persone where id=1')
       age = cur.fetchone()[0]
       cur.execute('update persone set Age='+str(age+1)+' where id=1')
       # cur.execute('rollback')
       cur.execute('commit')
print "ajout Done"

retraitAge.py

import MySQLdb as lite

num=1000
connexion = lite.connect(host="localhost", user="root", passwd="123", db="test")
with connexion:
    for i in range(num):
        cur = connexion.cursor()
        cur.execute('start transaction')
        cur.execute('select Age from persone where id=1')
        age = cur.fetchone()[0]
        cur.execute('update persone set Age='+str(age-1)+' where id=1')
        cur.execute('commit')
print "retrait Done"

我的主程序

from subprocess import Popen

a=Popen("python ajoutAge.py", shell=True)
aa=Popen("python ajoutAge.py", shell=True)
b=Popen("python retraitAge.py", shell=True)
bb=Popen("python retraitAge.py", shell=True)

a.communicate()
aa.communicate()
b.communicate()
bb.communicate()
print "Main done"

我的表使用 InnoDB 作为存储引擎。

4

1 回答 1

3

您正在创建一个竞争条件。

每次您选择当前年龄时，它和您的更新之间都会有一瞬间。在那一瞬间，另一个过程可能（并且显然有时是）更新值。

因此，在第一个过程中，当您将值更新为 age+1 时，它会根据稍微过时的值递增。

要解决此问题，您有几个选择：

  • SELECT ... FOR UPDATE，它会锁定该行，防止其他进程在您完成事务之前对其进行修改。你需要确保你没有提交你的 SELECT 事务，这会释放锁，允许另一个竞争条件。

  • UPDATE persone SET age = age+1 WHERE id=1（或者age=age-1当然）。换句话说，在您更改值的同一表达式中读取值，因此它是原子的，没有并发进程可以“潜入”并在两者之间进行更改。

于 2013-03-12T00:44:04.000 回答