Dbus/GLib 主循环、后台线程

Question

我一般从 DBus 和事件驱动编程开始。我试图创建的服务实际上由三个部分组成，但其中两个部分实际上是“服务器”。

1) 实际的 DBus 服务器通过 HTTPS 与远程网站通信、管理会话并向客户端传送信息。

2) 服务的另一部分每 2 分钟调用一次保持活动页面，以使会话在外部网站上保持活动状态

3) 客户端调用服务以从服务检索信息。

我找到了一些简单的示例程序。我正在尝试使它们适应原型#1 和#2。而不是为两者构建单独的程序。我认为我可以在一个单线程进程中运行它们。

我看到的问题是我在保持活动线程中调用 time.sleep(X) 。线程进入睡眠状态，但永远不会醒来。我认为 GIL 不是由 GLib 主循环释放的。

这是我的线程代码：

class Keepalive(threading.Thread):
  def __init__(self, interval=60):
    super(Keepalive, self).__init__()
    self.interval = interval
    bus = dbus.SessionBus()
    self.remote = bus.get_object("com.example.SampleService", "/SomeObject")

  def run(self):
    while True:
        print('sleep %i' % self.interval)
        time.sleep(self.interval)
        print('sleep done')
        reply_status = self.remote.keepalive()
        if reply_status:
            print('Keepalive: Success')
        else:
            print('Keepalive: Failure')

从打印语句中，我知道睡眠开始，但我从未看到“睡眠完成”。

这是主要代码：

if __name__ == '__main__':
try:
    dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)

    session_bus = dbus.SessionBus()
    name = dbus.service.BusName("com.example.SampleService", session_bus)
    object = SomeObject(session_bus, '/SomeObject')

    mainloop = gobject.MainLoop()

    ka = Keepalive(15)
    ka.start()
    print('Begin main loop')
    mainloop.run()
except Exception as e:
    print(e)
finally:
    ka.join()

一些其他观察结果：

我看到“开始主循环”消息，所以我知道它正在获得控制。然后，我看到“sleep %i”，之后就什么也没有了。

如果我^C，那么我会看到“睡眠完成”。大约 20 秒后，我从 self.run() 收到异常，远程应用程序没有响应：

DBusException：org.freedesktop.DBus.Error.NoReply：未收到回复。可能的原因包括：远程应用程序未发送回复、消息总线安全策略阻止回复、回复超时或网络连接中断。

在服务器中运行保持活动代码的最佳方式是什么？

谢谢，

Answer 1

使用 gobject 时，您必须通过调用 gobject.threads_init() 显式启用多线程。有关背景信息，请参阅 PyGTK 常见问题解答。

除此之外，出于您所描述的目的，超时似乎更合适。使用方式如下：

# Enable timer
self.timer = gobject.timeout_add(time_in_ms, self.remote.keepalive)
# Disable timer
gobject.source_remove(self.timer)

这会每隔 time_in_ms（毫秒）秒调用 keepalive 函数。更多详细信息，请再次参阅 PyGTK 参考。