Python 多线程

Question

我有这样的场景:

使用 Zope/Plone 和一些我的 python API 创建的网页。有一个网页，称之为“a”，它通过 python 方法调用数据库(Postgres)并返回一些信息。在页面“a”上，您可以“离线”修改数​​据库数据(我的意思是更改不会立即写入数据库，而是在您按“保存”并调用 python API 方法时的第二刻写入)。因此，想象一下这样的场景:一个名为“Sam”的用户加载页面并开始修改数据。同时，一个名为“Sara”的用户通过页面“a”单击“保存”来修改数据库。现在 Sam 没有实际的数据库数据:他将按下“保存”并覆盖 Sara 的数据更改。

我的页面上会收到实时提醒。我想我可以做这样的事情:

进行不可阻止的 AJAX 调用，并继续进行页面渲染。 AJAX 调用一个 python 方法，该方法创建一个执行无限循环的线程(在“X”条件下)。当我在数据库上写入数据时，我将调用一个函数来更改“X 条件”，停止线程并返回 AJAX。

此外，我无法锁定数据库，因为我必须向每个想要修改我的数据库的用户提供免费访问权限。

我的问题是:如何识别 python 线程？我刚刚看到从 Thread 继承的类上的每个方法都需要“self”作为参数。此外，当我访问“a”页面时，我必须调用线程，这将位于代码中的某个位置(例如“线程模块”上)，但插入位于另一个模块上。那么，我怎样才能实现我的想法呢？

如果有人有替代想法，请毫无问题地告诉我:)

Answer 1

您正在讨论的问题领域通常称为“并发”。由于当目标项中的任何字段发生更改时，您的方法会警告或阻止用户更新，因此该方法通常称为“悲观并发”。实现此目的的一种方法是跟踪项目在被选择时的样子，并且仅当数据库版本看起来与您选择的版本完全相同或自特定时间以来未更新时才更新(时间戳字段可能会有所帮助) )。您还可以尝试乐观并发，其中仅检查一个用户已更新并保存回数据存储的字段是否由其他用户更新。如果您选择支持并发的 ORM 库，这两种方法都是最简单的。

我最喜欢的 python Web 库是 django，这里有一个关于您想要解决的相同情况的问题:Django: How can I protect against concurrent modification of database entries 。我希望它有帮助。

按照您建议的方式处理并发是可行的，但在大多数情况下应该避免。我以前曾在向具有复杂对象的大型系统添加并发性时这样做过，这些对象具有广泛的副作用并且没有统一的数据访问(在系统的生命周期中有大约 5 种数据访问方法，这是一个丰富多彩的系统)。这是处理并发性的容易出错且复杂的方法(我认为我有一个客户端应用程序，并在描述对象的类型和标识符的数据表中标记“已 checkout ”项目后启动了观察者线程， checkout 它的用户，何时 checkout ，以及有效期多长，以防 checkout 对象的客户端在完成后未能将其 checkin )。

如果您设置不使用 ORM 并在项目发生更改时向用户显示一条消息，请尝试关闭上次更新的时间戳列，然后让您的 ajax 调用检查上次更新时间是否为大于您第一次加载该项目时的值。因此，如果您编写通用方法来执行此操作，则只需要表名称、主键和时间戳。

webservice 方法可能如下所示:

def is_most_current(table_name, id):
    db = MySQLdb.connect(passwd="moonpie",db="thangs")
    c=db.cursor()
    c.execute("SELECT last_updated from %s where id = %s", (table_name, id))
    return c.fetchone()

对于 python 多线程库，由于 python 的全局互锁问题，python 线程令人困惑并且性能较差，在许多情况下您实际上可能希望生成一个新进程(多处理库相当等效并且并行性能更好)处理场景)。至于“self”，这是对您正在处理的类实例的引用的Pythonic约定，很像C类语言中的“this”。您可以在构造线程时为其指定唯一的名称，从而轻松识别该线程。请参阅multiprocessing或threading文档以获取更多信息。如果您可以避免使用线程来解决此问题，我建议您这样做。