python - 多线程 python 应用程序在运行其线程时挂起

Question

我正在尝试创建一个可用作 DBus 服务的 MainObject。这个 MainObject 应该始终保持对其他对象/进程的响应，并且即使在处理它的项目时也是如此。因此，项目在单独的线程中一个接一个地处理(队列式)。您可以通过 DBus 或命令行向 MainObject 添加项目。我简化了示例(没有 dbus，没有命令行)来显示我的问题。

我的问题是，如果我重新启用“tt.join()”，应用程序会按预期工作，但会阻塞其他进程。难怪 tt.join 使应用程序等待，直到单独的线程完成其工作。另一方面，如果“tt.join()”保持禁用状态，应用程序不会阻止外部 dbus 事件，但永远不会出现“ThreadTest done!” (看实际输出)

我想要的是我的预期输出，但应用程序应保持响应。

#!/usr/bin/python2.5

import gobject
import threading
import re
import time

class ThreadTest(threading.Thread):

  def __init__(self):
    threading.Thread.__init__ (self)    
    print '  ThreadTest created!'

  def run(self):
    print '  ThreadTest running ...'
    time.sleep(1)
    print '  ThreadTest done!'
    return True

class MainObject():
  def __init__(self):
    self.timer = gobject.timeout_add(1000, self.update)
    self.loop  = gobject.MainLoop()
    print 'MainObject created!'

  def update(self):
    print 'MainObject updating ...'
    if self.check_running() == False:
      tt = ThreadTest()
      tt.start()
      #tt.join()
    return True

  def check_running(self):
    running = False
    expr = re.compile('ThreadTest')
    for threadstr in threading.enumerate():
      matches = expr.findall(str(threadstr))
      if matches:
        running = True
    return running  


mo = MainObject()
mo.loop.run()

预期输出:

MainObject created!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
  ThreadTest done!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
  ThreadTest done!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
  ThreadTest done!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
  ThreadTest done!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
  ThreadTest done!

实际输出:

MainObject created!
MainObject updating ...
  ThreadTest created!
  ThreadTest running ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...
MainObject updating ...

Answer 1

默认情况下，gobject 绑定(bind)不是多线程感知的。请在导入 gobject 后尝试执行以下操作:

gobject.threads_init()