python - asyncore 回调启动线程...可以吗？

Question

我不熟悉 asyncore ，并且除了一些扭曲教程的介绍外，对异步编程的了解非常有限。

我最熟悉线程并在我所有的应用程序中使用它们。一个特定的应用程序使用 couchdb数据库作为其接口(interface)。这涉及对数据库进行长轮询以查找更改和更新。我用于 couchdb 的模块是 couchdbkit .它使用 asyncore 循环来监视这些更改并将它们发送到回调。

因此，我从这个回调中得出我启动工作线程的地方。混合异步和线程编程似乎有点粗暴。我真的很喜欢 couchdbkit，但不想在我的程序中引入问题。

所以，我的问题是，从异步回调中触发线程是否安全？

这是一些代码...

def dispatch(change):
    global jobs, db_url # jobs is my queue
    db = Database(db_url)
    work_order = db.get(change['id']) # change is an id to the document that changed. 
                                  # i need to get the actual document (workorder)

    worker = Worker(work_order, db) # fire the thread
    jobs.append(worker)
    worker.start()
    return


main()
.
.
.

consumer.wait(cb=dispatch, since=update_seq, timeout=10000) #wait constains the asyncloop.

更新:

仔细研究了这个之后，我还有一个问题要问 couchdbkit 专家。可能会有数百个线程使用数据库。正如您在我的代码示例中看到的，我正在为每个线程实例化一个 couchdbkit.Database 对象。我认为这可能是浪费。那么，在线程之间全局使用单个数据库对象是否可以？

Answer 1

每次服务器返回一个新文档时，这不会创建一个新线程吗？我猜你最好在 在服务器上调用任何东西之前创建一个工作线程池，然后将一个作业添加到队列中，这些线程正在从 dispatch 中读取它们的工作 方法。

但没有理由认为混合线程和异步编程是危险的。