跨多个进程的 Python threading.Condition() 功能

Question

我正在使用 mod_wsgi 编写 WSGI 应用程序。我想要有很多并发连接的能力。 mod_wsgi 为每个请求启动一个新进程，从而无法使用 threading.Condition() 来通知从一个线程到另一个线程的更改。

我知道有几种不同的方法可以在不同的运行进程（RPC、AMQP、d-bus、Jabber）之间提供实时消息传递，但我具体寻找的是接近单行 threading.wait( ) 和 threading.notifyAll()。

当我没有使用 mod_wsgi，而只是运行多个线程时，这基本上就是我为我工作的内容。显然，这两个函数是由不同的线程运行的：

def put_value:
    # user has given a new value
    # update in DB, then notify any waiting threads

    my_condition.acquire()
    my_condition.notifyAll()
    my_condition.release()

def get_value:
    # user has requested to receive a new value as of this point
    # we will return a value as soon as we are notified it has changed

    my_condition.acquire()
    my_condition.wait()
    my_condition.release()
    # return some val out of the DB

我再次寻找的是与单行 threading.wait() 和 threading.notifyAll() 接近的东西。我不介意设置一些配置，甚至在后台运行一些东西 - 但我有相当多的代码依赖于在请求中间停止和等待的能力，直到通知它可以继续。

Answer 1

在mod_wsgi配置中，设置processes=1。请参阅 http://code.google.com/p/modwsgi/wiki/ConfigurationDirectives# WSGIDaemonProcess 了解详细信息。